Celery 每日计划任务与 Crontab
Posted
技术标签:
【中文标题】Celery 每日计划任务与 Crontab【英文标题】:Celery Daily Scheduled Tasks with Crontab 【发布时间】:2019-02-08 19:57:42 【问题描述】:我对使用 crontab 的每日计划任务有疑问。 这是我的 celery.py
app.conf.beat_schedule =
'run-cache-updater':
'task': 'tasks.run_cache_updater',
'schedule': crontab(
minute=0,
hour='1-4'
),
下面是我的tasks.py 我在那里做的是,从数据库中获取所有记录。触发其他作业以更新我在 Redis 上的缓存。
@app.task
def run_cache_updater():
batch_size = 1000
cache_records = models.CacheRecords.objects.all()
def _chunk_list(all_records, size_of_batch):
for i in range(0, len(all_records), size_of_batch):
yield [item.id for item in all_records[i: i + batch_size]]
for items in _chunk_list(cache_records, batch_size):
update_cache.delay(items)
@app.task
def update_cache(ids_in_chunks):
for id in ids_in_chunks:
# Some calls are done here. Then sleep for 200 ms.
time.sleep(0.2)
我的任务运行良好。但是,它们开始在 1 到 4 之间运行,然后每 4 小时再次开始,例如 8-11、15-18.. 我在这里做错了什么,我该如何解决?
【问题讨论】:
【参考方案1】:这听起来像是一个 Celery 错误,可能值得在他们的 Github 存储库中提出。
但是,作为一种解决方法,您可以尝试更明确的表示法 hour='1,2,3,4'
,以防万一问题出在特定 crontab 间隔样式的解析中。
【讨论】:
true 但是,那么它将从头开始执行第一个任务。我想在 1 点钟第一个任务开始并让其他任务排队,它们在 4 点钟停止。我不知道上面的代码是否也这样做了以上是关于Celery 每日计划任务与 Crontab的主要内容,如果未能解决你的问题,请参考以下文章
django + celery - 如何在我的 django 应用程序中为 celery 设置 crontab 计划?