データフローでのデータの処理とルーティング
データフローを使用すると、さまざまなデータ ソースを接続してデータ操作を実行できるため、データを移動、変換、エンリッチするためのデータ パスの設定が簡略化されます。 データフロー コンポーネントは、Azure Arc 拡張機能としてデプロイされる Azure IoT Operations の一部です。 データフローは、Kubernetes カスタム リソース定義 (CRD) を使用して構成されます。
次のようなさまざまなユース ケースの構成を記述できます。
- データを変換して MQTT に送り返す
- データを変換してクラウドに送信する
- データを変換なしでクラウドまたはエッジに送信する
データフローは、Azure IoT Operations インスタンスが展開されているリージョンに限定されません。 データフローを使用して、さまざまなリージョンのクラウド エンドポイントにデータを送信できます。
主要な機能
データフローの主な機能を次に示します。
データの処理とルーティング
データフローを使用すると、メッセージのインジェスト、処理、指定されたシンクへのルーティングを行うことができます。 以下を指定できます。
- ソース: メッセージの取り込み元
- 宛先: メッセージのドレイン先
- 変換 (省略可能): データ処理操作の構成
変換機能
処理ステージ中に変換をデータに適用して、さまざまな操作を実行できます。 この操作には、次のものが含まれます。
- 新しいプロパティの計算: メッセージ内の既存のプロパティに基づきます
- プロパティの名前の変更: データを標準化または明確化するためです
- 単位の変換: 値を別の測定単位に変換します
- 値の標準化: ユーザーが定義した範囲にプロパティ値をスケーリングします
- データのコンテキスト化: エンリッチメントと分析情報の促進のためにメッセージに参照データを追加します
構成とデプロイ
構成は、Kubernetes CRD を使用して指定します。 この構成に基づいて、データフロー オペレーターはデータフロー インスタンスを作成し、高可用性と信頼性を確保します。
メリット
- 簡略化されたセットアップ: データ ソースと変換先を簡単に接続します。
- 柔軟な変換: さまざまなデータ操作を実行します。
- スケーラブルな構成: Kubernetes CRD を使用して構成をスケーラブルかつ管理しやすくします。
- 高可用性: Kubernetes ネイティブ リソースにより、信頼性が確保されます。
データフローを使用すると、データ パスを効率的に管理できます。 運用上のニーズに合わせてデータが正確に送信、変換、エンリッチされることを保証できます。
スキーマ レジストリ
Azure デバイス レジストリで提供される機能であるスキーマ レジストリは、クラウドとエッジで同期されるリポジトリです。 スキーマ レジストリは、エッジ資産からのメッセージの定義を格納し、エッジでこれらのスキーマにアクセスするための API を公開します。 OPC UA 用コネクタのような Southbound コネクタは、メッセージ スキーマを作成してスキーマ レジストリに追加することができます。または、顧客は、スキーマを操作エクスペリエンス Web UI にアップロードすることができます。
Dataflows では、メッセージを宛先エンドポイントで想定されている形式に変換するために、メッセージ スキーマが使用されます。
詳細については、「メッセージ スキーマについて」を参照してください。