1

我使用 Telepot 库在 python 中编写了一个电报机器人。机器人本身正在工作。由于在运行机器人时我还需要定期做一些其他事情（即在日志中写入内容），我希望机器人在自己的线程中运行。

电报机器人的代码是一个被调用的文件telebot.py，而线程代码在一个被调用的文件中plantbot.py

我首先尝试简单地创建一个调用我的run_bot()函数的新线程，但它不起作用并给了我以下 RuntimeError：

Exception in thread Thread-1:
Traceback (most recent call last):
  File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.5/threading.py", line 862, in run
    self._target(*self._args, **self._kwargs)
  File "plantbot.py", line 12, in start_bot
    telebot.run_bot()
  File "/srv/plantbot/telebot.py", line 108, in run_bot
    loop = asyncio.get_event_loop()
  File "/usr/lib/python3.5/asyncio/events.py", line 671, in get_event_loop
    return get_event_loop_policy().get_event_loop()
  File "/usr/lib/python3.5/asyncio/events.py", line 583, in get_event_loop
    % threading.current_thread().name)
RuntimeError: There is no current event loop in thread 'Thread-1'.

这是我用于此的代码：

plantbot.py

def start_bot():
    telebot.run_bot()

bot = threading.Thread(target=start_bot, daemon=True)
bot.start()
print("Bot started...")
bot.join()

telebot.py

[lots of unrelated code]

bot = telepot.aio.Bot(TOKEN)

def run_bot():
    loop = asyncio.get_event_loop()
    loop.create_task(MessageLoop(bot, {'chat': on_chat_message, 'callback_query': on_callback_query}).run_forever())

    print('Listening ...')
    loop.run_forever()

然后我尝试了一些事件循环，直到我最终在我的主文件 ( plantbot.py) 中创建了事件循环，它看起来像这样：

plantbot.py

def start_bot(loop):
    telebot.run_bot(loop)

loop = asyncio.new_event_loop()
bot = threading.Thread(target=start_bot, args=(loop,),  daemon=True)
bot.start()
print("Bot started...")
bot.join()

telebot.py

[...]
bot = telepot.aio.Bot(TOKEN)

def run_bot(loop):
    loop.create_task(MessageLoop(bot, {'chat': on_chat_message, 'callback_query': on_callback_query}).run_forever())

    print('Listening ...')
    loop.run_forever()

我还尝试了另一种变体：

plantbot.py

def start_bot(loop):
    asyncio.set_event_loop(loop)
    loop.create_task(telebot.task.run_forever())
    loop.run_forever()

loop = asyncio.new_event_loop()
bot = threading.Thread(target=start_bot, args=(loop,),  daemon=True)
bot.start()
print("Bot started...")
bot.join()

telebot.py

[...]
bot = telepot.aio.Bot(TOKEN)

task = MessageLoop(bot, {'chat': on_chat_message, 'callback_query': on_callback_query})

不幸的是，这些都不起作用。

因此，我的问题是，如何在自己指定的线程中正确运行事件循环？具体来说：如何在自己的线程中运行电报机器人？

4

1 回答 1

0

我确实最终找到了解决方案，尽管它并不令人满意：

我现在在主线程中运行机器人并将其他所有内容放入其他线程中。它确实以这种方式工作。

于 2019-09-16T14:32:57.577 回答