From 737f498e1f402a5a41068a37ab20f34cabd4b052 Mon Sep 17 00:00:00 2001 From: Rasmus Luha Date: Tue, 29 Apr 2025 23:49:58 +0300 Subject: telegraf basicETL working --- modules/nifi/core.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'modules/nifi/core.py') diff --git a/modules/nifi/core.py b/modules/nifi/core.py index 118ee3a..bcf50c0 100644 --- a/modules/nifi/core.py +++ b/modules/nifi/core.py @@ -46,7 +46,7 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_ if config.INTERACTIVE_MODE: measurements_name = str(input("Palun sisesta andmebaasi jaoks vajalik 'measurement' nimi (influxDB): ")) else: - measurements_name = config.NIFI_MEASUREMENT_NAME+" " + measurements_name = config.MEASUREMENT_NAME+" " if needs_SplitJson: @@ -102,7 +102,7 @@ def build_pipeline(): else: api_url = config.API_URL data_values = config.API_FIELDS - schedulingPeriod = config.PIPELINE_SCHEDULING_PERIOD + schedulingPeriod = config.PIPELINE_SCHEDULING_PERIOD+"sec" new_pipeline_name = config.PIPELINE_NAME+".json" api_username = config.API_USERNAME api_password = config.API_PASSWORD -- cgit v1.2.3