2. Потоковая передача во внешние системы

Обзор

Возможна потоковая передача значений элементов данных и событий из Zabbix во внешние системы по HTTP (смотрите подробности протокола).

Для потоковой передачи подмножеств значений элементов данных или событий можно использовать фильтр тегов.

За потоковую передачу данных отвечают два процесса сервера Zabbix: менеджер коннекторов (connector manager) и рабочий процесс коннектора (connector worker). Внутренний элемент данных Zabbix zabbix[connector_queue] позволяет отслеживать количество значений, поставленных в очередь коннектора.

Настройка

Для настройки потоковой передачи данных во внешнюю систему необходимы следующие шаги:

1. Наличие удалённой системы, настроенной на получение данных из Zabbix. Для этой цели доступны следующие инструменты:

• Пример простого получателя [en], который записывает принимаемую информацию в файлы events.ndjson и history.ndjson.
• Kafka connector for Zabbix server [en] — написанный на Go легковесный сервер, предназначенный для пересылки значений элементов данных и событий от сервера Zabbix брокеру Kafka.

2. Настройте нужное количество рабочих процессов коннектора в Zabbix путём регулирования параметра StartConnectors в zabbix_server.conf. Количество рабочих процессов коннектора должно соответствовать (или превышать, если одновременных сессий больше одной) настроенному в веб-интерфейсе Zabbix числу сконфигурированных коннекторов. После этого перезапустите Zabbix сервер.

3. Сконфигурируйте новый коннектор в веб-интерфейсе Zabbix (Администрирование → Общие → Коннекторы (Administration → General → Connectors)) и перезагрузите кэш сервера с помощью команды zabbix_server -R config_cache_reload.

Обязательные поля отмечены звёздочкой.

Протокол

Обмен данными между сервером и получателем осуществляется по HTTP с использованием REST API, NDJSON, "Content-Type: application/x-ndjson".

Более подробную информацию смотрите в Протоколе экспорта 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» для запросов, которые были обработаны успешно, и другим для невыполненных запросов.

Пример успешного приёма:

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

Пример с ошибками:

localhost:8080/v1/history": 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"}