Azure Event Hubs ソースを eventstream に追加する

1. [ 接続設定の構成 ] ページで、機能レベルで [基本 ] が選択されていることを確認し、[ 新しい接続] を選択します。

   

   イベント ハブへの既存の接続がある場合は、その既存の接続を選択します。 次に、次の手順でデータ形式の構成に進みます。

   

2. [接続設定] セクションで、次の手順に従います:

   1. Event Hubs の名前空間の名前を入力します。
   2. イベント ハブの名前を入力します。

   

3. [ 接続資格情報 ] セクションで、次の手順に従います。

   1. [ 接続名] に、イベント ハブへの接続の名前を入力します。
   2. [認証の種類] で、[共有アクセス キー] が選択されていることを確認します。
   3. [ 共有アクセス キー名] に、共有アクセス キーの名前を入力します。 アクセス キーを取得する手順については、「 Azure Event Hubs 接続文字列を取得する」を参照してください。
   4. [ 共有アクセス キー] に、共有アクセス キーの値を入力します。
   5. [接続] を選択します。

   

4. コンシューマー グループの場合は、コンシューマー グループの名前を入力します。 イベント ハブの既定のコンシューマー グループは $Default。

5. [データ形式] では、Azure イベント ハブから取得する受信リアルタイム イベントのデータ形式を選択します。 JSON、Avro、CSV (ヘッダー付き) データ形式から選択できます。

   

6. 右側の [ ソースの詳細 ] ウィンドウで、ソース名の横にある鉛筆アイコンを選択し、ソースの名前を入力します。 このステップはオプションです。

   

7. ページの下部にある次へ を選択します。

   

8. [ 確認と接続 ] ページで設定を確認し、[ 追加] を選択します。

   

1. [ 接続設定の構成 ] ページの [ 機能レベルの選択] で、[ 拡張機能] を選択します。

   

   イベント ハブへの既存の接続がある場合は、その既存の接続を選択します。 次に、次の手順でデータ形式の構成に進みます。

2. [接続設定] セクションで、次の手順に従います:

   1. Event Hubs の名前空間の名前を入力します。

   2. イベント ハブの名前を入力します。

      

3. [ 接続資格情報 ] セクションで、次の手順に従います。

   1. [ 接続名] に、イベント ハブへの接続の名前を入力します。

   2. [認証の種類] で、[共有アクセス キー] が選択されていることを確認します。

   3. [ 共有アクセス キー名] に、共有アクセス キーの名前を入力します。 アクセス キーを取得する手順については、「 Azure Event Hubs 接続文字列を取得する」を参照してください。

   4. [ 共有アクセス キー] に、共有アクセス キーの値を入力します。

   5. [接続] を選択します。

      

4. コンシューマー グループの場合は、コンシューマー グループの名前を入力します。 イベント ハブの既定のコンシューマー グループは $Default。

   

5. 右側の [ ソースの詳細 ] ウィンドウで、ソース名の横にある鉛筆アイコンを選択し、ソースの名前を入力します。 このステップはオプションです。

   

6. ページの下部にある次へ を選択します。

7. [ スキーマ処理 ] ページで、選択したイベント ハブから受信したイベントを処理するルールを指定して、eventstream がそれらを正しく適用できるようにする必要があります。 マッピング ルールは、イベントのモデル化方法によって異なります。

   すべてのイベントを管理するスキーマが 1 つある場合は、[ 固定スキーマ] を選択します。

   さまざまな受信イベントを表す複数のスキーマがある場合は、スキーマを適用する照合ルールを定義できます。 このモードを選択するには、[ ヘッダーによる動的スキーマ ] オプションを選択します。 次に、ヘッダーと値のペアを使用して各スキーマを選択して規則を指定します。 ヘッダーは、イベント メタデータの一部であるカスタム Kafka ヘッダー プロパティです。 この値は、そのプロパティに対して想定される値です。

   

8. [ スキーマの追加 ] ドロップダウン メニューを選択し、イベント スキーマ レジストリから 1 つ以上の既存のスキーマを選択して、スキーマを選択します。 選択するスキーマがない場合は、このビューから新しいスキーマを作成できます。 新しいイベント スキーマを定義する方法については、「スキーマ セットでのイベント スキーマの作成と管理」を参照してください。

   

   [ イベント スキーマ レジストリから選択 ] オプションを選択した場合は、[ イベント スキーマの関連付け ] ウィンドウが表示されます。 スキーマ一致モードに応じて、レジストリから 1 つ以上のスキーマを選択し、ウィンドウの下部にある [選択] を 選択 します。

   

