python céleri - comment ajouter la tâche CELERYBEAT_SCHEDULE lors de l'exécution à un worker?

Question

J'ai créé un employé de céleri avec une seule tâche de planification de célerybeat qui s'exécute à 5 secondes d'intervalle de temps. Je me demande comment puis-je ajouter dynamiquement une autre tâche de rythme au céleri sans l'arrêter.

Exemple

app.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600, 
    CELERY_TIMEZONE = 'UTC', 
    CELERYBEAT_SCHEDULE = { 
    'long-run-5-secs': { 
     'task': 'test_proj.tasks.test', 
     'schedule': timedelta(seconds=5), 
     'args': (16,) 
    } 
    } 
) 

avec la configuration ci-dessus, je suis en mesure d'exécuter le travailleur de céleri avec le mode de battement avec succès.

Maintenant, je besoin d'ajouter le calendrier de battement ci-dessous dynamiquement

'à long terme 2-secs': { 'tâche': 'test_proj.tasks.test', 'horaire': timedelta (secondes = 2), 'args': (14,)},

Besoin d'aide sur ce

Merci

Answer 1

J'ai cherché une solution pour le même problème. J'ai peur que vous deviez attendre Celery ver.4.0. La planification dynamique des tâches est actuellement uniquement prise en charge dans le développement version version: http://docs.celeryproject.org/en/master/userguide/periodic-tasks.html#beat-entries