python - 重启 celery 会导致重复任务吗？

Question

我在 celery 中有一个电子邮件任务，预计从现在起 10 天()。但是，我发现有些人一次收到 5-6 封重复的电子邮件。我之前遇到过这个问题，因为 BROKER_TRANSPORT_OPTIONS 设置得太低了。现在我的设置文件中有这个:

BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 2592000} #30 days

所以这应该不再是问题了。我只是想知道是否还有其他可能导致它的原因。即重新启动 celery 。每次我部署新代码时，Celery 都会重新启动，而且每周可能发生 5 次或更多次，所以这是我唯一能想到的事情。

有什么想法吗？

谢谢。

Answer 1

如果 worker/beat 进程没有正确停止，任务重复是可能的。你如何重启 celery worker /节拍？检查服务器是否有僵尸 celery worker 并击败进程。尝试停止所有 celery 进程，检查不存在 celery 进程并重新启动它。毕竟检查 ps ax | grep celery 显示新的 worker 并且只有一个节拍。