Wie kann man sicherstellen, dass Django-Modelle vor der Ausführung der Sellerie-Aufgabe gespeichert werden?

Question

Ich habe ein Django 1.11 + MySQL + Sellerie 4.1-Projekt, bei dem eine Ansicht einen neuen Benutzerdatensatz erstellt und dann eine Sellerie-Aufgabe startet, um zusätzliche lang andauernde Aktionen in Bezug darauf auszuführen.

Das typische Problem in diesem Fall besteht darin sicherzustellen, dass die Benutzererstellung für die Datenbank festgeschrieben wird, bevor die Sellery-Task ausgeführt wird. Andernfalls gibt es eine Race-Bedingung, und die Task kann versuchen, auf einen Datensatz zuzugreifen, der nicht beendet wird, wenn er ausgeführt wird, bevor die Transaktion festgeschrieben wird.

Die Art, wie ich gelernt hatte, dies zu beheben, bestand darin, die Aufnahmeerstellung immer in eine manuelle Transaktion oder einen atomaren Block zu verpacken und danach die Sellerie-Aufgabe auszulösen. z.B.

def create_user(): 
    with transaction.atomic(): 
     user = User.objects.create(username='blah') 
    mytask.apply_async(args=[user.id]) 

@task 
def mytask(user_id): 
    user = User.objects.get(id=user_id) 
    do_stuff(user) 

Allerdings sehe ich noch gelegentlich den Fehler DoesNotExist: User matching query does not exist in meinem Sellerie Arbeiter logs, was bedeutet, meine Aufgabe manchmal ausgeführt wird, bevor der Benutzerdatensatz begangen wird.

Ist das nicht die richtige Strategie, oder implementiere ich sie nicht richtig?

Answer 1

Ich glaube, ein post_save Signal wäre besser geeignet für das, was Sie versuchen zu tun: https://docs.djangoproject.com/en/1.11/ref/signals/#post-save. Dieses Signal sendet ein created Argument als booleschen Wert, so dass es einfach ist, nur bei der Objekterstellung zu arbeiten.