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のみをサポートしています。 |
Auto-Acknowledge Messages |
False (Non-Auto-Acknowledge) の場合、 FlowFiles を成功に転送し、 NiFi セッションをコミットした後、プロセッサーによってメッセージが確認されます。非自動確認モードは、「一度だけ」の配信セマンティクスを提供します。もしtrue(Auto-Acknowledge)なら、 AMQP クライアントに配信されたメッセージは、 AMQP ブローカーによって送信直後に自動承認されます。これは一般的にスループットを向上させますが、 AMQP Broker、 NiFi またはプロセッサーの再起動/クラッシュ時にメッセージが失われることになります。自動確認モードは「at-most-once」配送セマンティクスを提供するため、メッセージの紛失が許容される場合にのみ推奨されます。 |
Batch Size |
1回のセッションで処理すべきメッセージの最大数。これだけのメッセージを受信したら（あるいは、これ以上メッセージを受信できなくなったら）、受信したメッセージは「成功」関係に転送され、 AMQP Broker にメッセージが確認されます。この値を大きくセットすると、特に小容量のメッセージのパフォーマンスが向上する 可能性がありますが、 NiFi を突然再起動したときに、より多くのメッセージが重複してしまう可能性もあります。 |
ブローカー |
<host>:<port> (例：localhost:5672) の形式で、既知の AMQP Broker のカンマ区切りリスト。これがセットされている場合、Host NameとPortは無視されます。同じ AMQP クラスタリングクラスタのホストのみを含めます。 |
クライアント 証明書 認証 有効 |
ユーザー名/パスワードではなく、 SSL 証明書を使用して認証します。 |
Header Key Prefix |
FlowFile 属性に追加されるヘッダーキーのプレフィックスとなるテキスト。プロセッサーは、このプロパティの値に「.」を追加します |
Header Output Format |
受信したメッセージからヘッダを出力する方法を定義します。 |
Header Separator |
文字列のヘッダのキーと値を区切る文字。値は1文字のみです。 |
ホスト名 |
AMQP ブローカーのネットワークアドレス (例: localhost)。Brokers がセットされている場合、このプロパティは無視されます。 |
受信メッセージ本文の最大サイズ |
インバウンド（受信）メッセージの最大本文サイズ。 |
パスワード |
認証および承認に使用されるパスワード。 |
ポート |
AMQP ブローカーの Port を識別子とする数値（例：5671）。Brokers がセットされている場合、このプロパティは無視されます。 |
Prefetch Count |
The maximum number of unacknowledged messages for the consumer. If consumer has this number of unacknowledged messages, AMQP broker will no longer send new messages until consumer acknowledges some of the messages already delivered to it. Allowed values: from 0 to 65535.0 means no limit |
キュー |
メッセージを消費する既存の AMQP キューの名前。通常、 AMQP 管理者によって事前に定義されています。 |
Remove Curly Braces |
もし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 メッセージを受信した取引所 |