python - 下线时处理django + celery

Question

我想弄清楚当我的 django 项目因某种原因离线时如何处理 celery 。

我在文档中找到了 worker-offline事件，所以我猜我可以在 celery 离线时以某种方式捕获此事件，并通过电子邮件通知我的 celery worker 已关闭。

我的问题是如何实现这种行为？是否有任何示例或 Django 应用程序？这是我应该如何处理这些情况吗？

Answer 1

在我的生产设置中，我使用 supervisor守护和控制 celery worker 。您可以在系统上运行脚本来监视主管控制状态的状态(在 state of the process 进入 FATAL 状态时发出警报)。

假设您的工作人员不断地在日志文件中吐出文本，您可以设置日志新鲜度检查。如果您检测到日志在 X 秒/分钟内未更新，则会发出警报。

还有 Celery Flower ，一个专为远程监控和远程管理 Celery 而设计的系统。我没有在生产中使用它，所以我无法判断它是否满足您的特定需求。