Как прослушать изменения в коллекции MongoDB?

То, о чем вы думаете, очень похоже на триггеры. У MongoDB нет поддержки триггеров, однако некоторые люди "сворачивали", используя некоторые трюки. Ключ здесь - это oplog.

Когда вы запускаете MongoDB в наборе реплик, все действия MongoDB записываются в журнал операций (известный как oplog). Oplog - это в основном простой список изменений, внесенных в данные. Replicas Устанавливает функцию, слушая изменения в этом всплеске, а затем применяя изменения локально.

Звучит ли это знакомо?

Я не могу подробно описать весь процесс здесь, это несколько страниц документации, но необходимые инструменты доступны.

Сначала некоторые рецензии на oplog  - Краткое описание  - Макет local коллекции (который содержит oplog)

Вы также захотите использовать tailable cursors. Они предоставят вам возможность прослушать изменения вместо опроса для них. Обратите внимание, что репликация использует хвостовые курсоры, поэтому это поддерживаемая функция.

Так как MongoDB 3.6 появится новый API уведомлений, который вы можете использовать для этого. См. это сообщение в блоге для примера. Пример из него:

cursor = client.my_db.my_collection.changes([
    {'$match': {
        'operationType': {'$in': ['insert', 'replace']}
    }},
    {'$match': {
        'newDocument.n': {'$gte': 1}
    }}
])

# Loops forever.
for change in cursor:
    print(change['newDocument'])

В качестве альтернативы вы можете использовать стандартный метод Mongo FindAndUpdate, а в обратном вызове запускать событие EventEmitter (в Node), когда выполняется обратный вызов.

Любые другие части приложения или архитектуры, прослушивающие это событие, будут уведомлены об обновлении и любые соответствующие данные, отправленные туда. Это действительно простой способ получения уведомлений от Mongo.

Многие из этих ответов будут давать вам новые записи, а не обновления и/или крайне неэффективны

Единственный надежный, эффективный способ сделать это - создать хвостовой курсор в локальной коллекции db: oplog.rs, чтобы получить ВСЕ изменения в MongoDB и сделать с ними то, что вы сделаете. (MongoDB даже делает это внутренне более или менее для поддержки репликации!)

Объяснение того, что содержит oplog: https://www.compose.com/articles/the-mongodb-oplog-and-node-js/

Пример библиотеки Node.js, которая предоставляет API вокруг того, что можно сделать с помощью oplog: https://github.com/cayasso/mongo-oplog

Существует рабочий пример java, который можно найти здесь.

 MongoClient mongoClient = new MongoClient();
    DBCollection coll = mongoClient.getDatabase("local").getCollection("oplog.rs");

    DBCursor cur = coll.find().sort(BasicDBObjectBuilder.start("$natural", 1).get())
            .addOption(Bytes.QUERYOPTION_TAILABLE | Bytes.QUERYOPTION_AWAITDATA);

    System.out.println("== open cursor ==");

    Runnable task = () -> {
        System.out.println("\tWaiting for events");
        while (cur.hasNext()) {
            DBObject obj = cur.next();
            System.out.println( obj );

        }
    };
    new Thread(task).start();

Ключ QUERY OPTIONS, указанный здесь.

Также вы можете изменить запрос поиска, если вам не нужно каждый раз загружать все данные.

BasicDBObject query= new BasicDBObject();
query.put("ts", new BasicDBObject("$gt", new BsonTimestamp(1471952088, 1))); //timestamp is within some range
query.put("op", "i"); //Only insert operation

DBCursor cur = coll.find(query).sort(BasicDBObjectBuilder.start("$natural", 1).get())
.addOption(Bytes.QUERYOPTION_TAILABLE | Bytes.QUERYOPTION_AWAITDATA);

Собственно, вместо просмотра вывода, почему вы не замечаете, когда что-то новое вставлено с помощью промежуточного продукта, которое было предоставлено схема mongoose

Вы можете поймать событие вставки нового документа и сделать что-то после этой вставки