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ācija

Lai konfigurētu datu straumēšanu uz ārēju sistēmu, ir jāveic šādas darbības:

1. Sagatavojiet 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ē events.ndjson un history.ndjson failos.
• Kafka savienotājs Zabbix serverim - 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. Zabbix iestatiet nepieciešamo savienotāja darba procesu skaitu, pielāgojot StartConnectors parametru failā zabbix_server.conf. Savienotāja darba procesu skaitam jāatbilst Zabbix lietotāja saskarnē konfigurētajam savienotāju skaitam (vai tas jābūt lielākam, ja vienlaicīgo sesiju skaits ir lielāks par 1). Pēc tam restartējiet Zabbix serveri.

3. Zabbix lietotāja saskarnē konfigurējiet jaunu savienotāju (Administration > General > Connectors) un pārlā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 ar komatiem atdalītu bootstrap 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 vispirms, un izmanto to klastera metadatus. Ja sarakstā ir adreses no dažādiem Kafka klasteriem, tiks izmantots tikai ātrāk atbildējušais klasteris, bet pārējās adreses tiks reģistrētas kā nepieejamas; tā rezultātā var tikt parādīti tādi startēšanas brīdinājumi kā šis, 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ātos tīklos, konteineru tīklos vai nestandarta DNS/hosts iestatījumos) hostu nosaukumi vai IP adreses var tikt atrisinātas uz loopback adresēm (piemēram, 127.0.0.1/localhost) vai klients tās var normalizēt, kas var padarīt šādus brīdinājumus maldinošus. Lai mazinātu neskaidrības, pārliecinieties, ka visas Kafka.URL adreses pieder vienam un tam pašam Kafka klasterim, pārbaudiet DNS atrisināšanu no savienotāja hosta un brokeru advertised.listeners, un dodiet priekšroku adresēm, kas atrisinās 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"}