如何通过SQS代理监视芹菜中的任务？

Question

使用类似于flower的仪表板来监视celery任务的方法是什么。从documentation中，我看到尚不存在SQS监视支持。还有什么其他选择？

我正在将芹菜与Django一起使用。

Answer 1

除了使用cloudwatch（https://dzone.com/articles/using-sqs-with-celery）之外，您唯一的选择就是构建自己的选项。幸运的是，您可以使用boto3做到这一点。您将必须“读取”队列中的每条消息，但是如果您需要任务级别的详细信息，它将采用json格式。据我所知，还没有预建的库可以监视django + celery + sqs。