9. [固定スキーマ] オプションを選択した場合は、スキーマに一致する規則をこれ以上指定する必要はありません。 次の手順に進むことができます。

   [ ヘッダーによる動的スキーマ ] オプションを選択した場合は、Kafka ヘッダー プロパティと、スキーマにマップされる予期される値を指定します。 スキーマをさらに追加し、それらのスキーマにマップするさまざまなヘッダー プロパティや異なる値を指定します。

   注

   マッピング ルールを定義する場合、ヘッダーの各値は一意である 必要があります 。 スキーマを再利用しようとすると、既存のストリームを中断する可能性があることを示す警告メッセージが表示されます。 マッピング規則が同じである限り、スキーマを再利用できます。 この制限がユーザーの使用に影響する場合は、Microsoft の担当者に連絡してフィードバックを共有してください。 この制限の削除に積極的に取り組んでいます。

   

10. すべての予期されるイベントのスキーマがマップされたら、[スキーマ処理] ページの下部にある [次へ] を選択します。

    

11. [ 確認と接続 ] ページで設定を確認し、[ 接続] を選択します。

    

12. [確認と接続] ページで [追加] を選択します。

    

更新されたイベントストリームを表示する

1. 編集モードで、Event Hubs ソースがキャンバス上の eventstream に追加されていることを確認します。 [ 最新の情報に更新] を選択すると、イベント ハブにデータのプレビューが表示されます。 この新しく追加されたイベント ハブを実装するには、リボンの [発行 ] を選択します。

   

2. イベント ハブは、 ライブ ビューで視覚化できます。 ダイアグラムで [イベント ハブ ] タイルを選択して、次の例のようなウィンドウを開きます。

   

更新されたイベントストリームを表示する

1. 編集モードで、Event Hubs ソースがキャンバス上の eventstream に追加されていることを確認します。 [ 最新の情報に更新] を選択すると、イベント ハブにデータのプレビューが表示されます。 この新しく追加されたイベント ハブを実装するには、リボンの [発行 ] を選択します。

   

2. イベント ハブは、 ライブ ビューで視覚化できます。 ダイアグラムで [イベント ハブ ] タイルを選択して、次の例のようなウィンドウを開きます。

   

スキーマを使用するように eventstream 送信先を構成する

現時点では、拡張機能が有効になっているイベントストリームでは、eventhouse、カスタム エンドポイント、および派生ストリーム変換先のみがサポートされています。 このセクションでは、イベントストリームに対して拡張機能 (スキーマ サポートなど) が有効になっている場合に、eventhouse 変換先を追加および構成する方法について説明します。

カスタム エンドポイント変換先のスキーマを構成する

1. [ イベントの変換] または [宛先の追加] を選択し、[ CustomEndpoint] を選択します。

2. [ カスタム エンドポイント ] ウィンドウで、宛先の名前を指定します。

3. [入力スキーマ] で、イベントのスキーマを選択します。 このボックスでは、イベントストリームのスキーマサポートを有効にするときに選択します。

カスタム エンドポイントの送信先を構成する詳細な手順については、「 カスタム エンドポイントまたはカスタム アプリの宛先をイベントストリームに追加する」を参照してください。

イベントハウスの宛先に対するスキーマを設定する

1. [ イベントの変換] または [宛先の追加] を選択し、[ Eventhouse] を選択します。

2. [Eventhouse] ウィンドウで、次のスキーマ関連の設定を構成します。

   1. [入力スキーマ] で、ドロップダウン リストから 1 つ以上のスキーマを選択します。

      

      注

      Event Hubs ソースを構成するときに [ヘッダーによる動的スキーマ ] オプションを選択した場合は、ソースに対して複数のスキーマを構成し、それらをさまざまなプロパティとその値にマップしている可能性があります。

   2. [テーブルの作成方法] では、要件に応じて、すべてのスキーマを結合した 1 つのテーブルを選択するか、スキーマごとに個別のテーブルを選択します。

      

   3. [ データの書き込み方法] で、次のいずれかのオプションを選択します。

      • ペイロードのみ: 抽出されたペイロード データをテーブルに書き込みます。 複数の入力スキーマがある場合、データは複数のテーブルに送信されます。
      • メタデータとペイロード: メタデータとペイロード データを 1 つのテーブルに書き込みます。 列の例には、 source 、 subject、 type、および dataがあります。

      

イベントハウスの宛先を構成する詳細な手順については、「 イベントストリームにイベントハウスの宛先を追加する」を参照してください。