使用 sqs 代理进行 celery 监控

Question

我们将 Airflow(1.10.3) 与 celery executor(4.1.1 (latentcall)) 和代理 SQS 一起使用。在调试问题时，我们尝试了 celery CLI，发现任何检查命令或监视工具都不支持 SQS 代理，例如。花。有什么方法可以监控 celery worker 的任务或事件？

我们已经尝试过如下的诅咒监视器：

芹菜事件 -b sqs://

但它显示没有发现工人，没有选择任务。 Inspect Commands 直接显示：

可用性：RabbitMQ (AMQP) 和 Redis 传输。

如果我遗漏了什么，或者是否可以使用 SQS 监控 celery 工人，请告诉我。

Answer 1

SQS 传输不提供对监控/检查的支持（这是我不使用它的主要原因）...根据latest documentation Redis 和 RabbitMQ 是唯一支持监控/检查的代理类型和遥控器。