sql >> Databáze >  >> NoSQL >> MongoDB

Mongo Change Streams běžící vícekrát (druh):Aplikace Node spouští více instancí

Udělat to se silnými zárukami je obtížné, ale ne nemožné. O podrobnostech jednoho řešení jsem psal zde:https://www.alechenninger.com/2020/05/building-kafka-like-message-queue-with.html

Příklady jsou v Javě, ale důležitou součástí je algoritmus.

Jde o několik technik:

  • Každý proces se pokusí získat zámek
  • Každý zámek (nebo každá změna) má přidružený token oplocení
  • Zpracování každé změny musí být idempotentní
  • Během zpracování změny se token používá k zajištění uspořádaných a efektivních aktualizací.

Více podrobností v příspěvku na blogu.



  1. Jaká je maximální velikost dávkové operace MongoDB?

  2. MongoDB tečka (.) v názvu klíče

  3. $unionWith – MongoDB je ekvivalent UNION ALL

  4. Zničení / odstranění Queue() v Redis Queue (rq) programově