GetAzureEventHub 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-azure-nar
説明¶
信頼性の高いチェックポイント追跡なしでMicrosoft Azureイベントハブからのメッセージを受信します。クラスタ環境では、 GetAzureEventHub プロセッサー インスタンスは独立して動作し、すべてのクラスタノードがすべてのメッセージを処理します（プロセッサーをプライマリのみモードで実行している場合を除く）。ConsumeAzureEventHub は、Azure Event Hubs からのメッセージを受信するための推奨アプローチを提供します。このプロセッサーは、Azure イベントハブへの接続用のスレッドプールを作成します。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
イベントハブ コンシューマーグループ |
イベントをプルする際に使用するコンシューマーグループの名前。 |
イベントハブメッセージのエンキュー時間 |
YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) という形式でフォーマットされた、以下から読み込みを開始するイベントハブにエンキューされているべきメッセージからのタイムスタンプ (ISO-8601 Instant) です。 |
イベントハブ名 |
Azure イベントハブのソース名 |
イベントハブ名前空間 |
サービス バス エンドポイント ドメインのプレフィックスが付いた Azure イベントハブの名前空間 |
パーティション・レシーバー・タイムアウト (ミリ秒) |
パーティション・レシーバーがフェッチ・サイズを受信してから戻るまでの時間（ミリ秒単位）。デフォルトは60000です。 |
パーティション・レシーバーのフェッチ・サイズ |
レシーバーがリターンする前にイベント・ハブ・パーティションからフェッチすべきイベントの数。デフォルトは100です。 |
サービス バス エンドポイント |
デフォルトのwindows.netドメイン以外の名前空間をサポートするため。 |
共有アクセスポリシー名 |
共有アクセスポリシーの名前。このポリシーは、保険金請求に耳を傾ける必要があります。 |
共有アクセスポリシー プライマリキー |
共有アクセスポリシーのキー。プライマリ・キーとセカンダリ・キーのどちらを使ってもかまいません。 |
輸送タイプ |
Azureイベントハブとの通信に使用される高度なメッセージキューイングプロトコルのトランスポートタイプ |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
use-managed-identity |
Azure VM/VMSS の管理 ID を使用するかどうかを選択します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
success |
イベントハブから正常に受信された FlowFile は、この Relationship に転送されます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
eventhub.enqueued.timestamp |
メッセージがイベントハブにエンキューされた時間(エポックからのミリ秒、 UTC)。 |
eventhub.offset |
メッセージが格納されたパーティション内のオフセット |
eventhub.sequence |
メッセージに関連するAzureシーケンス番号 |
eventhub.name |
メッセージが取り出されたイベントハブの名前。 |
eventhub.partition |
メッセージが取り出されたイベントハブ・パーティションの名前。 |
eventhub.property.* |
このメッセージのアプリケーション・プロパティ。IE: 'アプリケーション'は'eventhub.property.application'となります。 |