Perché posso accedere a un oggetto durante il segnale post_save, ma non quando faccio scattare il codice all'interno di quel segnale che lo chiama su un altro processo

Question

Tutti, ho un problema con i segnali django.

Ho un modello Nel tentativo di accelerare la reattività dei carichi di pagina, sto scaricando alcune elaborazioni intensive che devono essere eseguite, tramite una chiamata a un secondo server web localhost in esecuzione, entrambi che utilizzano lo stesso database . Sto vedendo un comportamento in cui il processo chiamante può recuperare l'oggetto, ma il processo chiamato non può. Entrambe le porte 80 e port [port] stanno puntando ai processi django che scorrono dallo stesso database.

In models.py

class A(models.Model): 
    stuff... 

def trigger_on_post_save(sender, instance, create, raw, **keywords): 
    #This line works 
    A.objects.get(pk=instance.pk) 
    #then we call this 
    urlopen(r'http://127.0.0.1:[port]' + 
     reverse(some_view_url, args(instance_pk)).read() 

post_save.connect(trigger_on_post_save, A) 

In views.py

def some_view_function(request, a_pk): 
    #This line raises an object_not_found exception 
    A.objects.get(pk=a_pk) 

Inoltre, dopo che la chiamata urlopen solleva un'eccezione, l'oggetto non esiste nel database. Ho capito che post_save è stato chiamato dopo che l'oggetto è stato salvato e scritto nel database. È sbagliato?

Answer 1

Credo che post_save si attivi dopo il salvataggio, ma prima che la transazione venga eseguita nel database. Per impostazione predefinita, Django esegue solo modifiche al database dopo che la richiesta è stata completata.

Due le possibili soluzioni al problema:

1. Manage your transactions manually, e il fuoco di un segnale personalizzato dopo si commettono.
2. Fai in modo che il tuo secondo processo attenda un po 'di tempo per la richiesta.

Per essere onesti, tuttavia, l'intera configurazione sembra un po 'sgradevole. Probabilmente dovresti esaminare Celery per l'accodamento di attività asincrone.

Answer 2

Aveva lo stesso problema durante la creazione di un nuovo modello da admin django. Sovrascrivere il metodo ModelAdmin.save_model per gestire la transazione manualmente.

def save_model(self, request, obj, form, change): 
    from django.db import transaction 
    with transaction.commit_on_success(): 
     super(ModelAdmin, self).save_model(request, obj, form, change) 

    # write your code here 

Answer 3

ci siamo imbattuti in un problema simile e abbiamo finito per usare on_commit callback (NOTA: questo è possibile solo con Django> = 1.9). Quindi, si potrebbe possibile fare qualcosa di simile:

from django.db import transaction 

class A(models.Model): 
    stuff... 

def trigger_on_post_save(sender, instance, create, raw, **keywords): 
    def on_commit(): 
     urlopen(r'http://127.0.0.1:[port]' + 
       reverse(some_view_url, args(instance_pk)).read() 
    transaction.on_commit(on_commit) 

post_save.connect(trigger_on_post_save, A) 

L'idea è che si wil essere chiamata la tua endpoint dopo la transazione è stata impegnata, in modo da l'istanza oggetto dell'operazione sarà già salvato;).

Answer 4

È un bel posto per usare i decoratori. C'è un po 'esteso versione di risposta di @ yoanis-gil:

def on_transaction_commit(func): 
    def inner(*args, **kwargs): 
     transaction.on_commit(lambda: func(*args, **kwargs)) 

return inner 

@receiver(post_save, sender=A) 
@on_transaction_commit 
def trigger_on_post_save(sender, **kwargs): 
    # Do things here