summaryrefslogtreecommitdiff
path: root/modules/nifi/nifi_utils.py
diff options
context:
space:
mode:
authorRasmus Luha <rasmus.luha@ut.ee>2025-04-29 23:49:58 +0300
committerRasmus Luha <rasmus.luha@ut.ee>2025-04-29 23:49:58 +0300
commit737f498e1f402a5a41068a37ab20f34cabd4b052 (patch)
tree2b97e22aa8e3293e4c66e69c5ba7d7bcc5b0a5fd /modules/nifi/nifi_utils.py
parentb2e8ec86abe8089ed5fbd1655677889b6691397f (diff)
telegraf basicETL working
Diffstat (limited to 'modules/nifi/nifi_utils.py')
-rw-r--r--modules/nifi/nifi_utils.py3
1 files changed, 2 insertions, 1 deletions
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)