DLPX-96312 Mirrored perf_playbook for influxDB

Author: dbshah12

debian/rules

@@ -26,6 +26,6 @@ override_dh_auto_install:
 	dh_install telegraf/delphix-telegraf-service telegraf/perf_playbook /usr/bin
 	dh_install telegraf/delphix-telegraf.service /lib/systemd/system
 	dh_install telegraf/telegraf* telegraf/*.sh /etc/telegraf
-	dh_install influxdb/delphix-influxdb-service influxdb/delphix-influxdb-init /usr/bin
+	dh_install influxdb/delphix-influxdb-service influxdb/delphix-influxdb-init influxdb/perf_influxdb /usr/bin
 	dh_install influxdb/delphix-influxdb.service /lib/systemd/system
 	dh_install influxdb/influxdb.conf influxdb/influxdb-init.conf /etc/influxdb

influxdb/delphix-influxdb-init

@@ -16,7 +16,8 @@ INFLUXDB_META_FILE="$INFLUXDB_CONFIG_DIR/influxdb_meta"
 # State file written immediately after /api/v2/setup so the script can resume
 # if it is interrupted before the metadata file is fully written.
 INFLUXDB_SETUP_STATE_FILE="$INFLUXDB_CONFIG_DIR/influxdb_setup_state"
-TELEGRAF_BASE="/etc/telegraf/telegraf.base"
+INFLUXDB_FLAG=/etc/telegraf/INFLUXDB_ENABLED
+INFLUXDB_OUTPUT=/etc/telegraf/telegraf.outputs.influxdb
 INFLUXDB_INIT_CONF="$INFLUXDB_CONFIG_DIR/influxdb-init.conf"
 
 # Load tunable configuration (org, bucket, retention, wait parameters).
@@ -156,24 +157,21 @@ READ_TOKEN_RESPONSE=$(influx_post "/api/v2/authorizations" "{
 READ_TOKEN=$(json_field "$READ_TOKEN_RESPONSE" "['token']") || exit 1
 
 #
-# Append the [[outputs.influxdb_v2]] stanza to telegraf.base so Telegraf
-# knows where to ship metrics.
+# Write the [[outputs.influxdb_v2]] stanza to a dedicated telegraf output file
+# and enable it via the INFLUXDB_ENABLED flag. The flag is read by
+# delphix-telegraf-service to conditionally include this output.
 #
-if [[ ! -f "$TELEGRAF_BASE" ]]; then
-	log "WARNING: $TELEGRAF_BASE not found, skipping Telegraf output stanza."
-elif ! grep -q "^[[:space:]]*#\{0,1\}\[\[outputs\.influxdb_v2\]\]" "$TELEGRAF_BASE"; then
-	cat >>"$TELEGRAF_BASE" <<EOF
-
+cat >"$INFLUXDB_OUTPUT" <<EOF
 [[outputs.influxdb_v2]]
   urls = ["http://127.0.0.1:8086"]
   token = "$WRITE_TOKEN"
   organization = "$INFLUXDB_ORG"
   bucket = "$INFLUXDB_BUCKET"
   namepass = ["cpu", "disk", "diskio", "mem", "net", "procstat", "processes", "swap", "system", "zfs"]
 EOF
-fi
 # Enforce restrictive permissions so the write token is not world-readable.
-chmod 640 "$TELEGRAF_BASE"
+chmod 640 "$INFLUXDB_OUTPUT"
+touch "$INFLUXDB_FLAG"
 
 #
 # Persist org/bucket/admin credentials/tokens so DE APIs can expose them to DCT

influxdb/perf_influxdb

@@ -0,0 +1,49 @@
+#!/bin/bash
+#
+# Copyright (c) 2026 by Delphix. All rights reserved.
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+#
+# Script that enables and disables InfluxDB metric output for Telegraf.
+#
+
+INFLUXDB_FLAG=/etc/telegraf/INFLUXDB_ENABLED
+INFLUXDB_OUTPUT=/etc/telegraf/telegraf.outputs.influxdb
+
+function die() {
+	echo -e "$(date +%T:%N:%z): $(basename $0): $*" >&2
+	exit 1
+}
+
+[[ $EUID -ne 0 ]] && die "must be run as root"
+
+function usage() {
+	echo "$(basename $0): $*" >&2
+	echo "Usage: $(basename $0) [enable|disable]"
+	exit 2
+}
+
+function enable_influxdb() {
+	date
+	[[ ! -f $INFLUXDB_OUTPUT ]] && die "$INFLUXDB_OUTPUT not found. Run delphix-influxdb-init first."
+	echo "Enabling InfluxDB Metric Output"
+	touch $INFLUXDB_FLAG
+	systemctl restart delphix-telegraf
+}
+
+function disable_influxdb() {
+	date
+	echo "Disabling InfluxDB Metric Output"
+	rm -rf $INFLUXDB_FLAG
+	systemctl restart delphix-telegraf
+}
+
+if [[ $# -ne 1 ]]; then
+	usage
+fi
+
+case "$1" in
+enable) enable_influxdb ;;
+disable) disable_influxdb ;;
+*) usage ;;
+esac

telegraf/delphix-telegraf-service

@@ -3,7 +3,9 @@ BASE_CONFIG=/etc/telegraf/telegraf.base
 DOSE_INPUTS=/etc/telegraf/telegraf.inputs.dose
 DCT_INPUTS=/etc/telegraf/telegraf.inputs.dct
 PLAYBOOK_INPUTS=/etc/telegraf/telegraf.inputs.playbook
+INFLUXDB_OUTPUT=/etc/telegraf/telegraf.outputs.influxdb
 PLAYBOOK_FLAG=/etc/telegraf/PLAYBOOK_ENABLED
+INFLUXDB_FLAG=/etc/telegraf/INFLUXDB_ENABLED
 TELEGRAF_CONFIG=/etc/telegraf/telegraf.conf
 
 
@@ -21,6 +23,10 @@ function playbook_is_enabled() {
 	[[ -f $PLAYBOOK_FLAG ]]
 }
 
+function influxdb_is_enabled() {
+	[[ -f $INFLUXDB_FLAG ]]
+}
+
 rm -f $TELEGRAF_CONFIG
 
 if engine_is_object_based; then
@@ -43,4 +49,8 @@ else
 	fi
 fi
 
+if influxdb_is_enabled && [[ -f $INFLUXDB_OUTPUT ]]; then
+	cat $INFLUXDB_OUTPUT >> $TELEGRAF_CONFIG
+fi
+
 /usr/bin/telegraf -config $TELEGRAF_CONFIG

telegraf/telegraf.base

@@ -44,13 +44,9 @@
   data_format = "json"
   namepass = ["agg_*"]
 
-# Update token from /etc/influxdb/influxdb_meta (INFLUXDB_ADMIN_TOKEN), then uncomment and restart telegraf.
-#[[outputs.influxdb_v2]]
-#  urls = ["http://127.0.0.1:8086"]
-#  token = ""
-#  organization = "delphix"
-#  bucket = "default"
-#  namepass = ["cpu", "disk", "diskio", "mem", "net", "procstat", "processes", "swap", "system", "zfs"]
+# InfluxDB output is managed via /etc/telegraf/telegraf.outputs.influxdb (written by
+# delphix-influxdb-init) and the /etc/telegraf/INFLUXDB_ENABLED flag.
+# Use 'perf_influxdb enable|disable' to toggle and restart Telegraf.
 
 ###############################################################################
 #                            INPUT PLUGINS                                    #