多线程中的 Telethon 事件未按预期工作

Question

我想在多线程、多线程中运行 Telethon 事件。

对于下面的代码，我期望的是多线程、并发的独立事件。 await asyncio.sleep( 3 ) 将休眠 3 秒。因此，如果您在电报上向该帐户发送任何文本，它将等待 3 秒，然后给我发回“嗨”。我预计如果我一次发送多个文本，比如说 5 次，它应该等待大约 3 秒，然后立即给我发送“hi”，但不像等待 3 秒，发送“hi”，等待 3 秒，发送“嗨”。 .. 5 次，大约需要 15 秒。这不是我所期望的。

那么，如何修改代码以按预期运行代码？还是在电视马拉松上是不可能的？

我阅读了 google、stackoverflow、github 问题，但我自己找不到解决方案。所以我在这里需要你的帮助。谢谢。

import time
from pathlib import Path
import re
import random
import asyncio

from telethon import TelegramClient, events
from telethon.sessions import StringSession
from telethon import utils

import logging
logging.basicConfig(level=logging.ERROR)

api_id = ""
api_hash = ''
phone = ''
string = Path('./string').read_text()

message = "hi."

if __name__ == '__main__':

    client = TelegramClient(StringSession(string), api_id, api_hash, sequential_updates=True)

    @client.on(events.NewMessage(incoming=True))
    async def handle_new_message(event):
        print('message:', event.message.message)
        # // not working here, the sleep blocks next events but not only current event. 
        print('wait for 3 seconds...')
        await asyncio.sleep( 3 )
        await event.respond(message)


    print('Auto-replying...')
    client.start(phone)
    client.run_until_disconnected()
    # client.loop.run_forever()

    # string = StringSession.save(client.session)
    # Path('./string').write_text(string)

Answer 1

您正在使用sequential_updates，因此在第一次更新未完成之前，它不会移动到其他更新。我猜你需要关闭顺序更新。