PublishMQTT 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-mqtt-nar

説明¶

MQTT トピックにメッセージを公開します。

タグ¶

IOT, MQTT, 公開

入力要件¶

REQUIRED

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

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はタイムアウト処理を無効にし、クライアントはネットワーク接続が成功するか失敗するまで待ちます。
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 仕様バージョン。詳細については、許容値の説明を参照してください。
パスワード	ブローカーへの接続時に使用するパスワード
サービス品質 (QoS)	メッセージを送信するサービス品質 (QoS)。0'は「多くても1回」、'1'は「少なくとも1回」、'2'は「ちょうど1回」を表します。異なる QoS を持つメッセージの発行に対応するために式言語が許可されていますが、プロパティの終了値は '0'、'1'、または '2' のいずれかでなければなりません。
メッセージを保持	MQTT メッセージに retain フラグをセットするかどうか。
SSL コンテキストサービス	TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。
セッション有効期限間隔	この間隔が過ぎると、ブローカーはクライアントを失効させ、セッション状態をクリアします。
セッション状態	新しく始めるか、以前のフローを再開するか。詳細については、許容値の説明を参照してください。
トピック	メッセージを公開するトピック。
ユーザー名	ブローカーへの接続時に使用するユーザー名
message-demarcator	このプロパティを使用すると、1つの FlowFile から複数のメッセージを発行するオプションがあります。このプロパティでは、 FlowFile の内容を区切るための文字列 (UTF-8として解釈されます)を指定することができます。これはオプションのプロパティです。プロバイダーが提供されず、Record Reader/Writer が定義されていない場合、各 FlowFile は単一のメッセージとして発行されます。「改行」などの特殊文字を入力するには、 OS に応じて CTRL+Enter または Shift+Enter を使用します。
record-reader	入力された FlowFile を記録にパースするために使用するRecord Reader。
record-writer	MQTT メッセージとして発行する前に記録をシリアライズするために使用する Record Writer。

リレーションシップ¶

名前	説明
failure	宛先への送信に失敗した FlowFiles は、このリレーションシップに転送されます。
success	宛先に正常に送信された FlowFiles は、このリレーションシップに転送されます。

こちらもご覧ください¶

org.apache.nifi.processors.mqtt.ConsumeMQTT