From c080b8d6786e319bc9b93d6fe8854f9ac5321485 Mon Sep 17 00:00:00 2001 From: Tanmaya Panda Date: Mon, 12 Feb 2024 16:49:34 +0530 Subject: [PATCH] modified x-ms-user header Signed-off-by: Tanmaya Panda --- plugins/out_azure_kusto/azure_kusto.c | 8 ++++++++ plugins/out_azure_kusto/azure_kusto_ingest.c | 4 ++-- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/plugins/out_azure_kusto/azure_kusto.c b/plugins/out_azure_kusto/azure_kusto.c index 58ac559dbdc..0b6a23e8b1d 100644 --- a/plugins/out_azure_kusto/azure_kusto.c +++ b/plugins/out_azure_kusto/azure_kusto.c @@ -24,6 +24,7 @@ #include #include #include +#include #include "azure_kusto.h" #include "azure_kusto_conf.h" @@ -152,6 +153,13 @@ flb_sds_t execute_ingest_csl_command(struct flb_azure_kusto *ctx, const char *cs flb_http_add_header(c, "Accept", 6, "application/json", 16); flb_http_add_header(c, "Authorization", 13, token, flb_sds_len(token)); + + /* added kusto specific headers for debugging requests */ + flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16); + flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36); + flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR)); + flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16); + flb_http_buffer_size(c, FLB_HTTP_DATA_SIZE_MAX * 10); /* Send HTTP request */ diff --git a/plugins/out_azure_kusto/azure_kusto_ingest.c b/plugins/out_azure_kusto/azure_kusto_ingest.c index a5dedf2f8e1..be03d7610ee 100644 --- a/plugins/out_azure_kusto/azure_kusto_ingest.c +++ b/plugins/out_azure_kusto/azure_kusto_ingest.c @@ -166,7 +166,7 @@ static flb_sds_t azure_kusto_create_blob(struct flb_azure_kusto *ctx, flb_sds_t flb_http_add_header(c, "x-ms-version", 12, "2019-12-12", 10); /* added kusto specific headers for debugging requests */ - flb_http_add_header(c, "x-ms-user", 9, "Fluent-Bit", 10); + flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16); flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36); flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR)); flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16); @@ -375,7 +375,7 @@ static int azure_kusto_enqueue_ingestion(struct flb_azure_kusto *ctx, flb_sds_t flb_http_add_header(c, "x-ms-version", 12, "2019-12-12", 10); /* added kusto specific headers for debugging requests */ - flb_http_add_header(c, "x-ms-user", 9, "Fluent-Bit", 10); + flb_http_add_header(c, "x-ms-user", 9, "Kusto.Fluent-Bit", 16); flb_http_add_header(c, "x-ms-client-request-id", 22, generate_uuid(), 36); flb_http_add_header(c, "x-ms-client-version", 10, FLB_VERSION_STR, strlen(FLB_VERSION_STR)); flb_http_add_header(c, "x-ms-app", 8, "Kusto.Fluent-Bit", 16);