エンドポイントとしてKafkaを使用するNetScaler Observability Exporter

ネットスケーラー オブザーバビリティ エクスポーター の展開

NetScaler Observability Exporterサポート付きでNetScaler CPXを展開する

1. cpx-ingress-kafka.yamlとcic-configmap.yamlファイルをダウンロードします。
2. 必要なキーと値のペアを持つConfigMapを作成し、デプロイします。特定のエンドポイント向けに、ディレクトリで利用可能なcic-configmap.yamlファイルを使用できます。
3. 必要に応じて、NetScaler CPX 関連のパラメーターを変更します。
4. cic-configmap.yaml ファイルを編集し、NS_ANALYTICS_CONFIG エンドポイント構成で NetScaler Observability Exporter の次の変数を指定します。
   server: 'coe-kafka.default.svc.cluster.local' # COE service FQDN
5. 次のコマンドを使用して、NetScaler Observability Exporter のサポート付きで NetScaler CPX をデプロイします。
   kubectl create -f cpx-ingress-kafka.yaml
kubectl create -f cic-configmap.yaml

YAML を使用して NetScaler Observability Exporter をデプロイする

1. 次の YAML 定義を使用して ConfigMap を編集します。
   注:
   ブートストラップ Kafka ブローカーアドレス (コンマ区切り) と目的の Kafka トピックが指定されていることを確認してください。
   apiVersion: v1
kind: ConfigMap
metadata:
  name: coe-config-kafka
data:
  lstreamd_default.conf: |
    {
        "Endpoints": {
          "KAFKA": {
            "ServerUrl": "X.X.X.X:9092,Y.Y.Y.Y:9092", #Specify the bootstrap Kafka broker addresses (separated by comma in case multiple bootstrap brokers are to be configured)
            "KafkaTopic": "HTTP", #Specify the desired kafka topic
            "RecordType": {
                "HTTP": "all",
                "TCP": "all",
                "SWG": "all",
                "VPN": "all",
                "NGS": "all",
                "ICA®": "all",
                "APPFW": "none",
                "BOT": "none",
                "VIDEOOPT": "none",
                "BURST_CQA": "none",
                "SLA": "none",
                "MONGO": "none"
            },
            "ProcessAlways": "yes",
            "FileSizeMax": "40",
            "ProcessYieldTimeOut": "500",
            "FileStorageLimit": "1000",
            "SkipAvro": "no",
            "AvroCompress": "yes"
          }
      }
    }
   注: JSON 形式でトランザクションをエクスポートするには、Kafka への JSON 形式でのトランザクションのエクスポート を参照してください。
2. Kafka ノードのホスト名と IP または FQDN アドレスを指定します。3 ノード Kafka クラスターには、次の YAML 定義を使用します。
   apiVersion: apps/v1
kind: Deployment
metadata:
  name: coe-kafka
  labels:
    app: coe-kafka
spec:
  replicas: 1
  selector:
    matchLabels:
      app: coe-kafka
  template:
    metadata:
      name: coe-kafka
      labels:
        app: coe-kafka
    spec:
      hostAliases:
        - ip: "X.X.X.X" # Here we specify kafka node1 Ipaddress
          hostnames:
            - "kafka-node1"
        - ip: "Y.Y.Y.Y" # Here we specify kafka node2 Ipaddress
          hostnames:
            - "kafka-node2"
        - ip: "Z.Z.Z.Z" # Here we specify kafka node3 Ipaddress
          hostnames:
            - "kafka-node3"
      containers:
        - name: coe-kafka
          image: "quay.io/citrix/citrix-observability-exporter:1.3.001"
          imagePullPolicy: Always
          ports:
            - containerPort: 5557
              name: lstream
          volumeMounts:
            - name: lstreamd-config-kafka
              mountPath: /var/logproxy/lstreamd/conf/lstreamd_default.conf
              subPath: lstreamd_default.conf
            - name: core-data
              mountPath: /var/crash/
      volumes:
        - name: lstreamd-config-kafka
          configMap:
            name: coe-config-kafka
        - name: core-data
          emptyDir: {}
3. 必要に応じて、以下のYAML定義を使用して、NetScaler Observability ExporterポートをNetScalerに公開するためのサービス構成を編集します。
   Citrix-observability-exporterヘッドレスサービス:
   apiVersion: v1
kind: Service
metadata:
  name: coe-kafka
  labels:
    app: coe-kafka
spec:
  clusterIP: None
  ports:
    - port: 5557
      protocol: TCP
  selector:
      app: coe-kafka
   Citrix-observability-exporter ノードポートサービス
   apiVersion: v1
kind: Service
metadata:
  name: coe-kafka-nodeport
  labels:
    app: coe-kafka
spec:
  type: NodePort
  ports:
    - port: 5557
      protocol: TCP
  selector:
      app: coe-kafka

NetScaler Observability Exporterの展開を確認する

1. 次のコマンドを使用して展開を確認します。
   kubectl get deployment,pods,svc -o wide
   サンプル出力(/en-us/netscaler-observability-exporter/media/coe-kafka-verification-sample-output.png)
2. ブラウザでURL: https://<kubernetes-node-IP>:<cpx-ingress-kafka nodeport>を使用してアプリケーションにアクセスします。
   For example, from step 1, access `<http://10.102.61.56:31202/>` in which, `10.102.61.56` is one of the Kubernetes node IPs.
   HTTPメソッド(/en-us/netscaler-observability-exporter/media/coe-kafka-http-methods.png)
3. Kafka Consumerを使用してトランザクションデータを表示します。PythonKafkaConsumerからKafka Consumerにアクセスします。
   次の画像は、Kafka Consumerからのサンプルデータを示しています。
   Kafka Consumerからのデータ(/en-us/netscaler-observability-exporter/media/coe-kafka-consumer-transactions.png)

複数のNetScaler Observability ExporterインスタンスをNetScalerに手動で統合する

NetScaler Observability ExporterからKafkaへのJSON形式でのトランザクションエクスポートのサポート