MongodbとAmazon Kinesisをインテリジェントで耐久性のあるストリームに統合します

リアルタイムデータストリーミングのためにMongodbとAmazon Kinesisを統合する

この記事では、MongodbとAmazon Kinesisを統合して、ライブイベントに反応する堅牢でリアルタイムのデータストリームを作成する方法を示しています。 これは、Mongodb Stitch Triggersを使用して達成されます。これは、関連するデータの変更がMongodb内で発生した場合にAWS Kinesisアクションを開始します。

この統合により、ユーザーの行動のリアルタイム分析、パーソナライズされた製品の推奨事項、詐欺検出など、さまざまなアプリケーションが可能になります。 Mongodbに保存され、Kinesisにストリーミングされたデータは、Amazon Kinesisデータ分析のようなダウンストリームサービスによって処理され、異常検出またはデータ集約が可能です。

前提条件：

mongodb atlas instance：
1. aTlasインスタンス（たとえば、という名前のデータベースを使用し、eコマースアプリケーションデータのという名前のコレクションを使用）。 Mongodb Atlasは、支援のためにガイドを開始しています。streamdata clickdata
AWSアカウントとKinesisストリーム：
2. 構成されたKinesisストリーム（この例では）を備えたAWSアカウント（Kinesis Analyticsなど）にデータを送信します。 stitchStreammongodbステッチアプリケーション：
ステッチアプリケーション（Atlas内で作成）
3. ステップバイステップ統合：

コレクションを作成：

ステッチアプリケーションで、コレクションを作成します（データベース：
1. 、コレクション：

   ）。 ユーザー固有のデータへのアクセスを制限するテンプレートを使用します（ユーザーIDフィールドを指定します）。 streamdata clickdata AWSのステッチを構成する

   AWSサービスと「kinesis」という名前のルールを追加して、すべてのKinesisアクションを許可するルールを追加することにより、AWS Kinesisと通信するようにステッチを設定します。

2. キネシスストリーミング関数を作成します：

   stitch関数（
）を作成して、Kinesisストリームにドキュメントを送信します。 次のコードを貼り付けます：

exports = function(event){
 const awsService = context.services.get('aws');
 try{
   awsService.kinesis().PutRecord({
     Data: JSON.stringify(event.fullDocument),
     StreamName: "stitchStream",
     PartitionKey: "1"
      }).then(function(response) {
        return response;
      });
 }
 catch(error){
  console.log(JSON.parse(error));
 }
};

4. 関数をテストします：ステッチコンソールを使用して関数をテストし、サンプルを提供しますeventオブジェクト：

event = {
   "operationType": "replace",
   "fullDocument": { /* ...sample document... */ },
   "ns": { "db": "streamdata", "coll": "clickdata" }
};
exports(event);

5. ステッチトリガーを構成：stitchトリガーを作成して、コレクションの挿入、更新、および置換のputKinesisRecord関数を自動的に実行します。 clickdata

6. トリガーをテストします：データがAmazon Kinesisダッシュボードを使用してKinesisストリームにストリーミングされていることを確認します。

7. 高度な機能： Amazon Kinesisデータ分析などのサービスを利用して、さらに処理する（異常検出、集約など）。

この詳細なガイドを使用すると、リアルタイムのデータ処理と分析のために両方のプラットフォームのパワーを活用して、MongodbとAmazon Kinesisをシームレスに統合できます。 さらなる支援とトラブルシューティングについては、提供されたリソースを参照してください。

以上がMongodbとAmazon Kinesisをインテリジェントで耐久性のあるストリームに統合しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。