From 4759214471e2f36b6df2408fef1d911c6b4c599c Mon Sep 17 00:00:00 2001 From: Ramachandran A G <106139410+ag-ramachandran@users.noreply.github.com> Date: Wed, 4 Oct 2023 13:26:31 +0530 Subject: [PATCH] feat(outputs.azure_data_explorer): Set user agent string (#14047) --- plugins/outputs/azure_data_explorer/azure_data_explorer.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/plugins/outputs/azure_data_explorer/azure_data_explorer.go b/plugins/outputs/azure_data_explorer/azure_data_explorer.go index cca3837b7..c954b19d5 100644 --- a/plugins/outputs/azure_data_explorer/azure_data_explorer.go +++ b/plugins/outputs/azure_data_explorer/azure_data_explorer.go @@ -17,6 +17,7 @@ import ( "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/config" + "github.com/influxdata/telegraf/internal" "github.com/influxdata/telegraf/internal/choice" "github.com/influxdata/telegraf/plugins/outputs" "github.com/influxdata/telegraf/plugins/serializers" @@ -58,6 +59,8 @@ func (*AzureDataExplorer) SampleConfig() string { // Initialize the client and the ingestor func (adx *AzureDataExplorer) Connect() error { conn := kusto.NewConnectionStringBuilder(adx.Endpoint).WithDefaultAzureCredential() + // Since init is called before connect, we can set the connector details here including the type. This will be used for telemetry and tracing. + conn.SetConnectorDetails("Telegraf", internal.ProductToken(), "", "", false, "") client, err := kusto.New(conn) if err != nil { return err