Как смотреть объемные вставки только пимонго - PullRequest
Новая
       6

Как смотреть объемные вставки только пимонго

0 голосов
/ 18 июня 2020

У меня есть сценарий python, который вызывает: 

db.collection.insert_many(documents)

И еще одна программа, отслеживающая изменения в db : 

with db.watch() as stream:
    for change in stream:
        # Do something on on a change

Я вставляю Более 100 000 документов с insert_many и хотят что-то делать только после того, как insert_many (документы) завершены. Проблема в том, что insert_many идет одна за другой, и каждая вставка будет отображаться в потоке изменений. как только insert_many завершится, отбросьте коллекцию. 

db.dummy_collection.watch():
    for change in stream:
     # Look for change as operationType: drop
     # Do whatever I want with those newly added documents

Это работает с некоторыми потенциальными ошибками (два человека загружают одновременно). Есть ли способ получше?

...