celery :我是否误解了它的工作原理？

Question

我有一个基于 EC2 的 REST Web 服务，它通过 SQS 连接到一组工作实例。我希望用 Celery 替换当前设置，保留(暂时)SQS 作为经纪人。

但是，我不确定我对 Celery 运作方式的心理描述是否十分准确。遵循 this 中似乎暗示的模式文章中，我的理解是我可以将消息从我的 API 排队到 SQS，然后这些将由 Celery 工作人员及时处理。然而，我发现的示例(几乎没有一个涉及使用 SQS 作为代理)似乎表明 Celery 自己 进行了排队。所以 Celery 就像队列的“包装器”，提交和处理任务。它同时充当生产者 和 消费者 - 对吗？如果是这样，那对我来说似乎是个大问题，因为我不使用 Python。工作人员自己将使用 execl() 来运行实际任务，但我将如何处理从 API 服务器向队列中初始提交的消息？这是 Celery 允许的吗？

我对此是否正确，或者我最初的理解是否准确？或者，它们是否同样是 Celery 的合法使用方式？

Answer 1

Celery 用于消息的协议(protocol)很好 documented .您可以使用任何语言实现自定义生产者或使用现有实现之一(PHP、Node.js、Ruby 等)。它们被列为 here .

您也可以使用 web hooks允许从任何环境调用任务。