Comment écouter pour un changement de collection MongoDB?

MongoDB a ce qu'on appelle plafonné collections et tailable curseurs qui permet de MongoDB à envoyer des données aux auditeurs.

Un capped collection est essentiellement une collection qui est d'une taille fixe et ne permet que des insertions. Voici à quoi il pourrait ressembler, pour en créer un:

db.createCollection("messages", { capped: true, size: 100000000 })

MongoDB Tailable curseurs (original post par Jonathan H. Salaire)

Ruby

coll = db.collection('my_collection')
cursor = Mongo::Cursor.new(coll, :tailable => true)
loop do
  if doc = cursor.next_document
    puts doc
  else
    sleep 1
  end
end

PHP

$mongo = new Mongo();
$db = $mongo->selectDB('my_db')
$coll = $db->selectCollection('my_collection');
$cursor = $coll->find()->tailable(true);
while (true) {
    if ($cursor->hasNext()) {
        $doc = $cursor->getNext();
        print_r($doc);
    } else {
        sleep(1);
    }
}

Python (par Robert Stewart)

from pymongo import Connection
import time

db = Connection().my_db
coll = db.my_collection
cursor = coll.find(tailable=True)
while cursor.alive:
    try:
        doc = cursor.next()
        print doc
    except StopIteration:
        time.sleep(1)

Perl (par Max)

use 5.010;

use strict;
use warnings;
use MongoDB;

my $db = MongoDB::Connection->new;
my $coll = $db->my_db->my_collection;
my $cursor = $coll->find->tailable(1);
for (;;)
{
    if (defined(my $doc = $cursor->next))
    {
        say $doc;
    }
    else
    {
        sleep 1;
    }
}

Ressources Supplémentaires:

Ruby/Node.js le Didacticiel qui vous guide à travers la création d'une application à l'écoute de l'insère dans une MongoDB plafonné collection.

Un article qui parle de tailable curseurs plus en détail.

PHP, Ruby, Python, Perl et des exemples d'utilisation de tailable curseurs.

Découvrez ce: Changement de Flux de

10 Janvier 2018 - Version 3.6

*EDIT: j'ai écrit un article sur la façon de le faire https://medium.com/riow/mongodb-data-collection-change-85b63d96ff76

https://docs.mongodb.com/v3.6/changeStreams/

---

Il y a de nouveau dans mongodb 3.6
https://docs.mongodb.com/manual/release-notes/3.6/ 2018/01/10

$ mongod --version
db version v3.6.2

---

Afin d'utiliser changeStreams la base de données doit être un Réplication Ensemble

Plus sur les Jeux de Réplication:
https://docs.mongodb.com/manual/replication/

Votre Base de données sera un "Autonome" par défaut.

Comment Convertir Autonome à un Jeu de Réplicas: https://docs.mongodb.com/manual/tutorial/convert-standalone-to-replica-set/

---

Suivantes exemple est une application pratique pour savoir comment vous pouvez l'utiliser.

* Spécifiquement pour le Nœud.

/* file.js */
'use strict'


module.exports = function (
    app,
    io,
    User //Collection Name
) {
    //SET WATCH ON COLLECTION 
    const changeStream = User.watch();  

    //Socket Connection  
    io.on('connection', function (socket) {
        console.log('Connection!');

        //USERS - Change
        changeStream.on('change', function(change) {
            console.log('COLLECTION CHANGED');

            User.find({}, (err, data) => {
                if (err) throw err;

                if (data) {
                    //RESEND ALL USERS
                    socket.emit('users', data);
                }
            });
        });
    });
};
/* END - file.js */

---

Liens utiles:

https://docs.mongodb.com/manual/tutorial/convert-standalone-to-replica-set

https://docs.mongodb.com/manual/tutorial/change-streams-example

https://docs.mongodb.com/v3.6/tutorial/change-streams-example

http://plusnconsulting.com/post/MongoDB-Change-Streams

Sinon, vous pouvez utiliser la norme Mongo FindAndUpdate méthode, et dans le rappel, le feu à un EventEmitter événement (Nœud) lorsque le rappel est exécuté.

Toutes les autres parties de l'application ou de l'architecture à l'écoute de cet événement seront informés de la mise à jour, et toutes autres données pertinentes envoyé là-bas aussi. C'est vraiment une façon simple d'obtenir des notifications de Mongo.

Il y a un travail exemple java qui peut être trouvé ici.

 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();

La clé est LES OPTIONS DE REQUÊTE donné ici.

Aussi vous pouvez modifier à trouver de la requête, si vous n'avez pas besoin de charger toutes les données à chaque fois.

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);

Il s'agit d'un impressionnant ensemble de services disponibles appelé MongoDB Point. Regarder dans les fonctions de points ou de déclencheurs. Notons que c'est un nuage payé service (AWS). Dans votre cas, sur la notice, vous pourriez l'appeler une fonction personnalisée écrite en javascript.