Почему я могу получить доступ к объекту во время него post_save Signal, но не тогда, когда я запускаю код внутри этого сигнала, который вызывает его на другом процессе

Все, у меня проблема с сигналами django.

У меня есть модель Чтобы ускорить отзывчивость загрузок страниц, я разгружаю интенсивную обработку, которую нужно выполнить, посредством вызова второго веб-сервера localhost, который мы запускаем, используя одну и ту же базу данных. Я вижу поведение, когда вызывающий процесс может получить объект, но вызываемый процесс не может. Оба порта 80 и порт [порт] указывают на процессы django, запущенные с той же базы данных.

В 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 )

В views.py

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

Кроме того, после вызова urlopen возникает исключение, объект не существует в базе данных. Насколько я понял, post_save был вызван после того, как объект был сохранен и записан в базу данных. Это неверно?

Ответ 1

Я считаю, что post_save срабатывает после сохранения, но до того, как транзакция будет передана в базу данных. По умолчанию Django фиксирует изменения в базе данных после завершения запроса.

Два возможных решения вашей проблемы:

Управлять транзакциями вручную и запускать собственный сигнал после фиксации.
Попросите свой второй процесс немного подождать, чтобы запрос прошел.

Честно говоря, вся ваша установка кажется немного противной. Вероятно, вам следует искать Celery для асинхронной очереди задач.

Ответ 2

Мы столкнулись с аналогичной проблемой, и мы закончили использование on_commit callback ( ПРИМЕЧАНИЕ: это возможно только с Django >= 1.9), Итак, вы можете сделать что-то вроде:

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 )

Идея здесь в том, что вы будете называть свою конечную точку после совершения транзакции, поэтому экземпляр, участвующий в транзакции, будет уже сохранен;).

Ответ 3

Имела ту же проблему при создании новой модели от администратора django. Переопределение метода ModelAdmin.save_model для управления транзакцией вручную.

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

Ответ 4

Хорошее место для использования декораторов. Существует немного расширенная версия ответа @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