バルクアップセートが機能しないpymongo

Question

ドキュメントが存在する場合は更新し、コレクションに存在しない場合は挿入しています。 _idに基づいて、私はパンダのデータフレームレコードを文書としてコレクションに挿入しています。新しい文書の挿入は正常ですが、古い文書のフィールドの更新は機能していません。

bulk = pymongo.bulk.BulkOperationBuilder(pros_rides,ordered=False) 
for doc in bookings_df: 
    bulk.find({ "_id": doc["_id"] }).upsert().update({ 
     "$setOnInsert": doc 
    }) 
response = bulk.execute() 

どうすればよいですか？

Answer 1

upsertは、ドキュメントを更新または挿入することができます。 "$ setOnInsert"操作は、文書が挿入されたときにのみ実行され、は更新されず、に更新されます。ドキュメントが存在する場合は更新するために、ドキュメントが更新されたときに実行されるいくつかの操作を提供する必要があります。

は、この代わりのようなものを試してみてください：

bulk = pros_rides.initialize_unordered_bulk_op() 
for doc in books_df: 
    bulk.find({'_id': doc['_id']}).upsert().replace_one(doc) 

bulk.execute()