Каким образом реализовать очень быструю очередь в Django ORM для API?

Question

[kkolorid]

Доброго времени суток. Делаю API для работы, суть конкретного эндпоинта в том, что он берет из очереди в бд запись, обновляя ее статус с "ждет" на "выполняется" (соответственно берет постоянно очередной, который ожидает). Каким образом правильно это как-то в один запрос реализовать, если классическим способом взять, а потом обновить не прокатывает? При 2 и более потоках он дает просто одинаковые записи на обработку, не успевая обновить их статус...

Answer 1

[Everything_is_bad]

При 2 и более потоках он дает просто одинаковые записи на обработку, не успевая обновить их стату

лочить запись с помощью select_for_update https://docs.djangoproject.com/en/5.1/ref/models/q...

Comments

[kkolorid]

так если он заблокирует запись для изменения, всё ровно ее можно будет получать множество раз при одновременном запросе несколькими потоками, разве нет?

[kkolorid]

Просто особенность в том, что апи отдает запись на обработку, но результат у нее будет сильно позже, отдельным вообще запросом, мне не нужно ни чего делать с записью, кроме изменения ее статуса на "в работе", чтобы очередные запросы с Model.objects.filter(status="added").first() не брали то, что уже отдано только что

[Everything_is_bad]

kkolorid, ну читай внимательно там есть skip_locked=True

[kkolorid]

Everything_is_bad, спасибо, кажется получилось, судя по тестам !