summaryrefslogtreecommitdiff
path: root/modules/nifi/core.py
diff options
context:
space:
mode:
authorRasmus Luha <rasmus.luha@ut.ee>2025-05-11 23:30:25 +0300
committerRasmus Luha <rasmus.luha@ut.ee>2025-05-11 23:30:25 +0300
commitaad1cf42f85eb1a2e2a34bf997a03f2941ec99de (patch)
tree0a20e566a0cf7b42765caf000bdfd04ae7099d67 /modules/nifi/core.py
parent0cdd22fd88b00bc939eac7824bb1063f675cba84 (diff)
add comments
Diffstat (limited to 'modules/nifi/core.py')
-rw-r--r--modules/nifi/core.py15
1 files changed, 15 insertions, 0 deletions
diff --git a/modules/nifi/core.py b/modules/nifi/core.py
index 6eddbad..5c15837 100644
--- a/modules/nifi/core.py
+++ b/modules/nifi/core.py
@@ -19,6 +19,18 @@ def introduction():
def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_url, api_username, api_password):
+ """
+ data_values: valitud andmeväljad, mida konveier filtreerib
+ scedulingPeriod: kui tihti konveier jookseb
+ new_pipeline_name: uue konveieri nimi
+ api_url: andmete tõmbamise API url
+ api_username: Olemasolu korral API kasutaja nimi
+ api_parool: Olemasolu korral API kasutaja parool
+
+ Teeb mallis kõik vajalikud muudatused andmekonveieri valmimiseks
+ """
+
+
############### Choosing and modfyfing Template ##############
### Check if splitJson template needed
@@ -91,6 +103,9 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_
def build_pipeline():
+ """
+ Ehitab andmekonveieri kokku ning paigaldab soovi korral ka platvormile
+ """
if config.INTERACTIVE_MODE:
data_values, api_url, api_username, api_password= common.get_data_values()