Utilisation de variables globales dans Céleri: Quelle est la meilleure approche?

Question

J'écris une application en utilisant Django 1.10 et Céleri. J'essaie de créer une boucle de céleri pouvant être démarrée et arrêtée via Django.

Mon idée ressemble à ceci (très simple):

_run = False 

def do_work(): 
    global _run 
    while _run: 
    # Do something 

@app.task 
def start(): 
    global _run 
    _run = True 
    do_work() 

@app.task 
def stop(): 
    global _run 
    _run = False 

Le problème est que le céleri est généralement exécuté dans> 1 fil de travail et _run n'est pas accessible entre les threads.

Question: Quelle est la meilleure approche pour atteindre la fonctionnalité? Im penser à la mise en place d'une variable de base de données, mais je crains que ce n'est pas la meilleure approche.

Answer 1

L'une des approches possibles consiste à créer une tâche qui sera exécutée pour toujours et l'arrêter ensuite sur demande.

from proj.celery import app 
app.control.revoke(task_id) 

http://docs.celeryproject.org/en/latest/faq.html#can-i-cancel-the-execution-of-a-task