带有 Celery 错误的 Google Kubes 上的 Docker 应用程序

如何解决带有 Celery 错误的 Google Kubes 上的 Docker 应用程序

我在使用 GKE 的 docker 应用程序上运行计划任务时遇到了一些问题。

我的芹菜配置：

broKER_URL = 'redis://{}:{}/5'.format(redis_host,redis_port)
CELERY_RESULT_BACKEND = 'redis://{}:{}/5'.format(redis_host,redis_port)
broKER_TRANSPORT_OPTIONS = {'visibility_timeout': 245760}
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_RESULT_EXPIRES = 245760
CELERY_ENABLE_UTC = False
CELERY_IGnorE_RESULT = True

我的计划任务：

CELERYBEAT_SCHEDULE = {
    "task-am": {
        "task": "utils.client.celery_sync_accounts","schedule": crontab(hour="6")
    }
}

发生了什么...

Celery 一遍又一遍地生成 1000 个任务，最终我会读/写数百万次。

有一次我让它工作了，但现在它似乎再次出错。我相信这可能是时区问题？

另外，因为我正在运行 GKE，并且我有 3 个 Pod，这是否意味着计划任务会运行 3 次？

我几个月来一直在努力解决这个问题，任何帮助将不胜感激。