django /セロリデータのインポートで既存のデータがチェックされない

Question

私はdjangoでセロリを実行しています。タスクを使用して、オブジェクトのストリームをデータベースにインポートします。各タスクは1つのオブジェクトをインポートします。並行性はストリーム内では2です。オブジェクトは複製できますが、私のデータベース内にあるべきではありません。私が実行しているよ

コード：

if qs.exists() and qs.count() == 1: 
    return qs.get() 
elif qs.exists(): 
    logger.exception('Multiple venues for same place') 
    raise ValueError('Multiple venues for same place') 
else: 
    obj = self.create(**defaults) 

問題は、ストリーム内のオブジェクトが重複し、互いに非常に接近している場合、アプリはまだ二度同じオブジェクトをインポートしていることです。

DBチェックがこの並行処理設定で正しく機能していないと仮定します。この問題を解決するにはどのアーキテクチャをお勧めしますか？

Answer 1

ロックアーキテクチャを使用する必要があります。したがって、2つのタスクが同時にオブジェクトフェッチパートを実行するのをブロックします。python-redis-lockを使用してください。