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 | |
| parent | b2e8ec86abe8089ed5fbd1655677889b6691397f (diff) | |
telegraf basicETL working
Diffstat (limited to 'modules/nifi')
| -rw-r--r-- | modules/nifi/core.py | 4 | ||||
| -rw-r--r-- | modules/nifi/nifi_utils.py | 3 |
2 files changed, 4 insertions, 3 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 diff --git a/modules/nifi/nifi_utils.py b/modules/nifi/nifi_utils.py index 74cba81..1871940 100644 --- a/modules/nifi/nifi_utils.py +++ b/modules/nifi/nifi_utils.py @@ -34,7 +34,8 @@ def update_template(file_path, dot_path, new_key, new_value): def set_database_credentials(file_path,dot_path): ## Update URL - update_template(file_path, dot_path, "HTTP URL", config.DB_URL) + db_full_url=config.DB_URL+"/write?db="+config.DB_NAME + update_template(file_path, dot_path, "HTTP URL", db_full_url) ## Update username update_template(file_path, dot_path, "username", config.DB_USER) |