Передача записи операций сохранения по записи внутри потоков в Django - PullRequest
Новая
       18

Передача записи операций сохранения по записи внутри потоков в Django

0 голосов
/ 01 марта 2020

Моя цель - Django сохранять записи в записи БД по записи внутри потока. Мой код выглядит так: 

class MyThread(threading.Thread):
    def __init__(self, data, *args, **kwargs):
       self.data = data 
       super(MyThread, self).__init__(*args, **kwargs)

    def run(self):
        for record in data:
           s = MySerializer(data=record)
           if s.is_valid():
               s.save() # I want this record to appear in db at once

У меня ATOMIC_REQUESTS установлено значение True внутри settings.py. Я попытался включить команду s.save() в такой перевод: 

if s.is_valid():
   with transaction.atomic:
        s.save()

Но это не помогло. Интересно, возможно ли это и не является ли это анти-паттерном?

...