ConsumeMQTT 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-mqtt-nar
説明¶
トピックにサブスクライブし、 MQTT ブローカーからメッセージを受信します。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
---|---|
ブローカー URI |
MQTT ブローカーへの接続に使用する URI (複数可) (例: tcp://localhost:1883)。「tcp」、「ssl」、「ws」、「wss」スキームがサポートされています。'ssl' を使用するには、 SSL Context Service プロパティをセットする必要があります。カンマ区切りの URI リスト (例えば、tcp://localhost:1883,tcp://localhost:1884) がセットされている場合、プロセッサーは接続失敗時にラウンドロビンアルゴリズムを使用してブローカーに接続します。 |
クライアント ID |
使用する MQTT クライアント ID。セットされていない場合は、 UUID が作成されます。 |
接続タイムアウト(秒) |
MQTT サーバーへのネットワーク接続が確立されるまで、クライアントが待機する最大時間間隔。デフォルトのタイムアウトは30秒です。値0はタイムアウト処理を無効にし、クライアントはネットワーク接続が成功するか失敗するまで待ちます。 |
グループ ID |
使用する MQTT コンシューマーグループ ID。グループ ID がセットされていない場合、クライアントは個人コンシューマーとして接続します。 |
Keep Alive Interval (秒) |
メッセージの送受信間の最大時間間隔を定義します。これにより、 TCP/IP のタイムアウトを待つことなく、クライアントがサーバーが利用できなくなったことを検知できるようになります。クライアントはキープアライブ期間内に少なくとも1つのメッセージがネットワークを通過するようにします。その期間中にデータ関連のメッセージがない場合、クライアントは非常に小容量の「Ping」メッセージを送信し、サーバーはそれを確認します。値0はクライアントのキープアライブ処理を無効にします。 |
Last Will Message |
クライアントの遺言として送るメッセージ。 |
Last Will QoS Level |
QoS 遺言メッセージを公開する際に使用するレベル。 |
Last Will Retain |
クライアントのLast Willを保管するかどうか。 |
Last Will Topic |
クライアントのLast Willを送るトピック。 |
MQTT 仕様バージョン |
ブローカーと接続する際の MQTT 仕様バージョン。詳細については、許容値の説明を参照してください。 |
最大列サイズ |
MQTT メッセージは、プロセッサの実行スケジュール頻度に関係なく、常にトピックの購読者に送信されます。「実行スケジュール」が、このプロセッサーに到着するメッセージのレートに比べて大幅に遅れている場合、このプロセッサーの内部キューにバックアップが発生する可能性があります。このプロパティは、このプロセッサが内部キューで一度にメモリに保持するメッセージの最大数を指定します。このデータは、 NiFi を再起動すると失われます。 |
パスワード |
ブローカーへの接続時に使用するパスワード |
サービス品質 (QoS) |
メッセージを受信する Quality of Service (QoS)。値 '0'、'1'、'2' を受け付けます。'0' は「多くても1回」、'1' は「少なくとも1回」、'2' は「ちょうど1回」を表します。 |
SSL コンテキストサービス |
TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。 |
セッション有効期限間隔 |
この間隔が過ぎると、ブローカーはクライアントを失効させ、セッション状態をクリアします。 |
セッション状態 |
新しく始めるか、以前のフローを再開するか。詳細については、許容値の説明を参照してください。 |
トピックフィルター |
MQTT トピックフィルターで、購読するトピックを指定します。 |
ユーザー名 |
ブローカーへの接続時に使用するユーザー名 |
add-attributes-as-fields |
このプロパティをtrueにセットすると、各記録にデフォルト・フィールドが追加されます:topic、_qos、_isDuplicate、_isRetained。 |
message-demarcator |
このプロパティで、複数のメッセージを含む FlowFiles を出力するオプションがあります。このプロパティでは、複数のメッセージを区切るための文字列 (UTF-8 と解釈されます) を指定することができます。これはオプションのプロパティです。プロバイダーが提供されていない場合、またRecord Reader/ライターを定義していない場合、受信した各メッセージは1つの FlowFile になります。「改行」などの特殊文字を入力するには、 OS に応じて CTRL+Enter または Shift+Enter を使用します。 |
record-reader |
受信した MQTT メッセージを記録にパースするために使用するRecord Reader。 |
record-writer |
FlowFile に書き込む前に記録をシリアライズするために使用する Record Writer。 |
リレーションシップ¶
名前 |
説明 |
---|---|
メッセージ |
MQTT メッセージ出力 |
parse.failure |
構成されたRecord Readerを使用してメッセージを解析できない場合、メッセージの内容はこのリレーションシップに個別の FlowFile としてルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
---|---|
record.count |
受信した記録数 |
mqtt.broker |
MQTT メッセージ発信元のブローカー |
mqtt.topic |
MQTT メッセージを受信したトピック |
mqtt.qos |
このメッセージのサービス品質。 |
mqtt.isDuplicate |
このメッセージがすでに受信したものと重複しているかどうか。 |
mqtt.isRetained |
このメッセージが現在のパブリッシャーからのものであるかどうか、あるいは、そのトピックで公開された最後のメッセージとしてサーバーに "保持 "されているかどうか。 |