ConsumeAMQP 2025.5.31.15

バンドル

org.apache.nifi | nifi-amqp-nar

説明

AMQP 0.9.1 プロトコルを使用して、 AMQP Broker から AMQP メッセージを消費します。AMQP Brokerから受信した各メッセージは、'success'リレーションシップの FlowFile として出力します。

タグ

amqp、消費、取得、メッセージ、ウサギ、受信

入力要件

FORBIDDEN

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

AMQP バージョン

AMQP バージョン.現在、 AMQP v0.9.1のみをサポートしています。

ブローカー

<host>:<port> (例:localhost:5672) の形式で、既知の AMQP Broker のカンマ区切りリスト。これがセットされている場合、Host NameとPortは無視されます。同じ AMQP クラスタリングクラスタのホストのみを含めます。

クライアント 証明書 認証 有効

ユーザー名/パスワードではなく、 SSL 証明書を使用して認証します。

ホスト名

AMQP ブローカーのネットワークアドレス (例: localhost)。Brokers がセットされている場合、このプロパティは無視されます。

受信メッセージ本文の最大サイズ

インバウンド(受信)メッセージの最大本文サイズ。

パスワード

認証および承認に使用されるパスワード。

ポート

AMQP ブローカーの Port を識別子とする数値(例:5671)。Brokers がセットされている場合、このプロパティは無視されます。

キュー

メッセージを消費する既存の AMQP キューの名前。通常、 AMQP 管理者によって事前に定義されています。

SSL コンテキストサービス

TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。

ユーザー名

認証および承認 に使用されるユーザー名。

仮想ホスト

セキュリティ強化のために AMQP システムを分離する仮想ホスト名。

自動.認識

False (Non-Auto-Acknowledge) の場合、 FlowFiles を成功に転送し、 NiFi セッションをコミットした後、プロセッサーによってメッセージが確認されます。非自動確認モードは、「一度だけ」の配信セマンティクスを提供します。もしtrue(Auto-Acknowledge)なら、 AMQP クライアントに配信されたメッセージは、 AMQP ブローカーによって送信直後に自動承認されます。これは一般的にスループットを向上させますが、 AMQP Broker、 NiFi またはプロセッサーの再起動/クラッシュ時にメッセージが失われることになります。自動確認モードは「at-most-once」配送セマンティクスを提供するため、メッセージの紛失が許容される場合にのみ推奨されます。

バッチ.サイズ

1回のセッションで処理すべきメッセージの最大数。これだけのメッセージを受信したら(あるいは、これ以上メッセージを受信できなくなったら)、受信したメッセージは「成功」関係に転送され、 AMQP Broker にメッセージが確認されます。この値を大きくセットすると、特に小容量のメッセージのパフォーマンスが向上する 可能性がありますが、 NiFi を突然再起動したときに、より多くのメッセージが重複してしまう可能性もあります。

ヘッダー.形式

受信したメッセージからヘッダを出力する方法を定義します。

ヘッダー.キー.プレフィックス

FlowFile 属性に追加されるヘッダーキーのプレフィックスとなるテキスト。プロセッサーは、このプロパティの値に「.」を追加します

ヘッダー.セパレーター

文字列のヘッダのキーと値を区切る文字。値は1文字のみです。

プリフェッチ.カウント

コンシューマーの未承認メッセージの最大数。コンシューマーにこの数の未承認メッセージがある場合、 AMQP ブローカーは、コンシューマーがすでに配信されたメッセージのいくつかを承認するまで、新しいメッセージを送信しなくなります。許容値:0 から 65535。0は制限なしを意味します。

remove.curly.braces

もしtrueなら、Remove Curly Braces(中括弧を取り除く)、ヘッダーの中括弧は自動的に取り除かれます。

リレーションシップ

名前

説明

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 メッセージを受信した取引所