From 137b8a988f77e957feed698494f7143ac06a7b51 Mon Sep 17 00:00:00 2001 From: Rasmus Luha Date: Sun, 11 May 2025 15:43:31 +0300 Subject: add diffJsonRootPath template to telegraf --- modules/nifi/core.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'modules/nifi/core.py') diff --git a/modules/nifi/core.py b/modules/nifi/core.py index 79ab5b9..6eddbad 100644 --- a/modules/nifi/core.py +++ b/modules/nifi/core.py @@ -44,7 +44,7 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_ ## Measurements name defining if config.INTERACTIVE_MODE: - measurements_name = str(input("Palun sisesta andmebaasi jaoks vajalik 'measurement' nimi (influxDB): ")) + measurements_name = str(input("Palun sisesta andmebaasi jaoks vajalik 'measurement' nimi (influxDB): "))+" " else: measurements_name = config.MEASUREMENT_NAME+" " @@ -55,6 +55,7 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_ nifi_utils.update_template(new_pipeline_path, "flowContents.processors[3].properties", "JsonPath Expression", split_json_path) ## EvaluateJsonPath processor setup + ## TODO for key, value in data_values.items() : path_parts = value.split(']') nifi_utils.update_template(new_pipeline_path, "flowContents.processors[2].properties", key, "$"+path_parts[1]) @@ -93,6 +94,7 @@ def build_pipeline(): if config.INTERACTIVE_MODE: data_values, api_url, api_username, api_password= common.get_data_values() + print(data_values) print("\nKui tihti peaks andmekonveier jooksma? (sekundites)") schedulingPeriod = str(common.ask_digit_input(86400))+ "sec" -- cgit v1.2.3