我们可以将芹菜作为消息消费者(而不是生产者)和分发者吗？ [英] Can we use celery as a message consumer (not producer) and distributor?

问题描述

使用celery，是否可以使用RabbitMQ侦听新邮件并计划工作进程来处理它？

celerydocumentation的很多内容都是关于将其用作代理(比方说RabbitMQ)的任务生产者，在该代理中执行任务并通过代理交付。

我希望使用来自代理的消息(由其他服务生成)，并使用celery处理这些消息。

推荐答案

是。您所要做的就是配置放入rabbitMQ中的消息，使芹菜将其识别为一项任务。我已经使用Nifi做到了这一点。我目前使用的是json，消息如下：

{"expires": null, "utc": true, "args": ["${absolute.path}${filename}", "nifihost"], "chord": null, "callbacks": null, "errbacks": null, "taskset": null, "id": "${uuid}", "retries": 0, "task": "taskmanager.tasks.nifi", "timelimit": [null, null], "eta": null, "kwargs": {}}

我不是百分之百确定除了"TASK"关键字之外还需要哪些关键字。

这篇关于我们可以将芹菜作为消息消费者(而不是生产者)和分发者吗？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！