Kann der Fehler reproduziert werden?
Ja, verwenden wir die berühmte Publication und Article Modelle aus Django-Dokumentation
. Dann lass uns ein paar Threads erstellen.
import threading
import random
def populate():
for i in range(100):
Article.objects.create(headline = 'headline{0}'.format(i))
Publication.objects.create(title = 'title{0}'.format(i))
print 'created objects'
class MyThread(threading.Thread):
def run(self):
for q in range(1,100):
for i in range(1,5):
pub = Publication.objects.all()[random.randint(1,2)]
for j in range(1,5):
article = Article.objects.all()[random.randint(1,15)]
pub.article_set.add(article)
print self.name
Article.objects.all().delete()
Publication.objects.all().delete()
populate()
thrd1 = MyThread()
thrd2 = MyThread()
thrd3 = MyThread()
thrd1.start()
thrd2.start()
thrd3.start()
Sie werden sicher Verstöße gegen eindeutige Schlüsselbeschränkungen des Typs sehen, der im Fehlerbericht gemeldet wird . Wenn Sie sie nicht sehen, versuchen Sie, die Anzahl der Threads oder Iterationen zu erhöhen.
Gibt es eine Problemumgehung?
Ja. Verwenden Sie through Modelle und get_or_create . Hier ist die aus dem Beispiel in der Django-Dokumentation angepasste models.py.
class Publication(models.Model):
title = models.CharField(max_length=30)
def __str__(self): # __unicode__ on Python 2
return self.title
class Meta:
ordering = ('title',)
class Article(models.Model):
headline = models.CharField(max_length=100)
publications = models.ManyToManyField(Publication, through='ArticlePublication')
def __str__(self): # __unicode__ on Python 2
return self.headline
class Meta:
ordering = ('headline',)
class ArticlePublication(models.Model):
article = models.ForeignKey('Article', on_delete=models.CASCADE)
publication = models.ForeignKey('Publication', on_delete=models.CASCADE)
class Meta:
unique_together = ('article','publication')
Hier ist die neue Threading-Klasse, die eine Modifikation der obigen ist.
class MyThread2(threading.Thread):
def run(self):
for q in range(1,100):
for i in range(1,5):
pub = Publication.objects.all()[random.randint(1,2)]
for j in range(1,5):
article = Article.objects.all()[random.randint(1,15)]
ap , c = ArticlePublication.objects.get_or_create(article=article, publication=pub)
print 'Get or create', self.name
Sie werden feststellen, dass die Ausnahme nicht mehr angezeigt wird. Fühlen Sie sich frei, die Anzahl der Iterationen zu erhöhen. Ich bin nur mit get_or_create auf 1000 gestiegen es hat die Ausnahme nicht ausgelöst. Allerdings add() warf normalerweise eine Ausnahme mit in 20 Iterationen.
Warum funktioniert das?
Denn get_or_create ist atomar.
Aktualisierung: Danke @louis für den Hinweis, dass das Durchgangsmodell tatsächlich eliminiert werden kann. Also get_or_create in MyThread2 kann geändert werden als.
ap , c = article.publications.through.objects.get_or_create(
article=article, publication=pub)
