非同期コードに欠陥があり、db.close()
行は非同期のinsert
の前に実行されます コマンドはすべて完了しました。プログラムのフローを制御する必要があります。A)データベースの同時挿入が100万回発生しないようにし、B)すべてがmongoによって処理されるまで待ってから、接続を閉じます。 async.forEach
などのヘルパーライブラリについて考えてみます。 自分でコーディングしたくない場合は、これを支援します。
非同期コードに欠陥があり、db.close()
行は非同期のinsert
の前に実行されます コマンドはすべて完了しました。プログラムのフローを制御する必要があります。A)データベースの同時挿入が100万回発生しないようにし、B)すべてがmongoによって処理されるまで待ってから、接続を閉じます。 async.forEach
などのヘルパーライブラリについて考えてみます。 自分でコーディングしたくない場合は、これを支援します。
ジェネレータを使用したPyMongoの一括書き込み操作機能 MongoError:トポロジが閉じています。接続はMongoClient.close()に関連しているようで、使用中はクライアントが機能しません。