@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          # Укажите ваш порт
    )

Как я могу отслеживать изменения в sqlite3 в golang?

2 ответа

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