为什么 Celery 会撤销所有计划任务并丢弃它们？

Question

我对 Celery 有一个问题：从某一点开始（Celery worker 日志没有显示根本原因），所有任务（由 celerybeat 每 5 分钟安排一次）都被 workers 撤销和丢弃。

celerybeat 和 celeryd（工人）的日志中没有任何线索可以说明为什么会发生这种情况。我注意到从某个时间点开始，每 50 个任务中有 1 个被撤销，被撤销任务的频率不断上升，直到 24 小时后所有任务被系统地撤销。

我正在使用 Redis 作为代理，问题发生在 Linux Celery 部署上。

您知道问题的可能原因是什么吗？如果您需要更多信息，请随时询问！

Answer 1

我在查看日志中的任务 UUID 后弄明白了发生了什么：

[2015-10-27 05:27:45,879: INFO/MainProcess] Received task: hidden_task_name[29e47148-8865-4d46-a7ef-f8a0d625fe05] expires:[2015-10-27 05:57:45.870869+00:00]
[2015-10-27 06:28:23,696: INFO/MainProcess] Discarding revoked task: hidden_task_name[29e47148-8865-4d46-a7ef-f8a0d625fe05]

由于我使用 CELERYBEAT_SCHEDULE:

设置的任务到期日期，任务被丢弃

CELERYBEAT_SCHEDULE['---'] = {
        'task': ...,
        'schedule': ...,
        'args': (),
        'options': {
            # Do not run the task if it starts 30 minutes after it is
            # scheduled. This is useful if the Celery workers go down,
            # celerybeat will keep adding tasks to the queue.
            'expires': 1800
        }
    }

我的错:)

为什么 Celery 会撤销所有计划任务并丢弃它们？

Why does Celery revoke all scheduled tasks and discard them?

python

linux

redis

celery

celerybeat