supress nifi pipeline upload warnings from stdout

2 files changed, 11 insertions, 9 deletions

diff --git a/config.py b/config.py
index 2db70db..3c5ec72 100644
--- a/config.py
+++ b/config.py
@@ -1,5 +1,5 @@
-INTERACTIVE_MODE=False
-PLATFORM="Telegraf"
+INTERACTIVE_MODE=True
+#PLATFORM="Telegraf"
 
 
 #### Nifi specific ####
@@ -10,12 +10,12 @@ NIFI_DEPLOY=True
 NIFI_USER="lab08nifiuser"
 NIFI_PASS="tartunifi2023"
 
-MEASUREMENT_NAME="Tartu_ilmaandmed"
+MEASUREMENT_NAME="EurDol_kurss"
 
 ## Database
 DB_URL="http://influxdb:8086"
 #DB_NAME="nifi_weatherData"
-DB_NAME="telegraf_weatherData"
+DB_NAME="nifi_valuuta"
 DB_USER="admin"
 DB_PASS="admin"
 
@@ -24,10 +24,10 @@ DB_PASS="admin"
 
 ## Needed if Interactive mode turned off
 #API_URL="https://api.open-meteo.com/v1/forecast?latitude=37.9838&longitude=23.7275&current_weather=true"
-API_URL="https://api.openweathermap.org/data/2.5/weather?q=Tartu&units=metric&lang=en&appid=01786b7e8b623a1d2112d672ecae1d0d"
+API_URL="https://v6.exchangerate-api.com/v6/78660310eae8ed2c9ab662f8/latest/USD"
 #API_FIELDS={'temperature': '.current_weather.temperature', 'windspeed': '.current_weather.windspeed'}
 API_FIELDS={'temp': '.main.temp', 'winds': '.wind.speed'}
 API_USERNAME="rasmus.luha"
 API_PASSWORD="Placeholder"
 PIPELINE_SCHEDULING_PERIOD="10"
-PIPELINE_NAME="OpenWeather_pipeline"
+PIPELINE_NAME="ExchangeRate_pipeline"
diff --git a/modules/nifi/nifi_utils.py b/modules/nifi/nifi_utils.py
index 1871940..6028003 100644
--- a/modules/nifi/nifi_utils.py
+++ b/modules/nifi/nifi_utils.py
@@ -3,7 +3,9 @@ import config
 import requests
 import sys
 import json
+import urllib3
 
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 
 def update_template(file_path, dot_path, new_key, new_value):
 
@@ -25,12 +27,12 @@ def update_template(file_path, dot_path, new_key, new_value):
 
     # Step 4: Add or update the key
     current[new_key] = new_value
-    print(f"🛠 Added '{new_key}': '{new_value}' at path '{dot_path}'")
+    #print(f"🛠 Added '{new_key}': '{new_value}' at path '{dot_path}'")
 
     # Step 5: Save back the JSON
     with open(file_path, "w") as f:
         json.dump(data, f, indent=2)
-        print("✅ Changes saved.")
+        #print("✅ Changes saved.")
 
 def set_database_credentials(file_path,dot_path):
     ## Update URL
@@ -87,4 +89,4 @@ def upload_nifi_pipeline(token, pipeline_path, processorGroup_name, username=con
         )
 
     upload_resp.raise_for_status()
-    print(f"✅ Uploaded process group '{processorGroup_name}' successfully!")
+    print(f"✅ Andmekonveier '{processorGroup_name}' on edukalt ka Nifi platvormile paigaldatud!")