MQTT データを 時系列データベース にストリーミング

EMQX はデバイス接続を処理し、保存前にテレメトリを前処理します。SQL ルールでメッセージのフィルタリングやフィールドの変換を行い、データベース統合がその結果を対応する書き込み先に書き込みます。

EMQX は InfluxDB、TimescaleDB、Apache IoTDB、ClickHouse、GreptimeDB などのデータベースとの統合をサポートしています。対応バージョンと設定については、各ガイドをご確認ください。Prometheus は、監視のために EMQX ブローカーのメトリクスを収集します。

対応するデータベース Sink は、一時的な中断の間、リクエストをバッファリングして配信をリトライできます。データを保持できる範囲は、コネクター、バッファモードと容量、リクエストの有効期限（TTL）によって異なります。失敗・破棄されたリクエストを監視してください。バッファリングによってデータを無期限に保持できるわけではありません。

はい。SQL ルールを使って、データベースに書き込む前にメッセージのフィルタリング、タイムスタンプと測定値の選択、フィールド値の変換を行えます。出力フィールドとその型は、データベースのスキーマに合わせてください。

使用するデータベースに対応したコネクターを選び、そのガイドで対応バージョン、認証情報、書き込みフォーマットを確認してください。ルールとデータベース Sink を設定したら、書き込み先でタイムスタンプと測定値を確認します。