sql >> データベース >  >> NoSQL >> MongoDB

複数回実行されているMongoChangeStreams(種類):複数のインスタンスを実行しているノードアプリ

    強力な保証でこれを行うことは困難ですが、不可能ではありません。ここに1つのソリューションの詳細について書きました:https://www.alechenninger.com/2020/05/building-kafka-like-message-queue-with.html

    例はJavaですが、重要な部分はアルゴリズムです。

    それはいくつかのテクニックに帰着します:

    • 各プロセスはロックの取得を試みます
    • 各ロック(または各変更)には、フェンシングトークンが関連付けられています。
    • 各変更の処理はべき等である必要があります
    • 変更を処理している間、トークンは順序付けられた、効果的に1回限りの更新を保証するために使用されます。

    詳細については、ブログ投稿をご覧ください。



    1. Dockerコンテナ(Python、Flask、Redis)内でカスタムRQワーカーを起動する方法

    2. Hadoop –初心者向けのApacheHadoopチュートリアル

    3. Puppetを使用したMongoDBのデプロイとメンテナンスのガイド:パート1

    4. Mongooseドキュメント内で自由形式のJSONデータを許可するにはどうすればよいですか?