2 流式传输到外部系统

概述

Zabbix 可以通过 HTTP 将监控项值和事件流式传输到外部系统（详见 协议详情）。

标签过滤器可用于流式传输监控项值或事件的子集。

Zabbix 有两个服务器进程负责数据流式传输：连接器管理器和连接器工作进程。Zabbix 的内部监控项 zabbix[connector_queue] 允许监控连接器队列中排队的值的数量。

配置

配置 Zabbix 向外部系统进行数据流式传输的步骤如下：

1. 准备一个远程系统，用于接收来自 Zabbix 的数据。 可以使用以下工具之一：

• 简单的示例 接收器，将接收的信息记录在 events.ndjson 和 history.ndjson 文件中。
• Zabbix 服务器的 Kafka 连接器 - 一个轻量级的服务器，用 Go 编写，设计用于将 Zabbix 的监控项值和事件转发到 Kafka Broker。

2. 通过调整 zabbix_server.conf 中的 StartConnectors 参数来设置 Zabbix 中所需的连接器工作进程数量。 连接器工作进程的数量应与在 Zabbix 前端配置的连接器数量匹配（或超过，如果并发会话超过 1）。 然后重新启动 Zabbix 服务器。

3. 在 Zabbix 前端 (Administration → General → Connectors) 配置一个新的连接器，并使用 zabbix_server -R config_cache_reload 命令重新加载服务器缓存。

所有必填字段都用红色星号标记。

协议

服务器与接收器之间的通信通过使用 REST API 和 NDJSON（Newline-delimited JSON）格式的 HTTP 完成，内容类型为 “Content-Type: application/x-ndjson”。

有关更多详细信息，请参阅 Newline-delimited JSON 导出协议。

服务器请求

流式传输监控项值的示例：

POST /v1/history HTTP/1.1
       Host: localhost:8080
       Accept: */*
       Accept-Encoding: deflate, gzip, br, zstd
       Content-Length: 628
       Content-Type: application/x-ndjson
       {"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"foo","value":"test"}],"itemid":44457,"name":"foo","clock":1673454303,"ns":800155804,"value":0,"type":3}
       {"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"foo","value":"test"}],"itemid":44457,"name":"foo","clock":1673454303,"ns":832290669,"value":1,"type":3}
       {"host":{"host":"Zabbix server","name":"Zabbix server"},"groups":["Zabbix servers"],"item_tags":[{"tag":"bar","value":"test"}],"itemid":44458,"name":"bar","clock":1673454303,"ns":867770366,"value":123,"type":3}

流式传输事件的示例：

POST /v1/events HTTP/1.1
       Host: localhost:8080
       Accept: */*
       Accept-Encoding: deflate, gzip, br, zstd
       Content-Length: 333
       Content-Type: application/x-ndjson
       {"clock":1673454303,"ns":800155804,"value":1,"eventid":5,"name":"trigger for foo being 0","severity":0,"hosts":[{"host":"Zabbix server","name":"Zabbix server"}],"groups":["Zabbix servers"],"tags":[{"tag":"foo_trig","value":"test"},{"tag":"foo","value":"test"}]}
       {"clock":1673454303,"ns":832290669,"value":0,"eventid":6,"p_eventid":5}

接收器响应

响应包括HTTP响应状态码和JSON有效负载。成功处理的请求的HTTP响应状态码必须为 “200”、”201”、”202”、”203” 或 “204”，而失败的请求则使用其他状态码。

成功示例：

HTTP/1.1 200 OK
       Date: Wed, 11 Jan 2023 16:40:30 GMT
       Content-Length: 0

带有错误的示例：

HTTP/1.1 422 Unprocessable Entity
       Content-Type: application/json
       Date: Wed, 11 Jan 2023 17:07:36 GMT
       Content-Length: 55
       {"error":"invalid character '{' after top-level value"}