問題描述

在使用celery做定時(shí)任務(wù)的時(shí)候，比如下面代碼

app.conf.beat_schedule = { # ’login_task’: { # ’task’: ’tasks.login.excute_login_task’, # ’schedule’: 60*60*20.0, # }, ’test_celery’: {’task’: ’tasks.login.test_timertask’,’schedule’: 60.0, }}

在使用

celery beat -A tasks.login --loglevel=info

后，會(huì)延遲60秒才執(zhí)行第一次任務(wù)。請(qǐng)問一下，怎么寫能讓它在剛啟動(dòng)定時(shí)任務(wù)的時(shí)候就執(zhí)行，然后每過60s再次執(zhí)行？

問題解答

簡(jiǎn)單方法 在這個(gè)之后 or 之前調(diào)用tasks.login.test_timertask()

app.conf.beat_schedule = {

# ’login_task’: {# ’task’: ’tasks.login.excute_login_task’,# ’schedule’: 60*60*20.0,# },’test_celery’: { ’task’: ’tasks.login.test_timertask’, ’schedule’: 60.0,}

}