我可以使用Celery发布和订阅主题吗？

Question

我见过的执行/安排Celery任务的所有示例都是这样：

add.delay()

我想知道我是否可以用芹菜做这样的事情：

celery_app.publish(topic='my-topic')

以及在其他代码库/服务中：

@task(topic='my-topic')
def mytask():
    do_stuf()

这样，当事件发生时，我不需要知道哪些任务必须执行某些操作。

我可能对这个问题有一些误解，但我自己找不到答案。

Answer 1

没有主题，只是排队。是的，您可以将任务发送到任何队列。订阅队列是工作人员级别的远程命令，因此也是可能的。