让Telepot机器人在其自己的线程中运行

Question

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

电报机器人的代码是一个名为telebot.py的文件，而线程代码位于一个名为plantbot.py

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

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})

不幸的是，这些都没有奏效。

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

Answer 1

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

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