2 Straumēšana uz ārējām sistēmām

Pārskats

Ir iespējams straumēt vienumu vērtības un notikumus no Zabbix uz ārējām sistēmām, izmantojot HTTP (skatiet protokola informāciju).

Birkas filtru var izmantot, lai straumētu vienumu vērtību vai notikumu apakškopas.

Par datu straumēšanu ir atbildīgi divi Zabbix servera procesu tipi: connector manager un connector worker. Zabbix iekšējais vienums zabbix[connector_queue] ļauj uzraudzīt savienotāja rindā ievietoto vērtību skaitu.

Konfigurēšana

Lai konfigurētu datu straumēšanu uz ārēju sistēmu, jāveic tālāk norādītās darbības:

1. Iestatiet attālo sistēmu datu saņemšanai no Zabbix. Šim nolūkam ir pieejami šādi rīki:

• Vienkārša saņēmēja piemērs, kas saņemto informāciju reģistrē failos events.ndjson un history.ndjson.
• Kafka connector for Zabbix server - viegls Go valodā rakstīts serveris, kas paredzēts vienumu vērtību un notikumu pārsūtīšanai no Zabbix servera uz Kafka brokeri.

2. Iestatiet nepieciešamo savienotāju darbu skaitu Zabbix, pielāgojot StartConnectors parametru failā zabbix_server.conf. Savienotāju darbu skaitam jāatbilst Zabbix lietotāja saskarnē konfigurētajam savienotāju skaitam (vai tas jāpārsniedz, ja vienlaicīgo sesiju skaits ir lielāks par 1). Pēc tam restartējiet Zabbix serveri.

3. Konfigurējiet jaunu savienotāju Zabbix lietotāja saskarnē (Administration > General > Connectors) un atkārtoti ielādējiet servera kešatmiņu ar komandu zabbix_server -R config_cache_reload.

Obligātie lauki ir atzīmēti ar zvaigznīti.

Ja Kafka savienotājs ir konfigurēts ar komatiem atdalītu sāknēšanas brokeru adrešu sarakstu (piemēram, Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093), Kafka klients izveido savienojumu ar brokeri(-iem), kas atbild pirmais, un izmanto to klastera metadatus. Ja sarakstā ir adreses no dažādiem Kafka klasteriem, tiks izmantots tikai visātrāk atbildējušais klasteris, bet pārējās adreses tiks reģistrētas kā nepieejamas; tādēļ var tikt parādīti tālāk norādītie brīdinājumi par palaišanu, pat ja savienotājs ir savienots:

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

Dažās vidēs (privātajos tīklos, konteineru tīklos vai nestandarta DNS/hosts konfigurācijās) resursdatoru nosaukumi vai IP adreses var tikt atrisinātas uz cilpas atpakaļadresēm (piemēram, 127.0.0.1/localhost) vai arī klients tās var normalizēt, tādēļ šādi brīdinājumi var būt maldinoši. Lai mazinātu neskaidrības, pārliecinieties, ka visas Kafka.URL adreses pieder vienam un tam pašam Kafka klasterim, pārbaudiet DNS izšķiršanu no savienotāja resursdatora un brokeru advertised.listeners, kā arī dodiet priekšroku adresēm, kas tiek izšķirtas uz brokera reklamēto adresi.

Protokols

Saziņa starp serveri un saņēmēju notiek, izmantojot HTTP un REST API, NDJSON, "Content-Type: application/x-ndjson".

Lai iegūtu sīkāku informāciju, skatiet Ar jaunu rindu atdalīta JSON eksporta protokolu.

Servera pieprasījums

Piemērs vienumu vērtību straumēšanai:

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}

Piemērs notikumu straumēšanai:

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}

Saņēmēja atbilde

Atbilde sastāv no HTTP atbildes statusa koda un JSON slodzes. HTTP atbildes statusa kodam jābūt "200", "201", "202", "203" vai "204" pieprasījumiem, kas tika veiksmīgi apstrādāti, bet citam kodam — neveiksmīgiem pieprasījumiem.

Veiksmīgas atbildes piemērs:

HTTP/1.1 200 OK
Content-Type: application/json
X-Content-Type-Options: nosniff
Date: Tue, 21 Apr 2026 10:13:04 GMT
Content-Length: 23

{"response":"success"}

Piemērs ar kļūdām:

HTTP/1.1 422 Unprocessable Entity
Content-Type: application/json
X-Content-Type-Options: nosniff
Date: Tue, 21 Apr 2026 12:15:01 GMT
Content-Length: 55

{"error":"invalid character '{' after top-level value"}