如何使用 JobQueue 管理来自 pub\sub 的推送通知?
How to manage Push notifications from pub\sub using JobQueue?
我正在使用 ConversationHandler
来管理我的启动状态。
我在那里也有一些计时器,所以我正在使用 JobQueue
。
我还有 Web 应用程序,用户可以在其中执行一些任务,任务完成后我希望它(站点)从机器人向用户发送通知。为了在用户和电报机器人之间互连,我决定使用 ZeroMQ(使用此示例 https://gist.github.com/ramn/7061042)
但是,我需要 运行 侦听器以某种方式在我的机器人代码中异步,否则它不会因为机器人的 start_polling
功能而开始执行。我确实尝试使用 JobQueue
来做到这一点并且效果很好,但是它停止了所有 JobQueue
队列 =(
我如何管理这种互连?我应该停止使用 JobQueue 并转移到一些类似 celery 的库吗?
谢谢!
我不确定这是否完全有帮助,但 python-telegram-bot
有一个 @run_async
装饰器,它为异步函数提供了额外的线程。
可以做from telegram.ext.dispatcher import run_async
然后装饰作业函数
可以在 wiki here 中找到更多详细信息。
我正在使用 ConversationHandler
来管理我的启动状态。
我在那里也有一些计时器,所以我正在使用 JobQueue
。
我还有 Web 应用程序,用户可以在其中执行一些任务,任务完成后我希望它(站点)从机器人向用户发送通知。为了在用户和电报机器人之间互连,我决定使用 ZeroMQ(使用此示例 https://gist.github.com/ramn/7061042)
但是,我需要 运行 侦听器以某种方式在我的机器人代码中异步,否则它不会因为机器人的 start_polling
功能而开始执行。我确实尝试使用 JobQueue
来做到这一点并且效果很好,但是它停止了所有 JobQueue
队列 =(
我如何管理这种互连?我应该停止使用 JobQueue 并转移到一些类似 celery 的库吗?
谢谢!
我不确定这是否完全有帮助,但 python-telegram-bot
有一个 @run_async
装饰器,它为异步函数提供了额外的线程。
可以做from telegram.ext.dispatcher import run_async
然后装饰作业函数
可以在 wiki here 中找到更多详细信息。