diff options
| author | Rasmus Luha <rasmus.luha@ut.ee> | 2025-04-23 23:24:51 +0300 |
|---|---|---|
| committer | Rasmus Luha <rasmus.luha@ut.ee> | 2025-04-23 23:24:51 +0300 |
| commit | 0c503f6cbcb8c74dbc06b7355744aa637cac7172 (patch) | |
| tree | 46e04a3741aa8f06255d5cde416b2bc0f12e2b28 /modules | |
| parent | c341ab0ab1697a26f09cc8f9131ca1d9f158034e (diff) | |
update README.md, add interactive mode measurement name input
Diffstat (limited to 'modules')
| -rw-r--r-- | modules/nifi/core.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/modules/nifi/core.py b/modules/nifi/core.py index 4b7f748..4ddc268 100644 --- a/modules/nifi/core.py +++ b/modules/nifi/core.py @@ -130,8 +130,14 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_ - ### Processor editing - TODO only from config file currently - measurements_name = config.NIFI_MEASUREMENT_NAME+" " + ### Processor editing + + ## Measurements name defining + if config.INTERACTIVE_MODE: + measurements_name = str(input("Palun sisesta andmebaasi jaoks vajalik 'measurement' nimi (influxDB): ")) + else: + measurements_name = config.NIFI_MEASUREMENT_NAME+" " + if needs_SplitJson: ## SplitJson update |