From 6cb9f3eb1614f097992e27f2309bf6ca1cd37238 Mon Sep 17 00:00:00 2001 From: Rasmus Luha Date: Mon, 12 May 2025 13:13:22 +0300 Subject: update README.md, cleanup --- modules/nifi/core.py | 2 -- modules/telegraf/core.py | 1 - 2 files changed, 3 deletions(-) (limited to 'modules') diff --git a/modules/nifi/core.py b/modules/nifi/core.py index 5c15837..0d6ca17 100644 --- a/modules/nifi/core.py +++ b/modules/nifi/core.py @@ -1,4 +1,3 @@ -## TODO - check syntax from common import core as common import config from modules.nifi import nifi_utils @@ -67,7 +66,6 @@ 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]) diff --git a/modules/telegraf/core.py b/modules/telegraf/core.py index b340742..69021a2 100644 --- a/modules/telegraf/core.py +++ b/modules/telegraf/core.py @@ -102,7 +102,6 @@ def build_pipeline(): measurement_name = str(input("Palun sisesta andmebaasi (influxDB) jaoks vajalik 'measurement' nimi: ")) new_pipeline_name=input("Mis saab andmekonveieri nimeks: ")+".toml" - ## TODO else: api_url = config.API_URL data_values = config.API_FIELDS -- cgit v1.2.3