データ フローを使用すると、データを移動、変換、エンリッチするためのデータ パスの設定が簡略化されます。 データ フローを使用すると、さまざまなデータ ソースを接続し、データ操作を実行できます。 データ フロー コンポーネントは、Azure Arc拡張機能としてデプロイするAzure IoT Operationsの一部です。 操作エクスペリエンス Web UI、Azure CLI、またはAzure Resource Manager テンプレートを使用して、データ フローを構成します。
次のようなさまざまなユース ケースの構成を記述できます。
- データを変換し、MQTT に送り返します。
- データを変換してクラウドに送信します。
- 変換なしでクラウドまたはエッジにデータを送信します。
データ フローは、IoT Operations インスタンスをデプロイするリージョンに限定されるわけではありません。 データ フローを使用して、さまざまなリージョンのクラウド エンドポイントにデータを送信できます。
Note
データ フローは、プレビューのみの Data Processor コンポーネントを初期Azure IoT Operationsリリースから置き換えます。
--include-dpの az iot ops init パラメーターは削除され、不要になりました。データ フロー コンポーネントは自動的にデプロイされます。
主要な機能
このセクションでは、データ フローの主な機能について説明します。
データの処理とルーティング
データ フローを使用すると、メッセージのインジェスト、処理、指定されたシンクへのルーティングを行うことができます。 以下を指定できます。
- ソース: メッセージの取り込み元。
- 宛先: MQTT エンドポイントのメッセージ コンテンツに基づく動的トピック ルーティングのサポートを含む、メッセージのドレイン先。
- 変換 (省略可能): データ処理操作の構成。
変換機能
処理中にデータに変換を適用して、さまざまな操作を実行できます。 この操作には、次のものが含まれます。
- 新しいプロパティの計算: メッセージ内の既存のプロパティに基づく。
- プロパティの名前変更: データを標準化または明確にします。
- 単位の変換: 異なる測定単位に値を変換します。
- 値の標準化: プロパティ値をユーザー定義範囲にスケーリングします。
- データのコンテキスト化: メッセージに参照データを追加して、情報をエンリッチメントし、分析情報を促進します。
ヒント
条件付きルーティング、時間ベースの集計、構成可能な変換パイプラインなど、より豊富な処理機能については、 データ フロー グラフを参照してください。
構成とデプロイ
操作エクスペリエンス Web UI、Azure CLI、またはAzure Resource Manager テンプレートを使用して構成を指定します。 この構成に基づいて、データ フロー オペレーターはデータ フロー インスタンスを作成し、高可用性と信頼性を確保します。
メリット
- 簡略化されたセットアップ: データ ソースと変換先を簡単に接続できます。
- 柔軟な変換: さまざまなデータ操作を実行します。
- スケール可能な構成: スケーラブルで管理しやすい構成にはAzureツールを使用します。
- 高可用性: Kubernetes ネイティブ リソースによって信頼性が確保されます。
データ フローを使用すると、データ パスを効率的に管理できます。 運用上のニーズに合わせてデータが正確に送信、変換、エンリッチされることを保証できます。
スキーマ レジストリ
Azure Device Registry によって提供される機能であるスキーマ レジストリは、クラウドとエッジの同期されたリポジトリです。 スキーマ レジストリは、エッジ資産からのメッセージの定義を格納し、エッジでこれらのスキーマにアクセスするための API を公開します。 OPC UA 用コネクタのような南向きコネクタでは、メッセージ スキーマを作成してスキーマ レジストリに追加したり、操作エクスペリエンス Web UI にスキーマをアップロードしたりできます。
データ フローでは、メッセージ スキーマを使用して、送信先エンドポイントで想定される形式にメッセージを変換します。
詳細については、「 メッセージ スキーマについて」を参照してください。
データ バッファリングとディスクの永続化
データ フローが宛先エンドポイントにメッセージを送信すると、宛先またはネットワークが使用できなくなる可能性があります。 配信が完了できない場合、データ フローはソース メッセージを確認しません。 MQTT ブローカーはメッセージをサブスクライバー キューに保持し、データ フローは配信を再試行します。
宛先の停止動作、ブローカー サブスクライバー キュー、ディスクに基づくメッセージ バッファー、ブローカー永続化、データ フローの requestDiskPersistenceについては、「データ フロー のデータ バッファリングとディスク永続化の構成」を参照してください。