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

Question

我见过的所有执行/调度 Celery 任务的例子都是这样的:

add.delay()

我想知道我是否可以用 Celery 做这样的事情:

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

在其他代码库/服务中:

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

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

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

Answer 1

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

此外，您不能向队列发送任意消息，只能向 Celery 任务发送消息。如果您想生成/使用任意消息，请使用 kombu。