Комбинирование операций MongoDB

Введение в MongoDB на Python

Filip Schouwenaars

Machine Learning Researcher

Создание групповой операции

from pymongo import InsertOne, UpdateOne    # import classes

operations = [
    InsertOne({                             # operation 1
        "title": "Dune",
        "genre": ["action", "adventure", "drama"],
        "release_year": 2021,
        "rating": 8.0,
        "won_oscar": False
    }),
    UpdateOne(                              # operation 2
        { "title": "Titanic" },
        { "$set": { "won_oscar": True } }
    )
]

result = mov.bulk_write(operations)         # pass list to bulk_write

Анализ результата

print(result.inserted_count)

print(result.modified_count)

Важно помнить

Операции выполняются по порядку: ранее выполненные не откатываются
Нужна большая надёжность? Используйте транзакции

Зачем использовать bulk_write?

Эффективность
- Все операции отправляются в одном запросе
- Экономия времени и снижение сетевых издержек
Отслеживаемость
- Единый объект результата
- Сводная информация по всем операциям
- Удобнее для аудита и отладки
Чистота кода
- Операции не разбросаны по коду
- Логика сгруппирована и легко читается

Что можно комбинировать?

Можно использовать любое сочетание:
- InsertOne()
- UpdateOne() / UpdateMany() / ReplaceOne()
- DeleteOne() / DeleteMany()
- ReplaceOne()
Отлично подходит для:
- Синхронизации данных
- Очистки наборов данных
- Массового импорта

Давайте потренируемся!

Введение в MongoDB на Python