Постоянные ошибки в Telegram боте

import logging
import os
from telegram import Update
from telegram.ext import (
    Application,
    CommandHandler,
    MessageHandler,
    filters,
    CallbackContext
)
from telegram.request import HTTPXRequest
from google.cloud import dialogflow
import asyncio
 
# Базовая настройка логирования
logging.basicConfig(
    format='%(asctime)s - %(levelname)s - %(message)s',
    level=logging.INFO
)
 
# Настройки бота
TELEGRAM_TOKEN = '..........'
DIALOGFLOW_PROJECT_ID = '...........'
 
# Настройка переменных окружения для Dialogflow
os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = "C:\\Users\\user\\Downloads\\small-talk-bs9o-32f457b76283.json"
 
 
# Обработчик команды /start
async def start_command(update: Update, context: CallbackContext):
    await update.message.reply_text('Привет! Я твой виртуальный помощник.')
 
 
# Обработчик текстовых сообщений
async def text_message(update: Update, context: CallbackContext):
    try:
        session_client = dialogflow.SessionsClient()
        session = session_client.session_path(DIALOGFLOW_PROJECT_ID, update.message.chat_id)
 
        text_input = dialogflow.types.TextInput(
            text=update.message.text,
            language_code='ru'
        )
 
        query_input = dialogflow.types.QueryInput(text=text_input)
        response = session_client.detect_intent(
            session=session,
            query_input=query_input
        )
 
        if response.query_result.fulfillment_text:
            await update.message.reply_text(response.query_result.fulfillment_text)
        else:
            await update.message.reply_text('Не понял вас. Попробуйте спросить иначе.')
 
    except Exception as e:
        logging.error(f"Ошибка обработки текста: {str(e)}")
        await update.message.reply_text('Произошла ошибка. Попробуйте позже.')
 
 
# Обработчик команды /help
async def help_command(update: Update, context: CallbackContext):
    await update.message.reply_text(
        "Доступные команды:\n"
        "/start - начать диалог\n"
        "/help - показать список команд"
    )
 
 
# Основная функция запуска
async def main():
    request_kwargs = {
        'read_timeout': 300,  # увеличенный таймаут чтения
        'connect_timeout': 120,  # увеличенный таймаут подключения
        'write_timeout': 240  # увеличенный таймаут записи
    }
 
    app = Application.builder() \
        .token(TELEGRAM_TOKEN) \
        .request(HTTPXRequest(**request_kwargs)) \
        .build()
 
    # Регистрация обработчиков
    app.add_handler(CommandHandler("start", start_command))
    app.add_handler(CommandHandler("help", help_command))
    app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, text_message))
 
    try:
        logging.info("Запуск бота...")
        await app.initialize()
 
        # Корректный запуск бота
        await app.updater.start_polling(
            poll_interval=1.0,
            timeout=300,  # увеличенный таймаут опроса
            allowed_updates=Update.ALL_TYPES,
            drop_pending_updates=True
        )
        logging.info("Бот запущен успешно")
 
        # Используем run_app вместо run_forever
        await app.run_polling()
 
    except asyncio.TimeoutError:
        logging.error("Превышено время ожидания подключения к Telegram API")
    except Exception as e:
        logging.error(f"Ошибка при запуске бота: {str(e)}")
    finally:
        try:
            # Проверяем, запущен ли апдейтер перед остановкой
            if app.updater.running:
                await app.shutdown()
                logging.info("Ресурсы очищены")
        except Exception as e:
                logging.error(f"Ошибка при очистке ресурсов: {str(e)}")
 
        except Exception as e:
            logging.error(f"Ошибка при завершении работы: {str(e)}")
 
if __name__ == '__main__':
    try:
        asyncio.run(main())
    except Exception as e:
        logging.error(f"Критическая ошибка при запуске: {str(e)}")