sql >> Database >  >> NoSQL >> MongoDB

Mongo Change Streams die meerdere keren worden uitgevoerd (soort van):Node-app die meerdere instanties uitvoert

Dit doen met sterke garanties is moeilijk, maar niet onmogelijk. Ik schreef hier over de details van één oplossing:https://www.alechenninger.com/2020/05/building-kafka-like-message-queue-with.html

De voorbeelden zijn in Java, maar het belangrijkste is het algoritme.

Het komt neer op een paar technieken:

  • Elk proces probeert een slot te verkrijgen
  • Elk slot (of elke wijziging) heeft een bijbehorend hekfiche
  • Het verwerken van elke wijziging moet idempotent zijn
  • Tijdens het verwerken van de wijziging wordt het token gebruikt om te zorgen voor geordende, effectief eenmalige updates.

Meer details in de blogpost.



  1. Is er een manier om paginering te implementeren in de lente webflux en reactieve lentegegevens?

  2. 3 manieren om een ​​willekeurig voorbeeld van documenten uit een MongoDB-verzameling te retourneren

  3. StackExchange.Redis met Azure Redis is onbruikbaar traag of veroorzaakt time-outfouten

  4. Redis scan sleutels overslaan