[comment]: # translation:outdated [comment]: # (tags: connector) [comment]: # ({cdb0d4ea-b45624e8}) # 2 Strumieniowanie do systemów zewnętrznych [comment]: # ({/cdb0d4ea-b45624e8}) [comment]: # ({fa81590c-c479d2fd}) #### 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](#protocol)). Filtr tagów może być używany do strumieniowania podzbiorów wartości pozycji lub zdarzeń. Za strumieniowanie danych odpowiadają dwa typy procesów serwera Zabbix: `connector manager` i `connector worker`. Wewnętrzna pozycja Zabbix `zabbix[connector_queue]` umożliwia monitorowanie liczby wartości umieszczonych w kolejce connector. [comment]: # ({/fa81590c-c479d2fd}) [comment]: # ({695ba0a3-cfad3c2f}) #### Konfiguracja Aby skonfigurować strumieniowanie danych do systemu zewnętrznego, wymagane są następujące kroki: 1\. Przygotuj zdalny system do odbierania danych z Zabbix. W tym celu dostępne są następujące narzędzia: - Przykład prostego [odbiornika](https://git.zabbix.com/projects/ZT/repos/receiver/browse), który zapisuje odebrane informacje w plikach `events.ndjson` i `history.ndjson`. - [Kafka connector for Zabbix server](https://git.zabbix.com/projects/ZT/repos/kafka-connector/browse) — 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`](/manual/appendix/config/zabbix_server#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 (*Administracja* > *Ogólne* > *Connectors*) i przeładuj pamięć podręczną konfiguracji serwera poleceniem `zabbix_server -R config_cache_reload`. ![](../../../../assets/en/manual/config/connector.png){width="600"} Pola obowiązkowe są oznaczone gwiazdką. |Parametr|Opis| |--|--------| |*Name*|Wprowadź nazwę connectora.| |*Data type*|Wybierz typ danych do strumieniowania:
**Item values** — strumieniowanie wartości pozycji z Zabbix do systemów zewnętrznych;
**Events** — strumieniowanie zdarzeń z Zabbix do systemów zewnętrznych.| |*URL*|Wprowadź adres URL odbiornika. Obsługiwane są makra użytkownika.| |*Tag filter*|Eksportuj tylko wartości pozycji lub zdarzenia pasujące do filtra tagów. Jeśli nie ustawiono, eksportowane będzie wszystko.
Możliwe jest zarówno uwzględnianie, jak i wykluczanie określonych tagów oraz wartości tagów. Można ustawić kilka warunków. Dopasowanie nazw tagów zawsze uwzględnia wielkość liter.

Dla każdego warunku dostępnych jest kilka operatorów:
**Exists** — uwzględnij określone nazwy tagów;
**Equals** — uwzględnij określone nazwy i wartości tagów (z uwzględnieniem wielkości liter);
**Contains** — uwzględnij określone nazwy tagów, których wartości zawierają wprowadzony ciąg (dopasowanie podciągu, bez uwzględniania wielkości liter);
**Does not exist** — wyklucz określone nazwy tagów;
**Does not equal** — wyklucz określone nazwy i wartości tagów (z uwzględnieniem wielkości liter);
**Does not contain** — wyklucz określone nazwy tagów, których wartości zawierają wprowadzony ciąg (dopasowanie podciągu, bez uwzględniania wielkości liter).

