diff options
| author | Rasmus Luha <rasmus.luha@ut.ee> | 2025-04-29 23:49:58 +0300 |
|---|---|---|
| committer | Rasmus Luha <rasmus.luha@ut.ee> | 2025-04-29 23:49:58 +0300 |
| commit | 737f498e1f402a5a41068a37ab20f34cabd4b052 (patch) | |
| tree | 2b97e22aa8e3293e4c66e69c5ba7d7bcc5b0a5fd /modules/nifi/core.py | |
| parent | b2e8ec86abe8089ed5fbd1655677889b6691397f (diff) | |
telegraf basicETL working
Diffstat (limited to 'modules/nifi/core.py')
| -rw-r--r-- | modules/nifi/core.py | 4 |
1 files changed, 2 insertions, 2 deletions
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 |