Microsoft Azure Event Hubsは、毎秒数百万のイベントを取り込み処理する高スループットのデータ・ストリーミング・プラットフォームで、リアルタイム分析と企業システム全体のシームレスな統合を可能にします。
このタスクの概要
IBM® App Connect Enterprise Windows、 AIX、および Linux® システムで利用可能な「 Microsoft Azure 」Event Hubs入力ノードおよび「 Microsoft Azure 」Event Hubsリクエストノードを介して、 Microsoft Azure Event Hubs と同期通信を行います。
メッセージフローで Microsoft Azure Event Hubs Input ノードを使用すると、 Microsoft Azure Event Hubs からの入力を受け付けることができます。 例えば、 Microsoft Azure Event Hubs Input ノードを使用して、 Microsoft Azure Event Hubs の新しいメッセージを監視することができます。 新しいメッセージが作成されると、 Microsoft Azure Event Hubs Input ノードは、新しいイベントの詳細を持つビジネス・オブジェクトを表すメッセージ・ツリーを生成します。 メッセージツリーはOut端末に伝搬され、メッセージフローの残りの部分は、他のシステムを更新したり、変更を監査したりするためにデータを使用することができる。 Microsoft Azure Event Hubs Input ノードの設定については、 Microsoft Azure Event Hubs Input nodeを参照してください。
Microsoft Azure Event Hubs Request ノードを使用して、 Microsoft Azure Event Hubs に接続し、コンシューマー・グループ、メッセージ、イベント・ハブ、パーティションなどのオブジェクトに対してアクションを実行するリクエストを発行できます。 詳細は、 Microsoft Azure Event Hubs Request nodeを参照。
手順
以下の手順では、 Microsoft Azure Event Hubs アカウントに接続し、コネクタ検出を使用して Microsoft Azure Event Hubs Request ノードを構成する方法を示します。 Microsoft Azure Event Hubs Input ノードを含むフローを作成し、コネクター・ディスカバリーを介して構成することで、 Microsoft Azure Event Hubs Input ノードを構成して、 Microsoft Azure Event Hubsの入力を監視することができます。
- IBM App Connect Enterprise ツールキットで、 Microsoft Azure のEvent Hubsリクエストノードを含むフローを作成します。
- フローで Microsoft Azure Event Hubs Request ノードを選択し、エディタにノードプロパティを表示します。
- 基本タブで、 Launch Connector Discovery をクリックします。
コネクターのディスカバリー中に使用するポリシー・プロジェクトの名前とボールトの詳細を指定するパネルが表示されます。
- コネクターのディスカバリー中に使用するポリシー・プロジェクトとボールトの詳細を指定します。
- ポリシー プロジェクト] フィールドで、コネクタ検出中に作成されるポリシーを格納するために使用されるポリシー プロジェクトを指定します。
あるいは、「新規」をクリックし、新規ポリシー・プロジェクトの名前を指定して、新規ポリシー・プロジェクトを作成することもできます。 次に、「完了」をクリックします。
- コネクタ検出時に使用するデータ保管庫を指定します。 デフォルトでは、コネクタ検出時に使用される資格情報は外部ディレクトリ保管庫に格納されます。 App Connect Enterprise データ保管庫に格納されます。 このデータ保管庫は、統合サーバーの作業ディレクトリに作成され、その特定の統合サーバーだけが使用できます。
資格情報の格納に使用するデータ保管庫を指定するには、以下のトピックのいずれかの「
Using Connector Discovery ウィザード」 セクションの手順を完了します:
- 保管庫キー フィールドに、保管庫に格納されている資格情報へのアクセスに使用される保管庫キーを入力しま す。 ボールト鍵の長さは 8 文字以上でなければなりません。
- オプション: デフォルトでは、指定されたデータ保管庫の場所とデータ保管庫キーは、Toolkit の環境設定として保存され、Connector Discovery を起動したときに値がプリセットされます。 設定を保存しない場合は、ボールト設定に保存 を選択解除します。
- Launch Discovery]をクリックして、 Microsoft Azure Event Hubs コネクタのコネクタ検出ウィザードを開始します。
Connector Discovery ウィンドウが表示されます。 既存の Microsoft Azure Event Hubs 接続(アカウント)が利用可能な場合、それらの接続のリストが表示されます。 既存の接続がない場合、 Microsoft Azure Event Hubs コネクタのステータスは Not connected と表示されます。
- ウィザードで必要なコネクター・プロパティーを設定します。
- Connector Discovery ウィザードでプロパティの指定が完了したら、 Save をクリックします。
ウィザードで設定したプロパティの値は、 IBM App Connect Enterprise Toolkit 内の Microsoft Azure Event Hubs Request ノードに返されます。
- 検出を終了し、プロパティ値を保存したら、ウィンドウの右上隅にある X をクリックして Connector Discovery ウィザードを終了します。
- 「 IBM App Connect Enterprise Toolkit 」の 「 Microsoft Azure 」Event Hubs リクエスト ノードの編集画面に戻る。
コネクタ検出ウィザード(ステップ
6 )で設定されたコネクタ・プロパティが、
Microsoft Azure Event Hubs Request ノードに表示されるようになりました。
Basic タブには、ウィザードで設定した
Action プロパティと
Object プロパティの値が表示されます。 例えば、ウィザードで 選択した場合、ノードの
Basic タブには以下のプロパティが表示されます:
- 処置 -
CREATE
- オブジェクト -
eventHub
処置 プロパティーおよび オブジェクト プロパティーの値は、読み取り専用形式で表示されます。 これらの値を変更するには、「コネクター・ディスカバリーの起動」を再度クリックし、「コネクター・ディスカバリー」ウィザードで新しい値を設定します。 プロパティの横にある 「編集 」をクリックすると、他のプロパティを変更できます。
Schema base name プロパティは、 Microsoft Azure Event Hubs コネクタから送受信されるリクエストおよびレスポンス・メッセージのフォーマットを記述するスキーマ・ファイルのベース名を指定します。 スキーマ・ベース名は、ノードに対してディスカバリを最初に実行したときに自動的に設定され、現在のフロー名とノード名に基づいている。 ディスカバリーを初めて実行する前にこのプロパティを手動で設定した場合、設定した値が使用されます。 発見後にスキーマの名前を変更する場合は、このプロパティを編集して、プロジェクト内で名前を変更したスキーマが使用するスキーマ・ベース名と一致させる必要があります。 ディスカバリー後にこのプロパティを変更した場合は、スキーマ名を一致するように変更するか、ディスカバリーを再度実行する必要がある。
検出中に選択されたアクションに応じて、Connector Discovery ウィザードは要求スキーマと応答スキーマ、または応答スキーマのみを生成します。 リクエストスキーマは、選択されたアクションとオブジェクトがリクエスト メッセージを必要とする場合にのみ生成される。 生成されたリクエストスキーマは、リクエストメッセージの検証に使われる。 アクションが RETRIEVE または DELETE の場合、レスポンス・スキーマのみがコネクタから返される。
生成されたスキーマ・ファイルはプロジェクトに追加され、 マッピング・ ノードが入力データや出力データを変換するために使用することができます。 スキーマの完全なファイル名は、スキーマのベース名( gen/MyMessageFlow.Microsoft_Azure_Event_Hubs_Request など)に、 response.schema.json または request.schema.json のサフィックスを付けたものです。 リクエストスキーマを開く] または[ レスポンススキーマを開く] をクリックしてスキーマを開くことができます。
- Microsoft Azure Event Hubs Request ノードのプロパティ設定が正しいことを確認し、メッセージフローを保存します。
- Microsoft Azure Event Hubs Request ノードの Connection タブで、接続に使用するセキュリティ ID の詳細を含むポリシーを選択します。 この保険には
Microsoft Azure Event Hubs という種類がある。
- オプション: Connection] タブの[ Timeout] プロパティを設定して、ノードが Microsoft Azure イベントハブが操作を処理するまでの待機時間(秒)を指定します。
- Microsoft Azure Event Hubs Request ノードの Filter タブには、メッセージフローがデータを選択する方法を制御するプロパティが含まれています。 これらのプロパティの初期値は、コネクタ検出ウィザード(ステップ 6 で説明)で Microsoft Azure Event Hubs コネクタに設定されたプロパティ値から取得されます。 その後 Connector Discovery ウィザードに戻ってプロパティの値を変更すると(たとえば、新しい条件を追加することによって)、その更新はノードに設定されたプロパティに反映されます。
Filter Options プロパティは、 Microsoft Azure Event Hubs Request ノードが実行されるときに操作されるオブジェクトを制御します。 Filter Limit プロパティは、取得するアイテムの最大数と、制限を超えた場合に実行されるアクションを制御します。
これらのプロパティの値を変更するには、ノードの 「フィルタ」 タブで、 「フィルタ・オプション」 セクションで変更したい値の横にある 「編集 」をクリックし、 「フィルタ制限」 セクションで設定されているプロパティ値を変更します。
プロパティ値は、実行時に Microsoft Azure Event Hubs Request ノードに渡されるメッセージの内容から解決されるテキスト値、または ESQL または XPATH 式のいずれかになります。
- Request タブで、 Data location プロパティを設定して、 Microsoft Azure Event Hubs に作成されるオブジェクト・データを含む受信メッセージ・ツリーの場所を指定します。 このデータは、 Microsoft Azure Event Hubs Request ノードから Microsoft Azure Event Hubs システムに送信されるリクエストを形成する。
- Result タブで、 Output data location プロパティを設定して、 Microsoft Azure Event Hubs で作成されるレコードのデータを含む出力メッセージツリーの場所を指定します。
- デフォルトでは、リクエスト・メッセージはコネクタ検出時に生成されたリクエスト・スキーマに対して検証されます。 Microsoft Azure Event Hubs Request ノードの Validation プロパティを使用して、リクエストの検証をオフにしたり、検証設定を変更したりできます。
- メッセージフローを保存する。