文档文档

发布事件处理器

发布事件处理器将事件发布到另一个主题。

选项

以下发布事件处理器选项可以在处理器文件中设置。

名称类型描述
topics字符串列表要发布事件的主题名称列表。

示例:处理器文件

id: handler-id
topic: topic-name
kind: publish
options:
  topics:
    - system
    - ops_team

使用发布事件处理器

以下设置将警报发送到 cpu 主题,消息为“嘿,检查你的 CPU”。添加了一个发布处理器,它订阅 cpu 主题并将新警报发布到其他主题。

创建一个将警报消息发布到主题的 TICKscript。下面的 TICKscript 在空闲 CPU 使用率降至 10% 以下时,向 cpu 主题发送警报消息。

cpu_alert.tick

stream
  |from()
    .measurement('cpu')
  |alert()
    .crit(lambda: "usage_idle" < 10)
    .message('Hey, check your CPU')
    .topic('cpu')

添加并启用 TICKscript

kapacitor define cpu_alert -tick cpu_alert.tick
kapacitor enable cpu_alert

创建一个处理器文件,该文件订阅 cpu 主题并使用发布事件处理器将警报发布到其他主题。

publish_cpu_alerts_handler.yaml

id: publish-cpu-alert
topic: cpu
kind: publish
options:
  topics:
    - system
    - ops_team

添加处理器

kapacitor define-topic-handler publish_cpu_alerts_handler.yaml

此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

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

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

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

有关更多信息,请查看