Créer des tâches de céleri puis exécuter de manière synchrone

Mon application regroupe un tas de numéros de téléphone sur une page. Une fois que l'utilisateur appuie sur le bouton soumettre, j'ai créer un céleri tâche d'appel de chaque numéro et de donner un message de rappel puis de les rediriger vers une page où ils peuvent voir les mises à jour en direct à propos de l'appel. Je suis à l'aide des sockets web à mise à jour en direct l'état d'avancement de chaque appel et ont besoin de la de tâches à exécuter de manière synchrone comme je n'ai accès qu'à composer un numéro à partir d'un nombre.

Donc, une fois que le premier appel/tâche est terminée, je veux que le suivant d'un feu éteint.

J'ai pris un coup d'oeil à CELERY_ALWAYS_EAGER paramètres, mais il est juste allé à travers la première itération et s'est arrêté.

@task
def reminder(number):
    # CODE THAT CALLS NUMBER HERE....

def make_calls(request):
    for number in phone_numbers:                     
        reminder.delay(number)      

    return redirect('live_call_updates')

source d'informationauteur Austin

  1. 4

    si vous voulez le feu à chaque appel, l'un après l'autre, pourquoi ne pas vous envelopper tous les appels en une seule tâche

    @task
def make_a_lot_of_calls(numbers):
    for num in numbers:
        # Assuming that reminder blocks till the call finishes
        reminder(number)

def make_calls(request):
    make_a_lot_of_calls.delay(phone_numers)                          
    return redirect('live_call_updates')
  2. 18

    Si vous regardez la le céleri DOCS sur les tâches vous voyez que pour appeler une tâche synchronosuly, vous utilisez la commande apply() la méthode par opposition à la apply_async() la méthode.

    Donc dans votre cas, vous pouvez utiliser:

     reminder.apply(args=[number])

    Les documents également noter que:

    If the CELERY_ALWAYS_EAGER setting is set, it will be replaced by a local apply() call instead.

    Grâce à @JivanAmara qui dans les commentaires a rappelé que lors de l'utilisation d'appliquer(), la tâche sera exécutée localement(dans le serveur/ordinateur dans lequel elle est appelée). Et cela peut avoir des conséquences, si vous avez l'intention d'exécuter vos tâches sur plusieurs serveurs/machines.