Pyrogram 电报 API(不是机器人 api)
Pyrogram telegram API (not bot api)
我正在使用 Pyrogram 来处理电报 API。
我已成功加入频道。
我的任务是添加消息处理程序并在通道中接收消息。
但是消息到达时不会调用消息处理程序(我是频道的所有者)
代码:
import asyncio
from pyrogram import Client
import time
from pyrogram.handlers import MessageHandler, RawUpdateHandler
api_id = "xx"
api_hash = "xx"
def my_handler(client, message):
message.forward("me")
print('sent msg')
async def main():
async with Client("my_account", api_id, api_hash) as app:
a = await app.get_chat('test2k3')
msg_handler = MessageHandler(my_handler)
app.add_handler(msg_handler)
await app.join_chat(str(a.id))
print(f'joined chat ' + str(a.id))
while True:
time.sleep(2.4)
asyncio.get_event_loop().run_until_complete(main())
在异步函数中使用 asyncio.sleep() 而不是 time.sleep()
在客户端运行时休眠会停止它直到休眠结束。在按下 Ctrl 和 C 之前,Pyrogram 本身已经保持活动状态。删除你的 while True 睡眠循环。
我正在使用 Pyrogram 来处理电报 API。 我已成功加入频道。 我的任务是添加消息处理程序并在通道中接收消息。 但是消息到达时不会调用消息处理程序(我是频道的所有者)
代码:
import asyncio
from pyrogram import Client
import time
from pyrogram.handlers import MessageHandler, RawUpdateHandler
api_id = "xx"
api_hash = "xx"
def my_handler(client, message):
message.forward("me")
print('sent msg')
async def main():
async with Client("my_account", api_id, api_hash) as app:
a = await app.get_chat('test2k3')
msg_handler = MessageHandler(my_handler)
app.add_handler(msg_handler)
await app.join_chat(str(a.id))
print(f'joined chat ' + str(a.id))
while True:
time.sleep(2.4)
asyncio.get_event_loop().run_until_complete(main())
在异步函数中使用 asyncio.sleep() 而不是 time.sleep()
在客户端运行时休眠会停止它直到休眠结束。在按下 Ctrl 和 C 之前,Pyrogram 本身已经保持活动状态。删除你的 while True 睡眠循环。