ConsumeMQTT 2025.5.31.15

バンドル

org.apache.nifi | nifi-mqtt-nar

説明

トピックにサブスクライブし、 MQTT ブローカーからメッセージを受信します。

タグ

IOT, 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

このメッセージが現在のパブリッシャーからのものであるかどうか、あるいは、そのトピックで公開された最後のメッセージとしてサーバーに "保持 "されているかどうか。

こちらもご覧ください