2 外部システムへのストリーミング

概要

HTTP 経由で、Zabbix から外部システムへアイテムの値およびイベントをストリーミングできます（プロトコルの詳細を参照）。

タグフィルターを使用して、アイテムの値またはイベントのサブセットをストリーミングできます。

データストリーミングを担当する Zabbix サーバーのプロセスは、connector manager と connector worker の 2 つです。 Zabbix の内部アイテム zabbix[connector_queue] を使用すると、コネクターキューに追加された値の件数を監視できます。

設定

外部システムへのデータストリーミングを設定するには、以下の手順が必要です。

1. Zabbix からのデータを受信するためのリモートシステムを準備します。
この目的のために、以下のツールを利用できます。

• 受信した情報を events.ndjson および history.ndjson ファイルに記録する、シンプルな受信側の例。
• Zabbix server 用 Kafka connector - Go で記述された軽量サーバーで、Zabbix サーバーから Kafka ブローカーへアイテムの値およびイベントを転送するよう設計されています。

2. zabbix_server.conf の StartConnectors パラメータを調整して、Zabbix で必要な数のコネクタワーカーを設定します。
コネクタワーカー数は、Zabbix Webインターフェースで設定されたコネクタ数と一致させる必要があります（同時セッション数が 1 を超える場合は、それ以上にする必要があります）。
その後、Zabbix サーバーを再起動します。

3. Zabbix Webインターフェースで新しいコネクタを設定し（Administration > General > Connectors）、zabbix_server -R config_cache_reload コマンドでサーバーキャッシュを再読み込みします。

必須フィールドにはアスタリスクが付いています。

Kafka コネクタがブートストラップブローカーアドレスのカンマ区切りリストで設定されている場合（例: Kafka.URL=kafka1.example.com:9093,kafka2.example.com:9093）、Kafka クライアントは最初に応答したブローカーに接続し、そのクラスターメタデータを使用します。
リストに異なる Kafka クラスターのアドレスが含まれている場合、最も速く応答したクラスターのみが使用され、他のアドレスは利用不可としてログに記録されます。その結果、コネクタが接続されていても、以下のような起動時警告が表示されることがあります。

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

一部の環境（プライベートネットワーク、コンテナネットワーク、または標準的でない DNS/hosts 設定）では、ホスト名または IP がループバックアドレス（例: 127.0.0.1/localhost）に解決されたり、クライアントによって正規化されたりすることがあり、その結果、このような警告が誤解を招く場合があります。
混乱を減らすには、すべての Kafka.URL アドレスが同じ Kafka クラスターに属していることを確認し、コネクタホストからの DNS 名前解決とブローカーの advertised.listeners を確認し、ブローカーの通知アドレスに解決されるアドレスを優先して使用してください。

プロトコル

サーバーと受信側の通信は、REST API、NDJSON、Content-Type: application/x-ndjson を使用した HTTP 経由で行われます。

詳細については、改行区切り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}

イベントのストリーミングの例:

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}

Receiverのレスポンス

レスポンスは、HTTPレスポンスのステータスコードとJSONペイロードで構成されます。 正常に処理されたリクエストでは、HTTPレスポンスのステータスコードは "200"、"201"、"202"、"203"、または "204" である必要があります。その他のコードは、リクエストの失敗を示します。

成功時の例:

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

エラーがある場合の例:

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