文档文档

发布事件处理器

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

选项

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

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

示例:handler 文件

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

使用发布事件处理器

以下设置向 cpu 主题发送警报,消息为“Hey, check your 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

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

publish_cpu_alerts_handler.yaml

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

添加 handler

kapacitor define-topic-handler publish_cpu_alerts_handler.yaml

此页面是否对您有帮助?

感谢您的反馈!


Flux 的未来

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

阅读更多

InfluxDB 3 开源版本现已公开发布 Alpha 版

InfluxDB 3 开源版本现已可用于 alpha 测试,根据 MIT 或 Apache 2 许可授权。

我们正在发布两个产品作为 alpha 版本的一部分。

InfluxDB 3 Core 是我们新的开源产品。它是用于时间序列和事件数据的最新数据引擎。InfluxDB 3 Enterprise 是一个商业版本,它建立在 Core 的基础上,增加了历史查询功能、读取副本、高可用性、可扩展性和细粒度的安全性。

有关如何开始使用的更多信息,请查看