如何编写python telegram bot日志以将所有消息输出到控制台

据我了解，任务是确保发送到机器人的所有消息的文本都输出到控制台。听起来像是一个中间件任务。此外，中间件必须是外部的，以便消息首先进入其中，然后在处理程序中进行处理。

您可以在官方文档中阅读有关中间件的内容。

中间件代码如下所示：

import logging

from aiogram import BaseMiddleware
from aiogram.types import Message

from typing import Callable, Dict, Awaitable, Any

# Создаем класс мидлвари, унаследованный от
# aiogram'овского BaseMiddleware
class MessageLogMiddleware(BaseMiddleware):

    async def __call__(
        self,
        handler: Callable[[Message, Dict[str, Any]], Awaitable[Any]],
        event: Message,
        data: Dict[str, Any]
    ) -> Any:
        logging.info(event.text) # Выводим текст сообщения
        return await handler(event, data) # Возвращаем обновление хендлерам

# Регистрируем внешнюю миддлварь
dp.message.outer_middleware(MessageLogMiddleware())

这是如何运作的？

文档中有这张精彩的图片：

它清楚地表明消息（或任何其他更新）首先到达外部中间件，在我们的例子中是MessageLogMiddleware。其参数类型handler指定为Callable[[Message, Dict[str, Any]], Awaitable[Any]]。这Message是我们想要捕获的更新类型（我们想要捕获消息）。

当用户向机器人写入内容时，他的消息首先进入外部中间件（我们按照图片进行操作），然后通过过滤器进入简单的中间件，然后仅到达处理程序。

我们在打开路由器之前注册中间件，即直到该行dp.include_router(router)，您将看到所有消息输出到控制台。

完整代码：

import json

import uuid

import logging

import websockets

from typing import Callable, Dict, Awaitable, Any

from aiogram import Bot, types, Dispatcher, Router, F, BaseMiddleware
from aiogram.types import Message
from aiogram.filters import Command


bot.polling(none_stop=True, interval=0)
token = 'токен бота'
runware_api = 'апи нейронки'


class MessageLogMiddleware(BaseMiddleware):

    async def __call__(
        self,
        handler: Callable[[Message, Dict[str, Any]], Awaitable[Any]],
        event: Message,
        data: Dict[str, Any]
    ) -> Any:
        logging.info(event.text) # Выводим текст сообщения
        return await handler(event, data)


bot = Bot(token=token)
dp = Dispatcher()
router = Router()


async def create_image(prompt): # Генерируем картинку
    async with websockets.connect('wss://ws-api.runware.ai/v1') as websocket:
        auth_request = [{"taskType": "authentication","apiKey": runware_api}]
        await websocket.send(json.dumps(auth_request)) # Логинимся и получаем успешный ответ от сервера
        auth_response = await websocket.recv()
        n = 1
        image_request = [{"positivePrompt": prompt,"model": "runware:100@1",'steps':4,'width':512,'height':512,'numberResults':n,'outputType':['URL'],'taskType':'imageInference','taskUUID':uuid.uuid4().hex}]
        await websocket.send(json.dumps(image_request)) # Отправляем запрос на генерацию и получаем картинку
        img = await websocket.recv()
        data = json.loads(img)['data'][0]
        return data

@router.message(Command('start')) # Добавляем ответ на команду /start
async def start(message: types.Message):
    await message.answer('Привет!\nЯ бот для моментальной генерации картинок, отправь мне на английском любой промпт и я в ту же секунду сгенерирую тебе изображение')

@router.message() # Ловим промпты
async def gen(message: types.Message):
    if not message.text:
        return await message.answer('Отправь мне запрос текстом, я не понимаю другие форматы :(')
    msg = await message.answer(f'Начинаю генерацию по запросу:\n\n{message.text}')
    image = await create_image(message.text)
    await message.answer_photo(image['imageURL'], caption=f'Вот ваша генерация по запросу:\n\n{message.text}')
    await bot.delete_messages(message.chat.id, [msg.message_id, message.message_id])

async def main():
    logging.basicConfig(level=logging.INFO) # Выставляем уровень логов на INFO
    dp.message.outer_middleware(MessageLogMiddleware())
    router.message.filter(F.chat.type == 'private')
    dp.include_router(router)
    await dp.start_polling(bot)

if __name__ == '__main__':
    print('Деньги уже текут')
    asyncio.run(main())