通过Redis Pub/Sub启动Python Celery任务

Question

是否有一种有效的方法来启动任务，通过Redis发布/订阅和返回将该任务的值返回到Pub/Sub通道以启动另一个任务根据结果?

有谁知道怎么把这些放在一起吗?也许装饰器是处理和准备返回值的好方法到Pub/Sub频道，无需过多更改任务的代码。

任何帮助都非常感谢!

Answer 1

使用pub/sub的问题是它不是持久的。如果你想做更接近实时的交流，芹菜可能不是你最好的选择。