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 procesi: 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. Jābūt attālinātai sistēmai, kas ir iestatīta datu saņemšanai no Zabbix. Šim nolūkam ir pieejami šādi rīki:

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

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

3. Konfigurējiet jaunu savienotāju Zabbix lietotāja saskarnē (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 komatiem atdalītu bootstrap brokera adrešu sarakstu (piemēram, Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093), Kafka klients izveido savienojumu ar brokeri(-iem), kas atbild pirmie, 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; rezultātā startēšanas laikā var parādīties šādi brīdinājumi, pat ja savienotājs ir pieslēgts:

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ātie tīkli, konteineru tīkli vai nestandarta DNS/hosts iestatījumi) resursdatora nosaukumi vai IP adreses var tikt atrisinātas uz loopback adresēm (piemēram, 127.0.0.1/localhost) vai klienta pusē normalizētas, kas šādus brīdinājumus var padarīt 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, kā arī dodiet priekšroku adresēm, kas tiek atrisinātas uz brokera izziņoto 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; citi kodi norāda uz neveiksmīgiem pieprasījumiem.

Veiksmīgas atbildes piemērs:

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

Piemērs ar kļūdām:

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