文档文档

TCP 事件处理器

TCP 事件处理器将 JSON 编码的警报数据发送到 TCP 端点。

选项

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

名称类型描述
addressstringTCP 端点的地址。

示例:处理程序文件

id: handler-id
topic: topic-name
kind: tcp
options:
  address: 127.0.0.1:7777

示例:TICKscript

|alert()
  // ...
  .tcp('127.0.0.1:7777')

使用 TCP 事件处理器

TCP 事件处理器可以在 TICKscript 和处理程序文件中使用,以将警报数据发送到 TCP 端点。

从 TICKscript 发送警报数据到 TCP 端点

以下 TICKscript 使用 .tcp() 事件处理器,在空闲 CPU 使用率降至 10% 以下时发送警报数据。

tcp-cpu-alert.tick

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

从定义的处理程序发送警报数据到 TCP 端点

以下设置向 cpu 主题发送警报,消息为 “Hey, check your CPU”。添加了一个 TCP 处理程序,该处理程序订阅 cpu 主题并将所有警报消息发送到 TCP 端点。

创建一个 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 主题并使用 TCP 事件处理器将警报数据发送到 TCP 端点。

tcp_cpu_handler.yaml

id: tcp-cpu-alert
topic: cpu
kind: tcp
options:
  address: 127.0.0.1:7777

添加处理程序

kapacitor define-topic-handler tcp_cpu_handler.yaml

此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

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

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

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

有关更多信息,请查看