Comment puis-je obtenir des mises à jour en temps réel sur une requête Gremlin?

Question

Je suis tombé amoureux de mises à jour de streaming en temps réel à une requête lorsque j'utilisais Firebase, RethinkDB et similaire. Maintenant que je travaille avec des bases de données graphiques via Gremlin, je me demande comment obtenir ce comportement.

Par exemple trivial, si je spécifié une requête Gremlin comme:

g.V().values('name') 

Je souhaite recevoir une mise à jour quand un nouveau sommet est ajouté avec une propriété de nom ou un nom est changé sur une sommet existant. Je commence à utiliser Janusgraph, donc la solution idéale fonctionnerait là-bas - mais c'est une caractéristique tellement meurtrière que je pourrais être incliné à other Gremlin-friendly graph databases.

Merci!

Answer 1

Vous pouvez utiliser un EventStrategy avec n'importe quelle base de données de graphe compatible Tinkerpop. Une fois que vous avez créé la stratégie d'événement, vous l'ajoutez à votre traversée g = graph.traversal().withStrategies(strategy). Vous devrez implémenter l'interface MutationListener pour faire ce que vous voulez sur ces événements.

Answer 2

OrientDB a livequery si je ne sais pas qu'il intègre avec Gremlin - https://orientdb.com/docs/2.1/Live-Query.html - c'est le plus proche chose que je connais ce genre de fonctionnalité dans une base de données graphique compatible TinkerPop