Джанго неблокирующее сохранение?

Question

Есть ли способ вызвать save() на модели в django, не дожидаясь ответа от db?
Вы могли бы рассмотреть эту асинхронность, хотя мне нужно меньше, поскольку вызовы асинхронного вызова обычно дают вам обратный вызов, который мне не нужен здесь.
Поэтому в основном я хочу -

SomeModel.objects.bulk_create([list of objects ]), каждый говорят 1000 объектов,
Без этой строки блокирующей мой код. Я не буду использовать эти строки в моем коде.
Я ищу что-то простое, как пакет сельдерея, кажется, предлагает намного больше, чем это ..

Answer 1

По состоянию на 2016 год, Django является веб-фреймворк работает (на данный момент, если мы игнорируем channels) принимает HTTP запрос «как аргумент» и как можно скорее возвращает HTTP-ответ.

Эта архитектура означает, что в рамках концепции нет асинхронной работы. Если вы хотите отложить сохранение и вернуть ответ пользователю без ожидания, вы можете:

• либо запустить другой поток/блок асинхронного ввода (что может быть утомительным с транзакциями базы данных ...);
• услуги, такие как IronWorker, позволяющие запускать очереди для запуска async a.s.a.p;
• celery, что может принести слишком много возможностей для вашего дела, но будет лучше, чем работать, чем какое-нибудь домашнее решение.

Answer 2

rq (Redis Queue) - еще один вариант для асинхронных операций (кроме тех, которые Максим Лорант упоминает в своем ответе). Он использует Redis в качестве брокера (средний человек, который выполняет задачи), поэтому, если вы уже используете Redis или хотите добавить его в свой проект, вы должны его рассмотреть. Это приятное и простое решение, намного проще, чем сельдерей. Существует также django-rq простое приложение, которое обеспечивает интеграцию django для rq.

Update: Итоговые комментарии

django_rq предоставляет команды управления (rqworker), который запускает рабочий процесс. Любое задание, которое помещается в очередь, будет выполняться этим процессом. Вы можете отправить одно задание в очередь для каждого объекта (задание будет функцией с объектом в его аргументах, и оно сохранит объект в базе данных) или соберите список объектов и отправьте задание с этим списком. Во втором случае вам нужно временно хранить этот список где-нибудь, что может быть сложно.

Использование Redis для временного хранения объектов (рекомендуется)

Я думаю, что самый надежный способ сделать это, чтобы сериализовать объекты JSON и хранить их в список Redis. Затем регулярно проверяйте длину и длину требуемой длины, вы можете отправить задание в очередь, имеющую этот список в своих аргументах.

Использование памяти работника для временного хранения объектов

Вы также можете использовать оперативную память вашего работника в качестве временного хранилища. Это можно сделать, поскольку рабочий процесс имеет свою собственную память. В этом случае основной процесс (рабочий сервер) создает задание с объектом. Задание не сохраняет объект, оно просто добавляет его в список.Вы можете сохранить добавление объектов в этот список. Поскольку задания выполняются в рабочем процессе, этот список существует в памяти рабочего. Когда он имеет желаемую длину, вы можете сохранить все объекты.

Но представьте себе случай, когда вы создаете более одного рабочего. В этом случае каждое задание в очереди будет выбрано текущим свободным работником. Таким образом, некоторые объекты будут добавлены в список в памяти рабочего_1, некоторые другие объекты в списке worker_2 и т. Д., И вам придется иметь дело с таким количеством списков, что и рабочие.