python - Comment exécuter des tâches planifiées au céleri sans délai

Question

Lorsque vous utilisez du céleri pour effectuer des tâches planifiées, telles que le code suivant

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,
    }
}

En cours d'utilisation

celery beat -A tâches.login --loglevel=info

Après

, il y aura un délai de 60 secondes avant d'exécuter la première tâche. Je voudrais demander, comment puis-je l'écrire pour qu'il puisse être exécuté lorsque la tâche planifiée est démarrée pour la première fois, puis réexécutée toutes les 60 secondes ?

Answer 1

Méthode simple : appelez tâches.login.test_timertask() après ou avant cela

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,
}

}