Dostępne są dwa typy obliczania warunków:
**And/Or** — wszystkie warunki muszą być spełnione, a warunki mające tę samą nazwę tagu będą grupowane operatorem Or;
**Or** — wystarczy spełnienie jednego warunku.| |*Type of information*|Wybierz typ informacji (numeric (unsigned), numeric (float), character itp.), według którego mają być filtrowane wartości pozycji strumieniowane przez connector.
To pole jest dostępne, jeśli *Data type* jest ustawione na "Item values".| |*HTTP authentication*|Wybierz opcję uwierzytelniania:
**None** — bez uwierzytelniania;
**Basic** — używane jest uwierzytelnianie podstawowe;
**NTLM** — używane jest uwierzytelnianie NTLM ([Windows NT LAN Manager](http://en.wikipedia.org/wiki/NTLM));
**Kerberos** — używane jest uwierzytelnianie Kerberos (zobacz także: [Configuring Kerberos with Zabbix](/manual/appendix/items/kerberos));
**Digest** — używane jest uwierzytelnianie Digest;
**Bearer** — używane jest uwierzytelnianie Bearer.| |*Username*|Wprowadź nazwę użytkownika (do 255 znaków). Obsługiwane są makra użytkownika.
To pole jest dostępne, jeśli *HTTP authentication* jest ustawione na "Basic", "NTLM", "Kerberos" lub "Digest".| |*Password*|Wprowadź hasło użytkownika (do 255 znaków). Obsługiwane są makra użytkownika.
To pole jest dostępne, jeśli *HTTP authentication* jest ustawione na "Basic", "NTLM", "Kerberos" lub "Digest".| |*Bearer token*|Wprowadź token Bearer. Obsługiwane są makra użytkownika.
To pole jest dostępne i wymagane, jeśli *HTTP authentication* jest ustawione na "Bearer".| |*Advanced configuration*|Kliknij nagłówek *Advanced configuration*, aby wyświetlić zaawansowane opcje konfiguracji (patrz poniżej).| |*Max records per message*|Określ maksymalną liczbę wartości lub zdarzeń, które mogą być strumieniowane w jednej wiadomości.| |*Concurrent sessions*|Wybierz liczbę procesów nadawczych uruchamianych dla tego connectora. Można określić do 100 sesji; wartość domyślna to "1".| |*Attempts*|Liczba prób strumieniowania danych. Można określić do 5 prób; wartość domyślna to "1".| |*Attempt interval*|Określ, jak długo connector powinien czekać po nieudanej próbie strumieniowania danych. Można określić do 10s; wartość domyślna to "5s".
To pole jest dostępne, jeśli *Attempts* jest ustawione na "2" lub więcej.
Nieudane próby to takie, w których nie udało się nawiązać połączenia lub kod odpowiedzi HTTP nie jest równy 200, 201, 202, 203, 204. Ponowne próby są **wyzwalane** w przypadku błędów komunikacji lub gdy kod odpowiedzi HTTP nie jest równy 200, 201, 202, 203, 204, 400, 401, 403, 404, 405, 415, 422. Przekierowania są obsługiwane, więc 302 -> 200 jest odpowiedzią pozytywną, natomiast 302 -> 503 spowoduje ponowną próbę.| |*Timeout*|Określ limit czasu wiadomości (1-60 sekund, domyślnie — 5 sekund).
Obsługiwane są sufiksy czasu, np. 30s, 1m. Obsługiwane są makra użytkownika.| |*HTTP proxy*|Możesz określić HTTP proxy do użycia w następującym formacie:
`[protocol://][username[:password]@]proxy.example.com[:port]`
Obsługiwane są makra użytkownika.

Opcjonalny prefiks `protocol://` może być użyty do określenia alternatywnych protokołów proxy (obsługa prefiksu protokołu została dodana w cURL 7.21.7). Jeśli nie określono protokołu, proxy będzie traktowane jako HTTP proxy. Domyślnie użyty zostanie port 1080.

Jeśli określono *HTTP proxy*, proxy nadpisze zmienne środowiskowe związane z proxy, takie jak `http_proxy`, `HTTPS_PROXY`. Jeśli nie określono, proxy nie nadpisze zmiennych środowiskowych związanych z proxy. Wprowadzona wartość jest przekazywana bez zmian, bez sprawdzania poprawności.
Możesz również wprowadzić adres proxy SOCKS. Jeśli określisz niewłaściwy protokół, connector nie będzie w stanie strumieniować wartości pozycji lub zdarzeń z Zabbix.

Należy pamiętać, że w przypadku HTTP proxy obsługiwane jest tylko proste uwierzytelnianie.| |*SSL verify peer*|Zaznacz pole wyboru, aby weryfikować certyfikat SSL serwera WWW.
Certyfikat serwera zostanie automatycznie pobrany z systemowej lokalizacji urzędu certyfikacji (CA). Możesz nadpisać lokalizację plików CA za pomocą parametru konfiguracyjnego serwera Zabbix lub proxy [`SSLCALocation`](/manual/appendix/config/zabbix_server#sslcalocation).| |*SSL verify host*|Zaznacz pole wyboru, aby zweryfikować, czy pole *Common Name* lub pole *Subject Alternate Name* certyfikatu serwera WWW jest zgodne.
Ustawia to opcję cURL [`CURLOPT_SSL_VERIFYHOST`](http://curl.haxx.se/libcurl/c/CURLOPT_SSL_VERIFYHOST.html).| |*SSL certificate file*|Nazwa pliku certyfikatu SSL używanego do uwierzytelniania klienta. Plik certyfikatu musi być w formacie PEM^1^. Obsługiwane są makra użytkownika.
Jeśli plik certyfikatu zawiera również klucz prywatny, pozostaw pole *SSL key file* puste. Jeśli klucz jest zaszyfrowany, podaj hasło w polu *SSL key password*. Katalog zawierający ten plik jest określany przez parametr konfiguracyjny serwera Zabbix lub proxy [`SSLCertLocation`](/manual/appendix/config/zabbix_server#sslcertlocation).| |*SSL key file*|Nazwa pliku klucza prywatnego SSL używanego do uwierzytelniania klienta. Plik klucza prywatnego musi być w formacie PEM^1^. Obsługiwane są makra użytkownika.
Katalog zawierający ten plik jest określany przez parametr konfiguracyjny serwera Zabbix lub proxy [`SSLKeyLocation`](/manual/appendix/config/zabbix_server#sslkeylocation).| |*SSL key password*|Hasło do pliku klucza prywatnego SSL. Obsługiwane są makra użytkownika.| |*Description*|Wprowadź opis connectora.| |*Enabled*|Zaznacz pole wyboru, aby włączyć connector.| 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óre odpowiedzą jako pierwsze, i używa ich 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: ```default 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. [comment]: # ({/695ba0a3-cfad3c2f}) [comment]: # ({3208b284-b67df609}) #### 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](/manual/appendix/protocols/real_time_export). [comment]: # ({/3208b284-b67df609}) [comment]: # ({fd0d393d-ae5d9204}) ##### Żądanie serwera Przykład strumieniowania wartości pozycji: ```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} ``` Przykład strumieniowania zdarzeń: ```json 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} ``` [comment]: # ({/fd0d393d-ae5d9204}) [comment]: # ({d6988482-89101d44}) ##### 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, inny dla żądań zakończonych niepowodzeniem. Przykład powodzenia: ```json 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"} ``` Przykład z błędami: ```json 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"} ``` [comment]: # ({/d6988482-89101d44})