2 Strumieniowanie do systemów zewnętrznych

Przegląd

Możliwe jest strumieniowanie wartości pozycji i zdarzeń z Zabbix do zewnętrznych systemów przez HTTP (zobacz szczegóły protokołu).

Filtr tagów może być używany do strumieniowania podzbiorów wartości pozycji lub zdarzeń.

Za strumieniowanie danych odpowiadają dwa procesy serwera Zabbix: connector manager i connector worker. Wewnętrzna pozycja Zabbix zabbix[connector_queue] umożliwia monitorowanie liczby wartości umieszczonych w kolejce connector.

Konfiguracja

Aby skonfigurować strumieniowanie danych do systemu zewnętrznego, wymagane są następujące kroki:

1. Należy przygotować zdalny system do odbierania danych z Zabbix. W tym celu dostępne są następujące narzędzia:

• Przykład prostego odbiornika, który zapisuje odebrane informacje w plikach events.ndjson i history.ndjson.
• Kafka connector for Zabbix server — lekki serwer napisany w Go, przeznaczony do przekazywania wartości pozycji i zdarzeń z serwera Zabbix do brokera Kafka.

2. Ustaw wymaganą liczbę procesów roboczych connectora w Zabbix, dostosowując parametr StartConnectors w pliku zabbix_server.conf. Liczba procesów roboczych connectora powinna odpowiadać (lub być większa, jeśli liczba współbieżnych sesji jest większa niż 1) skonfigurowanej liczbie connectorów w Zabbix frontend. Następnie uruchom ponownie serwer Zabbix.

3. Skonfiguruj nowy connector w Zabbix frontend (Administration > General > Connectors) i przeładuj pamięć podręczną serwera poleceniem zabbix_server -R config_cache_reload.

Pola obowiązkowe są oznaczone gwiazdką.

Gdy connector Kafka jest skonfigurowany z rozdzieloną przecinkami listą adresów brokerów bootstrap (na przykład Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093), klient Kafka łączy się z brokerem (brokerami), który odpowie jako pierwszy, i używa jego metadanych klastra. Jeśli lista zawiera adresy z różnych klastrów Kafka, użyty zostanie tylko klaster odpowiadający najszybciej, a pozostałe adresy zostaną zapisane w logu jako niedostępne; w rezultacie podczas uruchamiania mogą pojawić się ostrzeżenia takie jak poniższe, mimo że connector jest połączony:

kafka cluster connected, but broker(s) "kafka1.example.com:9093, kafka2.example.com:9093" unavailable; will retry on message send if active brokers fail 

W niektórych środowiskach (sieci prywatne, sieci kontenerowe lub niestandardowe konfiguracje DNS/hosts) nazwy hostów lub adresy IP mogą być rozwiązywane do adresów pętli zwrotnej (na przykład 127.0.0.1/localhost) albo normalizowane przez klienta, co może sprawiać, że takie ostrzeżenia będą mylące. Aby ograniczyć nieporozumienia, upewnij się, że wszystkie adresy Kafka.URL należą do tego samego klastra Kafka, zweryfikuj rozwiązywanie DNS z hosta connectora oraz ustawienie advertised.listeners brokerów, a także preferuj adresy, które są rozwiązywane do adresu rozgłaszanego przez brokera.

Protokół

Komunikacja między serwerem a odbiorcą odbywa się przez HTTP z użyciem REST API, NDJSON, „Content-Type: application/x-ndjson”.

Więcej informacji można znaleźć w protokole eksportu JSON rozdzielanego znakami nowej linii.

Żądanie serwera

Przykład strumieniowania wartości pozycji:

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}

Przykład strumieniowania zdarzeń:

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}

Odpowiedź odbiorcy

Odpowiedź składa się z kodu statusu odpowiedzi HTTP oraz ładunku JSON. Kod statusu odpowiedzi HTTP musi mieć wartość „200”, „201”, „202”, „203” lub „204” dla żądań, które zostały obsłużone pomyślnie; inne wartości oznaczają nieudane żądania.

Przykład powodzenia:

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

Przykład z błędami:

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"}