mqtt.to() 函数
mqtt.to() 是实验性的，并且随时可能更改。
仅在 InfluxDB Cloud (TSM) 中受支持
experimental/mqtt 包仅在 InfluxDB Cloud (TSM) 中受支持。它仍然可以在 InfluxDB OSS 和 Enterprise 中导入，但函数将无法成功发布到 MQTT broker。 exclude_from: nightly: true oss: ^* enterprise: ^*
mqtt.to() 使用 MQTT 协议将表流中的数据输出到 MQTT broker。
函数类型签名
(
<-tables: stream[A],
broker: string,
?clientid: string,
?name: string,
?password: string,
?qos: int,
?retain: bool,
?tagColumns: [string],
?timeColumn: string,
?timeout: duration,
?topic: string,
?username: string,
?valueColumns: [string],
) => stream[B] where A: Record, B: Record
有关更多信息，请参阅函数类型签名。
参数
broker
(必需) MQTT broker 连接字符串。
topic
要将数据发送到的 MQTT 主题。
qos
MQTT 服务质量 (QoS) 级别。值范围为 [0-2]。默认为 0。
retain
MQTT retain 标志。默认为 false。
clientid
MQTT 客户端 ID。
username
发送到 MQTT broker 的用户名。
仅当 broker 需要身份验证时才需要用户名。如果您提供用户名，则必须提供密码。
password
发送到 MQTT broker 的密码。仅当 broker 需要身份验证时才需要密码。如果您提供密码，则必须提供用户名。
name
MQTT 消息的名称。
timeout
MQTT 连接超时。默认为 1s。
timeColumn
在输出行协议中用作时间值的列。默认为 "_time"。
tagColumns
在输出行协议中用作标签集的列。默认为 []。
valueColumns
在输出行协议中用作字段值的列。默认为 ["_value"]。
tables
输入数据。默认为管道转发数据 (<-)。
示例
发送数据到 MQTT broker
import "experimental/mqtt"
import "sampledata"
sampledata.float()
|> mqtt.to(
broker: "tcp://localhost:8883",
topic: "example-topic",
clientid: r.id,
tagColumns: ["id"],
valueColumns: ["_value"],
)
此页是否对您有帮助？
感谢您的反馈！