MQTT データを MongoDB にストリーミング

MongoDB はテレメトリデータを BSON ドキュメントとして保存し、ネストされたオブジェクト、配列、デバイスごとに異なるメタデータを扱えます。EMQX が MQTT データの取り込みと前処理を担い、MongoDB Sink がそのデータをコレクションに挿入します。ここで示すデータフローは、EMQX から MongoDB への一方向です。

EMQX の SQL ルールでフィールドを整えたうえで、Sink のペイロードテンプレートで結果をマッピングします。バイナリ形式やカスタム形式のペイロードは、事前に適切なデコーダーで解析する必要があります。テンプレートでは、型を保持するために文字列は引用符で囲み、数値は引用符で囲まないでください。代表的なデバイスメッセージでテストすることをお勧めします。

はい。ワークロードに見合った規模でデプロイすればスケールできます。処理能力は、メッセージのサイズとレート、ドキュメント構造、インデックス、データベースのリソースによって決まります。MongoDB のレプリカセットは冗長性とフェイルオーバーを提供し、シャーディングはデータを複数のシャードに分散します。代表的なトラフィックとクエリを用いて、パイプライン全体のベンチマークを実施してください。

EMQX は送信待ちのリクエストをバッファリングし、回復可能なエラーを再試行できます。配信を遅らせられる時間は、バッファ容量とリクエストの有効期限によって制限されます。失敗したリクエストと破棄されたリクエストを監視し、中断や再起動後の復旧をテストしたうえで、耐久性の要件に合わせて MongoDB の書き込み確認を設定してください。

MongoDB 統合に対応した EMQX、データベースへのネットワークアクセス、書き込み権限のある認証情報が必要です。MongoDB のデプロイ構成に合わせてコネクターを設定し、SQL ルールと、コレクションおよびペイロードテンプレートを指定した Sink を作成します。TLS を有効にして接続を暗号化し、テストドキュメントで書き込みを確認してください。