文档文档

MQTT 事件处理程序

MQTT 是一种用于小型传感器和移动设备的轻量级消息协议。Kapacitor 可以配置为将告警消息发送到 MQTT 代理。

配置

MQTT 事件处理程序的配置以及默认选项值在您的 kapacitor.conf 中设置。以下是一个配置示例

[[mqtt]]
  enabled = true
  name = "localhost"
  default = true
  url = "tcp://localhost:1883"
  ssl-ca = "/etc/kapacitor/ca.pem"
  ssl-cert = "/etc/kapacitor/cert.pem"
  ssl-key = "/etc/kapacitor/key.pem"
  client-id = "xxxx"
  username = "xxxx"
  password = "xxxx"

可以通过重复 [[mqtt]] 部分来配置多个 MQTT 代理。name 充当每个已配置 MQTT 客户端的唯一标识符。

enabled

设置为 true 以启用 MQTT 事件处理程序。

name

此代理配置的唯一名称。

default

当使用多个 MQTT 配置时,将当前配置设置为默认配置。

url

MQTT 代理的 URL。可能的协议包括

tcp - 原始 TCP 网络连接
ssl - TLS 保护的 TCP 网络连接
ws - Websocket 网络连接

ssl-ca

证书颁发机构 (CA) 文件的绝对路径。可以提供 CA 而无需密钥/证书对。

ssl-cert

pem 编码证书文件的绝对路径。

ssl-key

pem 编码密钥文件的绝对路径。

client-id

此 MQTT 客户端的唯一 ID。如果为空,则使用 name 的值。

username

MQTT 用户名。

password

MQTT 密码。

选项

以下 MQTT 事件处理程序选项可以在处理程序文件中设置,或者在使用 TICKscript 中的 .mqtt() 时设置。

名称类型描述
broker-namestring配置的 MQTT 代理的名称,用于发布告警。如果为空,则默认为配置的默认代理。
topicstring将调度告警的 MQTT 主题
qosint64将用于传递告警的 QoS。有效值包括

0 : 最多一次传递
1 : 至少一次传递
2 : 恰好一次传递
retainedbool指示是否应将此告警传递给在告警发生时未连接到代理的客户端。

示例:处理程序文件

id: handler-id
topic: topic-name
kind: mqtt
options:
  broker-name: 'name'
  topic: 'topic-name'
  qos: 1
  retained: true

示例:TICKscript

|alert()
  // ...
  .mqtt('topic-name')
    .brokerName('name')
    .qos(1)
    .retained(TRUE)

使用 MQTT 事件处理程序

MQTT 事件处理程序可以在 TICKscript 和处理程序文件中使用,以将告警发送到 MQTT 代理。

以下示例使用在 kapacitor.conf 中定义的以下 MQTT 代理配置

kapacitor.conf 中的 MQTT 设置

[[mqtt]]
  enabled = true
  name = "localhost"
  default = true
  url = "tcp://localhost:1883"

[[mqtt]]
  enabled = true
  name = "alerts-broker"
  default = false
  url = "ssl://123.45.67.89:1883"
  ssl-ca = "/etc/kapacitor/ca.pem"
  ssl-cert = "/etc/kapacitor/cert.pem"
  ssl-key = "/etc/kapacitor/key.pem"
  client-id = "alerts-broker"
  username = "myuser"
  password = "mysupersecretpassw0rd"

从 TICKscript 发送告警到 MQTT 代理

以下 TICKscript 使用 .mqtt() 事件处理程序将告警发送到 kapacitor.confi 中定义的默认 MQTT 代理的 alerts MQTT 主题,每当空闲 CPU 使用率降至 10% 以下时。

log-cpu-alert.tick

stream
  |from()
    .measurement('cpu')
  |alert()
    .crit(lambda: "usage_idle" < 10)
    .message('{{ .Time }}: CPU usage over 90%')
    .mqtt('alerts')
      .qos(2)

从定义的处理程序发送告警到 MQTT 代理

以下设置将告警发送到 cpu 主题。添加了一个 MQTT 处理程序,该处理程序订阅 cpu 主题,并在发布新消息时将消息发送到 alerts-brokeralerts MQTT 主题。

创建一个 TICKscript,将告警消息发布到主题。以下 TICKscript 在任何时候空闲 CPU 使用率降至 10% 以下时,都会向 cpu 主题发送告警消息。

cpu_alert.tick

stream
  |from()
    .measurement('cpu')
  |alert()
    .crit(lambda: "usage_idle" < 10)
    .message('{{ .Time }}: CPU usage over 90%')
    .topic('cpu')

添加并启用 TICKscript

kapacitor define cpu_alert -tick cpu_alert.tick
kapacitor enable cpu_alert

创建一个处理程序文件,该文件订阅 cpu 主题,并使用 MQTT 事件处理程序将告警发送到 alerts-broker

log_cpu_handler.yaml

id: log-cpu-alert
topic: cpu
kind: mqtt
options:
  broker-name: 'alerts-broker'
  topic: 'alerts'
  qos: 2
  retained: true

添加处理程序

kapacitor define-topic-handler log_cpu_handler.yaml

此页内容是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。您可以继续像现在一样使用它,而无需对您的代码进行任何更改。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速、最近数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。InfluxDB 3 Enterprise 构建在 Core 的基础上,增加了高可用性、读取副本、增强的安全性以及数据压缩,以实现更快的查询和优化的存储。InfluxDB 3 Enterprise 的免费层可供非商业家庭或业余爱好者使用。

有关更多信息,请查看