Я обновляю ~ 600 000 документов в коллекции монго, используя некоторый код PyMongo, который выглядит так:
bulk = coll.initialize_ordered_bulk_op()
for index, row in df.iterrows():
bulk.find({ '_id': ObjectId(row['id']) }).update({ '$set': { "X":
row['X'].split(',') } })
bulk.execute()
После некоторого дальнейшего изучения я понял, что может потерпеть неудачу для> 100 000 документов, и мне придется сделать что-то вроде того, что предлагается здесь.
Однако он отлично работает со всеми документами. Мне просто любопытно узнать, что я неправильно понял.
Заранее спасибо.