Как получить исходный вебхук от телеграма?

Пользователь

l_vinton_l

от l_vinton_l , в категории: Python , год назад

у меня есть бот на aiogram 2.25.2, мне нужно при старте бота получить json который присылает телеграм боту, важно то, что мне нужен именно исходный вебхук от телеги, а я могу получить лишь его часть, которую беру из объекта Message

1
2
3

@dp.message_handler(commands=['start'])
async def start(message: types.Message):
     print(message)

15 | 0

2 ответа

Пользователь

jaren

от jaren , год назад

@l_vinton_l В aiogram, начиная с версии 2.x, при использовании стандартных обработчиков, таких как @dp.message_handler, вы получаете обработанные данные, такие как объект Message. Однако, чтобы получить исходные данные вебхука в формате JSON (весь запрос от Telegram API), вам нужно самостоятельно обрабатывать запросы к вебхуку. Для этого можно использовать встроенные возможности aiohttp, который является основой aiogram, и перехватывать вебхуки на уровне HTTP-запросов. Вот пример, как это можно сделать:

Мой пример

from aiogram import Bot, Dispatcher, types
from aiogram.utils.executor import start_webhook
from aiohttp import web
import json


API_TOKEN = 'YOUR_BOT_API_TOKEN'


WEBHOOK_HOST = 'https://site.ru'
WEBHOOK_PATH = '/webhook'
WEBHOOK_URL = f"{WEBHOOK_HOST}{WEBHOOK_PATH}"


bot = Bot(token=API_TOKEN)
dp = Dispatcher(bot)


# Обработчик для команды start
@dp.message_handler(commands=['start'])
async def start(message: types.Message):
    await message.reply("Привет!!!")


# Получаем сырой JSON запрос от Telegram и выводим его
async def handle_webhook(request):
    raw_data = await request.text()  # Получаем сырые данные запроса
    print("Полученный вебхук (сырой JSON):")
    print(raw_data)


    # Обработка JSON данных
    update = types.Update(**json.loads(raw_data))
    
    # Передача обработанных данных в aiogram
    Dispatcher.set_current(dp)
    Bot.set_current(dp.bot)
    await dp.process_update(update)
    
    return web.Response()


# Основная конфигурация для вебхуков
async def on_startup(app):
    await bot.set_webhook(WEBHOOK_URL)


async def on_shutdown(app):
    await bot.delete_webhook()


# Настройка веб-приложения aiohttp
app = web.Application()
app.router.add_post(WEBHOOK_PATH, handle_webhook)


if __name__ == '__main__':
    start_webhook(
        dispatcher=dp,
        webhook_path=WEBHOOK_PATH,
        on_startup=on_startup,
        on_shutdown=on_shutdown,
        skip_updates=True,
        host='localhost',  # Укажите ваш хост
        port=3000          # Укажите ваш порт
    )

2 | 0

Пользователь

ludie

от ludie , 2 месяца назад

@l_vinton_l

Ваш код практически завершен, но есть несколько моментов, которые стоит уточнить и исправить:

WEBHOOK_HOST: Убедитесь, что WEBHOOK_HOST действительно является доменным именем вашего сервера, доступного для Telegram. Оно должно быть публично доступным.
Телеграм токен: Вставьте свой токен бота вместо 'YOUR_BOT_API_TOKEN'.
Настройка webhook: Проверьте, действительно ли ваш сервер может принимать запросы на интерфейсе, указанном в WEBHOOK_URL.
Хост и порт: В настройках start_webhook используйте правильный хост и порт. Если вы разрабатываете локально и используете публичный прокси (например, ngrok), укажите соответствующий WEBHOOK_HOST.
Логи и отладка: Убедитесь, что ваш сервер обрабатывает запросы и выводит журнал с полученными данными.
Обработка ошибок: Добавьте обработку возможных ошибок при обработке запросов и настройки вебхуков.

Вот улучшенный и прокомментированный код:

from aiogram import Bot, Dispatcher, types
from aiogram.utils.executor import start_webhook
from aiohttp import web
import json

API_TOKEN = 'YOUR_BOT_API_TOKEN'

WEBHOOK_HOST = 'https://your-domain.com'
WEBHOOK_PATH = '/webhook'
WEBHOOK_URL = f"{WEBHOOK_HOST}{WEBHOOK_PATH}"

bot = Bot(token=API_TOKEN)
dp = Dispatcher(bot)

# Обработчик для команды start
@dp.message_handler(commands=['start'])
async def start(message: types.Message):
    await message.reply("Привет!!!")

# Получаем сырой JSON запрос от Telegram и выводим его
async def handle_webhook(request):
    raw_data = await request.text()  # Получаем сырые данные запроса
    print("Полученный вебхук (сырой JSON):")
    print(raw_data)

    # Обработка JSON данных
    update = types.Update(**json.loads(raw_data))
    
    # Передача обработанных данных в aiogram
    Dispatcher.set_current(dp)
    Bot.set_current(dp.bot)
    await dp.process_update(update)
    
    return web.Response(status=200)  # Убедитесь вернуть 200

# Основная конфигурация для вебхуков
async def on_startup(app):
    await bot.set_webhook(WEBHOOK_URL)

async def on_shutdown(app):
    await bot.delete_webhook()

# Настройка веб-приложения aiohttp
app = web.Application()
app.router.add_post(WEBHOOK_PATH, handle_webhook)

if __name__ == '__main__':
    start_webhook(
        dispatcher=dp,
        webhook_path=WEBHOOK_PATH,
        on_startup=on_startup,
        on_shutdown=on_shutdown,
        skip_updates=True,
        host='localhost',  # Укажите ваш хост
        port=3000          # Укажите ваш порт
    )

Убедитесь, что работаете в среде, где сервер может принимать HTTP-запросы. Для локальной разработки вам может понадобиться туннелирование, например с помощью ngrok, чтобы открытый URL (WEBHOOK_HOST) указывал на ваш локальный сервер.

0 | 0

Как получить исходный вебхук от телеграма?

2 ответа

Похожие обсуждения: