ConsumeAMQP 2025.10.2.19¶
バンドル¶
org.apache.nifi | nifi-amqp-nar
説明¶
AMQP 0.9.1 プロトコルを使用して、 AMQP Broker から AMQP メッセージを消費します。AMQP Brokerから受信した各メッセージは、'success'リレーションシップの FlowFile として出力します。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
AMQP バージョン |
AMQP バージョン.現在、 AMQP v0.9.1のみをサポートしています。 |
自動確認メッセージ |
False (Non-Auto-Acknowledge) の場合、 FlowFiles を成功に転送し、 NiFi セッションをコミットした後、プロセッサーによってメッセージが確認されます。非自動確認モードは、「一度だけ」の配信セマンティクスを提供します。もしtrue(Auto-Acknowledge)なら、 AMQP クライアントに配信されたメッセージは、 AMQP ブローカーによって送信直後に自動承認されます。これは一般的にスループットを向上させますが、 AMQP Broker、 NiFi またはプロセッサーの再起動/クラッシュ時にメッセージが失われることになります。自動確認モードは「at-most-once」配送セマンティクスを提供するため、メッセージの紛失が許容される場合にのみ推奨されます。 |
バッチサイズ |
1回のセッションで処理すべきメッセージの最大数。これだけのメッセージを受信したら（あるいは、これ以上メッセージを受信できなくなったら）、受信したメッセージは「成功」関係に転送され、 AMQP Broker にメッセージが確認されます。この値を大きくセットすると、特に小容量のメッセージのパフォーマンスが向上する 可能性がありますが、 NiFi を突然再起動したときに、より多くのメッセージが重複してしまう可能性もあります。 |
ブローカー |
<host>:<port> (例：localhost:5672) の形式で、既知の AMQP Broker のカンマ区切りリスト。これがセットされている場合、Host NameとPortは無視されます。同じ AMQP クラスタリングクラスタのホストのみを含めます。 |
クライアント 証明書 認証 有効 |
ユーザー名/パスワードではなく、 SSL 証明書を使用して認証します。 |
ヘッダーキーのプレフィックス |
FlowFile 属性に追加されるヘッダーキーのプレフィックスとなるテキスト。プロセッサーは、このプロパティの値に「.」を追加します |
ヘッダー出力形式 |
受信したメッセージからヘッダを出力する方法を定義します。 |
ヘッダーセパレーター |
文字列のヘッダのキーと値を区切る文字。値は1文字のみです。 |
ホスト名 |
AMQP ブローカーのネットワークアドレス (例: localhost)。Brokers がセットされている場合、このプロパティは無視されます。 |
受信メッセージ本文の最大サイズ |
インバウンド（受信）メッセージの最大本文サイズ。 |
パスワード |
認証および承認に使用されるパスワード。 |
ポート |
AMQP ブローカーの Port を識別子とする数値（例：5671）。Brokers がセットされている場合、このプロパティは無視されます。 |
プリフェッチカウント |
コンシューマーの未確認メッセージの最大数。コンシューマーにこの数の未確認メッセージがある場合、 AMQP ブローカーは、コンシューマーがすでに配信されたメッセージのいくつかを確認するまで、新しいメッセージを送信しなくなります。許可された値: 0から65535。0は無制限を意味します |
キュー |
メッセージを消費する既存の AMQP キューの名前。通常、 AMQP 管理者によって事前に定義されています。 |
中括弧を取り除く |
もしtrueなら、Remove Curly Braces（中括弧を取り除く）、ヘッダーの中括弧は自動的に取り除かれます。 |
SSL コンテキストサービス |
TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。 |
ユーザー名 |
認証および承認 に使用されるユーザー名。 |
仮想ホスト |
セキュリティ強化のために AMQP システムを分離する仮想ホスト名。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
success |
AMQP キューから受け取ったすべての FlowFiles は、このリレーションにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
amqp$appId |
AMQP メッセージの App ID フィールド |
amqp$contentEncoding |
AMQP メッセージが報告するコンテンツ・エンコーディング |
amqp$contentType |
AMQP メッセージが報告する Content Type。 |
amqp$headers |
AMQP メッセージのヘッダー。プロセッサーがこの属性を出力するように構成されている場合にのみ追加。 |
<ヘッダーキープレフィックス>.<属性> |
ヘッダーを属性として出力するようにプロセッサーが構成されている場合、 各メッセージヘッダーはこの属性名で挿入されます。 |
amqp$deliveryMode |
メッセージの配送モードの数値インジケータ。 |
amqp$priority |
メッセージの優先順位 |
amqp$correlationId |
メッセージの相関図 ID |
amqp$replyTo |
メッセージの Reply-To フィールドの値。 |
amqp$expiration |
メッセージの有効期限 |
amqp$messageId |
メッセージの一義の ID |
タイムスタンプ |
エポックからのミリ秒の数としての、メッセージのタイムスタンプ。 |
amqp$type |
メッセージのタイプ |
amqp$userId |
ユーザーの ID |
amqp$clusterId |
AMQP クラスタの ID |
amqp$routingKey |
AMQP メッセージのルーティングKey |
amqp$exchange |
AMQP メッセージを受信した取引所 |