diff options
author | Rasmus Luha <rasmus.luha@ut.ee> | 2025-05-11 23:30:25 +0300 |
---|---|---|
committer | Rasmus Luha <rasmus.luha@ut.ee> | 2025-05-11 23:30:25 +0300 |
commit | aad1cf42f85eb1a2e2a34bf997a03f2941ec99de (patch) | |
tree | 0a20e566a0cf7b42765caf000bdfd04ae7099d67 /modules/nifi/core.py | |
parent | 0cdd22fd88b00bc939eac7824bb1063f675cba84 (diff) |
add comments
Diffstat (limited to 'modules/nifi/core.py')
-rw-r--r-- | modules/nifi/core.py | 15 |
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() |