PublishMQTT 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-mqtt-nar
描述¶
向 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 会禁用超时处理，这表示客户端会一直等到网络连接成功或失败。 |
保持活动间隔（秒） |
定义消息发送或接收之间的最大时间间隔。这让客户端能检测服务器是否不再可用，而不必等待 TCP/IP 超时。在每个保持活动状态的时间段内，客户端将确保至少有一条消息通过网络传输。如果在这段时间内没有与数据相关的消息，客户端会发送一条非常小的“ping”消息，服务器将确认该消息。如果值为 0，客户端中的保持活动状态处理将会被禁用。 |
遗愿消息 |
作为客户端遗愿发送的消息。 |
遗愿 QoS 级别 |
发布遗愿消息时使用的 QoS 级别。 |
遗愿保留 |
是否保留客户端的遗愿 |
遗愿主题 |
要将客户端遗愿发送到的主题。 |
MQTT 规范版本 |
与代理连接时的 MQTT 规范版本。有关更多详细信息，请参阅允许的值的说明。 |
密码 |
连接代理时使用的密码 |
服务质量 (QoS) |
发送消息时使用的服务质量 (QoS)。接受“0”、“1”和“2”这三个值；“0”表示“最多一次”，“1”表示“至少一次”，“2”表示“仅一次”。允许使用表达式语言来支持发布具有不同 QoS 的消息，但该属性的最终值必须为“0”、“1”或“2”。 |
保留消息 |
是否应在 MQTT 消息上设置保留标志。 |
SSL Context Service |
用于为 TLS/SSL 连接提供客户端证书信息的 SSL Context Service。 |
会话过期间隔 |
在此间隔之后，代理会将客户端设为过期并清除会话状态。 |
会话状态 |
开始全新的流，还是恢复之前的流。有关更多详细信息，请参阅允许的值的说明。 |
主题 |
要向其发布消息的主题。 |
用户名 |
连接代理时使用的用户名 |
message-demarcator |
使用此属性，您可以选择从一个 FlowFile 中发布多条消息。此属性允许您提供一个字符串（解析为 UTF-8），用于划分 FlowFile 内容。这是一个可选属性；如果未提供，并且未定义记录读取器/写入器，则每个 FlowFile 都将作为一条消息发布。要输入特殊字符，例如“换行”，请根据 OS 使用 CTRL+Enter 或 Shift+Enter。 |
record-reader |
记录读取器，用于将传入 FlowFile 解析为记录。 |
record-writer |
记录写入器，用于将记录作为 MQTT 消息发布之前对其进行序列化。 |
关系¶
名称 |
描述 |
|---|---|
failure |
未能发送到目标的 FlowFiles 将转移到此关系。 |
success |
成功发送到目标的 FlowFiles 将转移到此关系。 |