áááºá¹ááá¬áá«áá°ááá¯ááºážá¡ááœááº!
áá¯ááºáá±á¬ááºá
áá¬ááŸá¬ á¡á±á¬ááºáá«á¡ááá¯ááºážááŒá
áºááẠ- á¡áááºáá¯á¶ááœááºááŒáá¬ážááá·áº flow áá
áºáá¯ááŸáááŒá®áž N server áá»á¬ážáᶠááŒáá·áºáá»ááºáááºááá¯á¡ááºáá«áááºá . á
á®ážáááºážááŸá¯á
ááºážáááºááŸá¯ - ááá¯ááºáá
áºáá¯ááᯠáá¯ááºáá±ážáá±ááŒá®áž á¡ááŒá¬áž NiFi á¥ááá¬ááá¯á· áá±ážááá¯á·áá±áá«áááºá NiFi Site á០Site protocol ááᯠá¡áá¯á¶ážááŒá¯á áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŸá¯ ááŒá
áºáá±á«áºáá«áááºá
NiFi Site to Site (S2S) ááẠNiFi instances áá»á¬ážá¡ááŒá¬áž áá±áá¬ááœáŸá²ááŒá±á¬ááºážááẠáá¯á¶ááŒá¯á¶ááŒá®áž á
áááºááŒáá¯ááºááŒááºáááºááá¯ááºáá±á¬ áááºážáááºážáá
áºáá¯ááŒá
áºáááºá S2S á¡áá¯ááºáá¯ááºáá¯á¶ááá¯ááŒáá·áºáá«á S2S ááá¯ááœáá·áºááŒá¯ááẠNiFi instance ááᯠconfigure áá¯ááºááẠááá±á·ááẠá¡áá±ážááŒá®ážáá«áááºá .
S2S ááá¯á¡áá¯á¶ážááŒá¯á áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááŸáá·áºáááºáááºáá¬áá»áŸáẠá¥ááá¬áá áºáá¯ááᯠclient áá¯áá±á«áºáááºá áá¯áááááẠserver áá áºáá¯ááŒá áºáááºá client á data ááá¯á·áááºá server á áááºáá¶áááºá áááºážááá¯á·á¡ááŒá¬áž áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠáááºááŸááºááẠáááºážáááºážááŸá áºááœááº
- ááœááºážááá¯áž. Remote Process Group (RPG) ááᯠá¡áá¯á¶ážááŒá¯á client instance ááŸáá±áá¬ááᯠáá±ážááá¯á·áá«áááºá server instance ááœáẠInput Port ááᯠá¡áá¯á¶ážááŒá¯á áá±áá¬ááᯠáááºáá¶áááŸááá«áááºá
- ááœá²áá«. áá¬áá¬ááẠRPG ááᯠá¡áá¯á¶ážááŒá¯á áá±áá¬ááᯠáááºáá¶áááŸááááºá client ááẠOutput port ááᯠá¡áá¯á¶ážááŒá¯á áá±ážááá¯á·áááºá
rolling á¡ááœáẠFlow ááᯠApache Registry ááœáẠááááºážáááºážáá¬ážáááºá
Apache NiFi Registry ááẠflow storage ááŸáá·áº versioning tool ááá¯áá¶á·ááá¯ážáá±ážáá±á¬ Apache NiFi á subproject áá
áºáá¯ááŒá
áºáááºá GIT áá
áºáá»áá¯ážá ááŸááºáá¯á¶áááºááŒááºážá ááá·áºááœááºážááŒááºážá ááŒááºáááºááŒááºážááŸáá·áº áá¯ááºáá±á¬ááºááŒááºážááá¯ááºáᬠá¡áá»ááºá¡áááºáá»á¬ážááᯠááœáẠááœá±á·ááá¯ááºáá«áááºá . ááá¯ááŸá±á¬ááºááŸá¯á¡ááœáẠá
á®ážáááºážááŸá¯ááᯠáá¯ááºáááºážá
ááºá¡á¯ááºá
á¯áá
áºáá¯á¡ááŒá
Ạáá±á«ááºážá
ááºáá¬ážááŒá®áž á€áá±á¬ááºááœáẠááŸááºáá¯á¶áááºááŸá¯ááœáẠááááºážáááºážáá¬ážáááºá áá»áœááºá¯ááºááá¯á·ááẠá€áá±á¬ááºážáá«ážááᯠáá±á¬ááºááá¯ááºážááœáẠááŒááºáááºáá±á¬áºááŒáá«áááºá
á¡á
ááœááºá N ááẠáá±ážáááºáá±á¬á¡áá«á á
á®ážáááºážááŸá¯ááᯠááá·áºáá»á±á¬áºáá±á¬á¡áá»áááºá¡ááœááºáž áááºááŒáá·áºáá±ážááá¯á·ááŒá®áž á¡ááºááááºáá¯ááºáá«áááºá
ááá¯á·áá±á¬áº N ááŒá®ážááœá¬ážáá¬áááºááŸáá·áºá¡áá»áŸ ááŒá¿áá¬áá»á¬áž ááá¯áá»á¬ážáá¬áááºá
- flow ááᯠupdate áá¯ááºááẠá¡áá»áááºááá¯ááŒá¬áááºá áá¬áá¬áá»á¬ážá¡á¬ážáá¯á¶ážááá¯á· áááºááœá¬ážáááºááá¯á¡ááºáááºá
- ááá°áá¬áá¯á¶á á¶áá»á¬ážááᯠá¡ááºááááºáá¯ááºáá¬ááœáẠá¡ááŸá¬ážá¡ááœááºážáá»á¬ážááŸááááºá áá®ááŸá¬ áá°ááá¯á· ááœááºážáá¶áá¬ážáá±ááá·áº áá®ááŸá¬ áá±á·ááœá¬ážááŒáááºá
- á¡áá¬ážáá° áá¯ááºáá±á¬ááºáá»ááºáá»á¬ážá áœá¬ááᯠáá¯ááºáá±á¬ááºáá±á¬á¡áá«ááœáẠáá°áá¬ážá¡ááŸá¬ážáá»á¬áž
á€á¡áá¬á¡á¬ážáá¯á¶ážááẠáá¯ááºáááºážá ááºááᯠá¡ááá¯á¡áá»á±á¬ááºáá¯ááºáá±á¬ááºááẠááá¯á¡ááºáááºáá°áá±á¬á¡áá»ááºááᯠáá»áœááºá¯ááºááá¯á·áᶠáá°áá±á¬ááºáá¬áá«áááºá á€ááŒá¿áá¬ááá¯ááŒá±ááŸááºážááẠá¡á±á¬ááºáá«áááºážáááºážáá»á¬ážááᯠáá»áœááºá¯ááºááŒáá¯ážá á¬ážáá¬ážáá«áááºá
- NiFi á¡á á¬áž MiNiFi ááá¯áá¯á¶ážáá«á
- NiFi CLI
- NiPyAPI
MiNiFi ááá¯á¡áá¯á¶ážááŒá¯ááŒááºážá
Apache NiFi á ááá±á¬áá»ááºááœá²áá áºáá¯ááŒá áºáááºá MiNiFy ááẠNiFi áá²á·ááá¯á·áá°áá®áá±á¬áááá¯áááºáá¬áá»á¬ážááá¯á¡áá¯á¶ážááŒá¯ááá·áºáá»á áºáá»á áºáá±á¬á¡á±ážáá»áá·áºáá áºáá¯ááŒá áºááŒá®áž NiFi ááœááºáá²á·ááá¯á·áá°áá®áá±á¬á á®ážáááºážááŸá¯ááá¯áááºáá®ážááá¯ááºá á±áááºá MiNiFy ááẠflow configuration á¡ááœáẠgraphical interface áááŸááá±á¬ááŒá±á¬áá·áº á¡á±ážáá»áá·áºáá¡áááºážááẠá¡ááŒá¬ážá¡áá¬áá»á¬ážááŒá¬ážááœáẠáááŸááááºá MiNiFy á graphical interface áááŸáááŒááºážááẠminifi ááœáẠflow delivery ááŒá¿áá¬ááᯠááŒá±ááŸááºážááẠááá¯á¡ááºáááºáᯠááá¯ááá¯áááºá MiNiFy ááᯠIOT ááœááºáááºááŒáœá áœá¬á¡áá¯á¶ážááŒá¯áá¬ážáá±á¬ááŒá±á¬áá·áºá á¡á áááºá¡ááá¯ááºážáá»á¬ážá áœá¬áá«ááŸáááŒá®áž áá±á¬ááºáá¯á¶ážá¡áá±ážá á¬ážá¡áá±ážá áááºááŒá áºáááºáá»á¬ážááá¯á· á á®ážáááºážááŸá¯áá±ážááá¯á·ááŒááºážáá¯ááºáááºážá ááºááẠá¡ááá¯á¡áá»á±á¬ááºáá¯ááºáá±á¬ááºááááºááŒá áºáááºá áááºážááŸá®ážááŒá®ážáá¬áž á¡áá¯ááºáá áºáᯠááá¯ááºáá¬ážá
á¡ááŒá¬ážááá±á¬áá»ááºááœá²ááẠá€ááŒá¿áá¬ááᯠááŒá±ááŸááºážááẠáá°áá®áá±ážáááá·áºááẠ- MiNiFi C2 Serverá á€áá¯ááºáá¯ááºááẠááŒáá·áºáá»ááºáááºáá±á¬ááºááŸá¯ááœáẠá¡áááá¡áá»ááºááŒá áºááẠáááºááœááºáá«áááºá áááºâáááºážáá»ááºâááᯠconfigure áá¯ááºâáááºáž - ááœááºâáá±á¬áºááŒáá¬ážáááºâ Habré ááŸáá·áº áááºáááºáá±á¬ á¡áá»ááºá¡áááºáá»á¬ážááẠááŒá¿áá¬ááᯠááŒá±ááŸááºážááẠáá¯á¶áá±á¬ááºáá«áááºá MiNiFi ááẠC2 áá¬áá¬ááŸáá·áº ááœá²áááºá áááºážáááœá²á·á ááºážáá¯á¶ááᯠá¡ááá¯á¡áá»á±á¬áẠá¡ááºááááºáá¯ááºáááºá á€áá»ááºážáááºááŸá¯ááá áºáá¯áááºážáá±á¬á¡á¬ážáááºážáá»ááºááŸá¬ C2 Server ááœáẠtemplates áá»á¬ážáááºáá®ážáááºááŒá áºáááºá registry ááá¯ááá¯ážááŸááºážá áœá¬áá¯ááºáá±á¬ááºááŒááºážáááºááá¯á¶áá±á¬ááºáá«á
á¡áááºáá±á¬áºááŒáá« áá±á¬ááºážáá«ážááœáẠáá±á¬áºááŒáá¬ážááá·áº ááœá±ážáá»ááºááŸá¯ááẠá¡áá¯ááºáá¯ááºá á¡áá±á¬ááºá¡áááºáá±á¬áºááẠááááºáá²áá±á¬áºáááºáž á¡á±á¬ááºáá«ááá¯á·ááᯠááá±á·ááá·áºáá«á
- minifi ááœáẠnifi á០áááá¯áááºáá¬á¡á¬ážáá¯á¶áž áááŸááá«á
- MiniFi ááŸá CPU áá¬ážááŸááºážáá»á¬ážááẠNiFi ááŸá CPU áá¬ážááŸááºážáá»á¬ážááẠáá±á¬ááºáá»áá±áá«áááºá
áá±ážáá¬ážáá»áááºááœáẠNiFi á áá±á¬ááºáá¯á¶ážáá¬ážááŸááºážááŸá¬ 1.9.2 ááŒá áºáááºá áá±á¬ááºáá¯á¶ážááœáẠMiNiFi áá¬ážááŸááºážá áááá¯áááºáá¬áá¬ážááŸááºážááŸá¬ 1.7.0 ááŒá áºáááºá áááá¯áááºáá¬áá»á¬ážááᯠMiNiFi ááá¯á· ááá·áºááœááºážááá¯ááºáá±á¬áºáááºáž NiFi ááŸáá·áº MiNiFi áááá¯áááºáá¬áá»á¬ážá¡ááŒá¬áž áá¬ážááŸááºážááœá²ááœá²ááŸá¯áá»á¬ážááŒá±á¬áá·áº áááºážááẠá¡áá¯ááºáááŒá áºááá¯ááºáá«á
NiFi CLI
á¡á¬ážááŒááºá·á á®áááºáá±á¬áº ááá¬ážáááºáááºááá¯ááºááŸááááááá¬á áááºážááẠá á®ážáááºážááŸá¯áá±ážááá¯á·ááŒááºáž ááá¯á·ááá¯áẠáá¯ááºáááºážá ááºá á®áá¶ááá·áºááœá²ááŸá¯áááºáááºááœáẠNiFI ááŸáá·áº NiFi Registry á¡ááŒá¬áž á¡ááŒááºá¡ááŸááºá¡áá»áá¯ážáááºáá±á¬ááºááŸá¯ááᯠá¡ááá¯á¡áá»á±á¬ááºáá¯ááºáá±á¬ááºááá·áºáááááá¬áá áºáá¯ááŒá áºáááºá á áááºááẠá€áááááá¬ááᯠáá±á«ááºážáá¯ááºáá¯ááºáá«á .
utility ááá¯ááœáá·áºáá«á
./bin/cli.sh
_ ___ _
Apache (_) .' ..](_) ,
_ .--. __ _| |_ __ )
[ `.-. | [ |'-| |-'[ | /
| | | | | | | | | | ' '
[___||__][___][___] [___]', ,'
`'
CLI v1.9.2
Type 'help' to see a list of available commands, use tab to auto-complete.
ááŸááºáá¯á¶áááºááŒááºážá០ááá¯á¡ááºáá±á¬ á á®ážáááºážááŸá¯ááᯠáá»áœááºá¯ááºááá¯á·á¡á¬áž áááºááá¯ááºá á±áááºá¡ááœáẠááŒááºážáá±á¬ááºáž (bucket identifier) ââââááŸáá·áº á á®ážáááºážááŸá¯ááá¯ááºááá¯áẠ(flow identifier) ââááᯠááááŸáááẠááá¯á¡ááºáá«áááºá á€áá±áá¬ááᯠcli ááŸáááá·áº ááá¯á·ááá¯áẠNiFi ááŸááºáá¯á¶áááºááŒááºážáááºá¡ááºáá¬áá±á·á áºááœáẠáá±á¬áºáááºážáá±á¬ááºáž ááá°ááá¯ááºáááºá áááºá¡ááºáá¬áá±á·á áºááẠá€áá²á·ááá¯á· ááŒá áºáááº-
CLI ááᯠá¡áá¯á¶ážááŒá¯á áááºá€ááá¯á·áá¯ááºáá±á¬ááºáááº-
#> registry list-buckets -u http://nifi-registry:18080
# Name Id Description
- -------------- ------------------------------------ -----------
1 test_bucket 709d387a-9ce9-4535-8546-3621efe38e96 (empty)
#> registry list-flows -b 709d387a-9ce9-4535-8546-3621efe38e96 -u http://nifi-registry:18080
# Name Id Description
- ------------ ------------------------------------ -----------
1 test_flow d27af00a-5b47-4910-89cd-9c664cd91e85
áá»áœááºá¯ááºááá¯á·ááẠááŸááºáá¯á¶áááºááŒááºážá០áá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠá áááºáááºááœááºážáááº-
#> nifi pg-import -b 709d387a-9ce9-4535-8546-3621efe38e96 -f d27af00a-5b47-4910-89cd-9c664cd91e85 -fv 1 -u http://nifi:8080
7f522a13-016e-1000-e504-d5b15587f2f3
á¡áá±ážááŒá®ážáá±á¬á¡áá»ááºááŸá¬ áá»áœááºá¯ááºááá¯á·ááẠáá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠááŸááá·áºáá±ážáá±á¬ nifi instance ááŸááºááá»áŸááᯠhost á¡ááŒá ẠáááºááŸááºááá¯ááºáááºá
áááºáá¬ážáá±á¬ áááá¯áááºáá¬áá»á¬ážááŒáá·áº ááá·áºááœááºážáá¬ážáá±á¬ áá¯ááºáááºážá ááºá¡á¯ááºá á¯á áááºážááá¯á·ááᯠá áááºááẠááá¯á¡ááºáááºá
#> nifi pg-start -pgid 7f522a13-016e-1000-e504-d5b15587f2f3 -u http://nifi:8080
áá±á¬ááºážááŒá®á áááá¯áááºáá¬áá»á¬ážá áááºáá«ááŒá®á ááá¯á·áá±á¬áºá ááŒá¿áá¬áá¡ááŒá±á¡áá±áá»á¬ážá¡áá áá»áœááºá¯ááºááá¯á·ááẠá¡ááŒá¬ážááŒá áºáááºáá»á¬ážááá¯á·áá±áá¬áá±ážááá¯á·ááẠNiFi instances ááá¯á¡ááºáá«áááºá áá¬áá¬ááá¯á·áá±áá¬ááœáŸá²ááŒá±á¬ááºážááẠPush áááºážáááºážááᯠááœá±ážáá»ááºáá²á·áááºáᯠáá°áááŒáá«á áá¯á·á áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠá á¯á ááºážáááºá¡ááœááºá áá»áœááºá¯ááºááá¯á·áá á®ážáááºážááŸá¯ááœáẠáá«ááŒá®ážáá¬ážááŒá áºááá·áº Remote Process Group (RPG) ááœáẠáá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºáž (Enable transmitting) ááᯠááœáá·áºáá¬ážááẠááá¯á¡ááºáá«áááºá
CLI ááŸáá·áº á¡ááŒá¬ážáááºážááŒá
áºáá»á¬ážááŸá á
á¬ááœááºá
á¬áááºážáá»á¬ážááœáẠáá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠááœáá·áºááẠáááºážáááºážááŸá¬áááœá±á·áá«á áá«ááᯠáááºááá¯áá¯ááºáááá² ááááẠcomment ááŸá¬ áá±ážáá±ážáá«á
áá«ááá¯á·ááŸá¬ bash ááŸáááŒá®áž á¡áá¯á¶ážááá¯ááœá¬ážááá¯á· á¡áááºááá·áºááŒá áºáá±ááŒá®ááá¯áá±á¬á· ááœááºáááºážááŸá¬áááºá á€ááŒá¿áá¬ááá¯ááŒá±ááŸááºážááẠNiFi API ááá¯áá¯á¶ážááá¯ááºáááºá á¡á±á¬ááºáá«áááºážáááºážááá¯áá¯á¶ážááŒáá«á áá¯á·á á¡áááºáá±á¬áºááŒáá«á¥ááá¬áá»á¬ážá០ID ááá¯áá°áá« (áá»áœááºá¯ááºááá¯á·áááá á¹á ááœááºáááºážááẠ7f522a13-016e-1000-e504-d5b15587f2f3)á NiFi API Methods á ááŸááºážáááºážáá»áẠ.
ááá¹áá¬ááá¯ááºááœááºá áááºááẠá¡á±á¬ááºáá«áá¯á¶á
á¶á០JSON ááᯠáá»á±á¬áºááŒááºááẠááá¯á¡ááºáááº-
{
"revision": {
"clientId": "value",
"version": 0,
"lastModifier": "value"
},
"state": "value",
"disconnectedNodeAcknowledged": true
}
"á¡áá¯ááº" áááºá¡ááœáẠááŒáá·áºá
áœááºáááá·áº áá±á¬ááºáá»á¬áž-
ááŒááºááẠ- áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŸá¯á¡ááŒá±á¡áá±á áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠááœáá·áºááẠááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠáááŸáááá¯ááºáááºá ááááºááẠáááºááá·áºáá²á·áááºá
áá¬ážááŸááºáž - áááá¯áááºáá¬áá¬ážááŸááºáž
áááºáá®ážááá·áºá¡áá« áá¬ážááŸááºážááẠ0 ááá¯á· áá¯á¶áá±ááŒá áºáááá·áºáááºá ááá¯á·áá±á¬áº á€áá±á¬ááºáá»á¬ážááᯠáááºážáááºážááŒáá·áº ááá°ááá¯ááºáááºá
bash script áá»á¬ážááá¯ááŸá
áºáááºáá°áá»á¬ážá¡ááœááºá á€áááºážáááºážááẠááá·áºáá»á±á¬áºáááºáá¯áááºááá±á¬áºáááºáž áá»áœááºá¯ááºá¡ááœáẠáááºáá²ááẠ- bash script áá»á¬ážááẠáá»áœááºá¯ááºá¡ááŸá
áºáááºáá¯á¶ážááá¯ááºáá±á áá±á¬ááºáá
áºáááºážá ááá¯á
áááºáááºá
á¬ážááŒá®áž ááá¯á¡áááºááŒá±áááºáááºáááºá
NiPyAPI
NiPyAPI ááẠNiFi ááŒá áºáááºáá»á¬ážááŸáá·áº á¡ááŒááºá¡ááŸááºáá¯á¶á·ááŒááºáááºá¡ááœáẠPython á á¬ááŒáá·áºááá¯ááºáá áºáá¯ááŒá áºáááºá á á¬ááŒáá·áºááá¯ááºááŸáá·áº á¡áá¯ááºáá¯ááºááẠááá¯á¡ááºáá±á¬ á¡áá»ááºá¡áááºáá»á¬áž áá«ááŸááááºá á¡ááŒááºá áááºááŒááºážááᯠááœáẠáá±á¬áºááŒáá¬ážáá«áááºá github ááœááº
ááŒááºáááºáááºááŸááºááŸá¯á¡ááœáẠáá»áœááºá¯ááºááá¯á·á script ááẠPython áááá¯ááááºáá
áºáá¯ááŒá
áºáááºá Coding ááᯠáááºááœá¬ážáá¡á±á¬ááºá
áá±á¬ááºáááºá¡áá¯ááºá¡ááœáẠconfigs ááá¯áááºááŸááºáá«á áá»áœááºá¯ááºááá¯á·ááẠá¡á±á¬ááºáá« parameters áá»á¬ážááᯠááá¯á¡ááºáá«áááº-
nipyapi.config.nifi_config.host = 'http://nifi:8080/nifi-api' #пÑÑÑ ÐŽÐŸ nifi-api ОМÑÑаМÑа, Ма кПÑПÑПЌ ÑазвПÑаÑОваеЌ process group
nipyapi.config.registry_config.host = 'http://nifi-registry:18080/nifi-registry-api' #пÑÑÑ ÐŽÐŸ nifi-registry-api registry
nipyapi.config.registry_name = 'MyBeutifulRegistry' #МазваМОе registry, как бÑÐŽÐµÑ ÐœÐ°Ð·ÑваÑÑÑÑ Ð² ОМÑÑаМÑе nifi
nipyapi.config.bucket_name = 'BucketName' #МазваМОе bucket, Оз кПÑПÑПгП пПЎÑÑгОваеЌ flow
nipyapi.config.flow_name = 'FlowName' #МазваМОе flow, кПÑПÑПе пПЎÑÑгОваеЌ
áááºáááºá áá±á¬áºááŒáá¬ážáá±á¬ á€á á¬ááŒáá·áºááá¯ááºá áááºážáááºážáá»á¬ážá á¡áááºáá»á¬ážááᯠáá»áœááºá¯áẠááá·áºááœááºážáá«áááºá .
ááŸááºáá¯á¶áááºááŒááºážááᯠá¡áá¯á¶ážááŒá¯á nifi instance ááá¯á· áá»áááºáááºáá«á
nipyapi.versioning.create_registry_clientá€á¡ááá·áºááœááºá áááºááẠregistry ááᯠáá¬ááááœáẠááá·áºááœááºážáá¬ážááŒá®ážááŒá áºááŒá±á¬ááºáž á á áºáá±ážááŸá¯ááá¯áááºáž ááá·áºááœááºážááá¯ááºáááºá áááºážá¡ááœáẠáááºááẠáááºážáááºážááᯠá¡áá¯á¶ážááŒá¯ááá¯ááºáááºá
nipyapi.versioning.list_registry_clientsááŒááºážáá±á¬ááºážáá²ááŸá á á®ážáááºážááŸá¯ááᯠáááºáá¶ááŸá¬ááœá±ááẠáá±áá¯á¶ážááᯠááŸá¬áááºá
nipyapi.versioning.get_registry_bucketááœá±á·ááŸááá±á¬áá¯á¶ážááᯠá¡áá¯á¶ážááŒá¯á áá»áœááºá¯ááºááá¯á·ááẠá á®ážáááºážááŸá¯ááᯠááŸá¬ááœá±áááºá
nipyapi.versioning.get_flow_in_bucketááá¯á·áá±á¬ááºá á€áá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠááá·áºááœááºážááŒá®ážááŒá áºáááŒá Ạáá¬ážáááºááẠá¡áá±ážááŒá®ážáá«áááºá áá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠááŒááááááºáá»á¬ážááŒáá·áº áá±áá¬áá»áᬠáá¯ááááá áºáá¯ááᯠáá áºáá¯áá¡áá±á«áºááœáẠá¡á¯ááºáá¬ážáá±á¬á¡áá« á¡ááŒá±á¡áá±áá áºáᯠááŒá áºáá±á«áºáá¬ááá¯ááºáááºá áá«á á áºáá±ážáá²á·áááºá áááºážáááºááŒá áºááá¯ááºááẠð áá±á«ááºážááá·áºáá¬ážáá±á¬áá¯ááºáááºážá ááºá¡á¯ááºá á¯á¡á¬ážáá¯á¶ážááá¯ááá°áááºáááºážáááºážááá¯á¡áá¯á¶ážááŒá¯áá«á
nipyapi.canvas.list_all_process_groupsááá¯á·áá±á¬áẠá¥ááá¬á¡á¬ážááŒáá·áºá á¡áááºááŒáá·áº ááŸá¬ááœá±ááá¯ááºáááºá
áááºážáááááºááᯠá¡ááºááááºáá¯ááºááŒááºáž áá¯ááºáááºážá ááºááᯠáá»áœááºá¯áẠáá±á¬áºááŒáááºááá¯ááºáá«á áááá¯áááºáá¬áá»á¬ážááᯠááá°áá¬áá¯á¶á á¶á áá¬ážááŸááºážá¡áá áºááœáẠááá·áºááœááºážáá«á áááºážá á®á á¬áá»á¬ážááœáẠáááºáá±á·áá»áºáá»á¬áž ááŸááá±ááŒááºážá¡ááœáẠááŒá¿áá¬áááŸááá¯áᬠááŒá±á¬áá«áááºá ááá¯á·áá±á¬áº áááá¯áááºáá¬áá»á¬ážááᯠáááºááŸá¬ážááá¯ááºáá»áŸáẠááŒá¿áá¬áá»á¬áž ááŒá áºáá±á«áºáá¬ááá¯ááºááẠ(áááºážáááŸá±á·ááœáẠáááºáá±á·áá»áºáááºážá á®áá áºáᯠá á¯áá±á¬ááºážáááá«á nifi ááẠáááá¯áááºáá¬á¡á¬áž áááºááŸá¬ážááŒááºážááᯠááœáá·áºáááŒá¯áá«)á á€ááŒá¿áá¬ááᯠáá»áœááºá¯ááºáááºáá²á·ááá¯á· ááŒá±ááŸááºážááááºááᯠáááºá áááºáááºá á¬ážáá«á áá»áœááºá¯ááºáᶠá á¬áá±ážáá«á á€á¡áá»ááºááᯠááœá±ážááœá±ážáá«áááºá áá±á¬ááºážáá«ážáá¡áá¯á¶ážááœááºá¡áááºá¡ááœááºáá»á¬ážá áá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠááá·áºááŒááºážá¡ááá·áºááá¯á· áááºááœá¬ážááŒáá«á áá¯á·á
áá¬ááºááœáŸááºážááᯠá¡ááŸá¬ážááŸá¬ááŒááºááá·áºá¡áá«á áá±á¬ááºáá¯á¶ážááœáẠáá¬ážááŸááºážááᯠá¡ááŒá²ááœá²ááá¬ážáá±á¬ á¡ááºá¹áá«áááºáá áºáá¯ááᯠááœá±á·ááá¯ááºááá±á¬ááŒá±á¬áá·áº á€áá¬ážááŸááºážááᯠáŠážá áœá¬ááŸááºážáááºážááẠá¡ááŒá¶ááŒá¯ááá¯áá«áááºá
nipyapi.versioning.get_latest_flow_veráá¯ááºáááºážá ááºá¡ááœá²á·ááᯠá¡áá¯á¶ážáá»áá«-
nipyapi.versioning.deploy_flow_versionáá»áœááºá¯ááºááá¯á·ááẠáááá¯áááºáá¬áá»á¬ážááᯠá áááºáááº-
nipyapi.canvas.schedule_process_groupCLI á¡ááŒá±á¬ááºáž ááá±á¬ááºááœááºá á¡áá±ážááááºážáá¯ááºáááºážá ááºá¡á¯ááºá á¯ááœáẠáá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠá¡ááá¯á¡áá»á±á¬ááºááœáá·áºááá¬ážáᯠáá±ážáá¬ážáá²á·áááºá áá¬ááºááœáŸááºážááᯠá¡áá±á¬ááºá¡áááºáá±á¬áºáá²á·á¡áá«ááŸá¬áááºáž áá®ááŒá¿áá¬ááᯠááŒá¯á¶ááœá±á·áá²á·ááá«áááºá ááá¯á¡áá»áááºááœááºá áá»áœááºá¯ááºááẠAPI ááá¯á¡áá¯á¶ážááŒá¯á áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŒááºážááᯠáá áááºááá¯ááºáá±á¬á·áá² NiPyAPI á á¬ááŒáá·áºááá¯ááºá áá±á¬á·ááºáá²áá±ážáá¬ážáá°áᶠá á¬áá±ážááŒá®áž á¡ááŒá¶áá¬ááº/á¡áá°á¡áá®áá±á¬ááºážááẠáá¯á¶ážááŒááºáá²á·áááºá áá±á¬á·ááºáá²áá±ážáá¬ážáá°á áá»áœááºá¯ááºá¡á¬áž ááŒááºááŒá±á¬áááºá áá»áœááºá¯ááºááá¯á·ááẠááŒá¿áá¬ááᯠááœá±ážááœá±ážáá²á·ááŒá®áž áá áºá á¯á¶áá áºáá¯ááᯠá á áºáá±ážááẠá¡áá»áááºááá¯á¡ááºááŒá±á¬ááºáž áá°áá±ážáá¬ážáá²á·áááºá ááᯠááŸá áºáááºá¡ááŒá¬ááœáẠáá»áœááºá¯ááºá startup ááŒá¿áá¬ááᯠááŒá±ááŸááºážáá±ážááá·áº Python áá¯ááºáá±á¬ááºáá»ááºááᯠáá±ážáá¬ážáá¬ážááá·áº á¡á®ážáá±ážááºáá áºáᯠáá±á¬ááºááŸááá¬áá«áááºá ááá¯á¡áá»áááºááœáẠNiPyAPI áá¬ážááŸááºážááẠ0.13.3 ááŒá áºááŒá®ážá áááºážááœáẠáááºááá·áºá¡áá¬áá»áŸ áááŸááá«á ááá¯á·áá±á¬áº áááŒá¬áá±ážáá®áááœááºááŸááá²á·áá±á¬ áá¬ážááŸááºáž 0.14.0 ááœááºá á€áá¯ááºáá±á¬ááºáá»ááºááᯠá á¬ááŒáá·áºááá¯ááºááœáẠááá·áºááœááºážáá¬ážááŒá®ážááŒá áºáááºá áá¯á¶áááºá
nipyapi.canvas.set_remote_process_group_transmissionááá¯á·ááŒá±á¬áá·áº NiPyAPI á á¬ááŒáá·áºááá¯ááºáá¡áá°á¡áá®ááŒáá·áºá áá»áœááºá¯ááºááá¯á·ááẠregistry ááá¯áá»áááºáááºáᬠá á®ážáááºážááŸá¯ááᯠááŸááá·áºáá±ážáᬠáááá¯áááºáá¬áá»á¬ážááŸáá·áº áá±áá¬ááœáŸá²ááŒá±á¬ááºážááŸá¯áá»á¬ážááá¯ááẠá áááºáá²á·áááºá ááá¯á·áá±á¬áẠáááºááẠáá¯ááºááᯠááŒá®ážáá¬á á á áºáá±ážááŸá¯ á¡áá»áá¯ážáá»áá¯ážááᯠáá±á«ááºážááá·áºááá¯ááºáááºá ááŸááºáááºážáá°ááá¯ááºáááºá áá«áááºá áá«áá±ááá·áº á¡á²áá«á áá¯á¶ážáááŒá¬ážáá¬ážáá²á· áá¬ááºáááºážáá«á
áá«ááá·áºááœááºážá ááºážá á¬ážáá¬ážáá±á¬ automation ááœá±ážá áá¬áá»á¬ážáá²á០áá±á¬ááºáá¯á¶ážáá áºáá¯ááẠáá»áœááºá¯ááºá¡ááœáẠá¡áááá±á¬ááºáá¯á¶ážáᯠáááºááááºá ááááŠážá áœá¬á áááºááẠá¡áááºáááá¯ááááºáá¯ááºááᯠááá·áºááœááºážááŒá®áž áááá¯ááááºážáááºážáá¬áá¬á áá¬ážááᯠá¡ááŒáá·áºá¡áá¡áá¯á¶ážáá»ááá¯ááºááá·áº python áá¯ááºááŒá áºáá±áá²ááŒá áºáááºá áá¯áááá¡áá±ááŒáá·áºá NiPyAPI ááá±á¬áá»ááºááẠáááºááŒáœá áœá¬ááœá¶á·ááŒáá¯ážáá±ááŒá®áž ááŒá¿áá¬áá»á¬ážááŸááá«á developer áᶠá á¬áá±ážááá¯ááºáá«áááºá ááááá¡áá±ááŒáá·áºá NiPyAPI ááẠááŸá¯ááºááœá±ážáá±á¬ááŒá¿áá¬áá»á¬ážááá¯ááŒá±ááŸááºážáá¬ááœáẠNiFi ááŸáá·áºá¡ááŒááºá¡ááŸááºáááºáá¶áááºá¡ááœáẠááá¯áááŒá±á¬ááºážááœááºááŒááºááœááºááŸááá±áá²ááŒá áºáááºá á¥ááá¬á¡á¬ážááŒáá·áºá á á®ážáááºážááŸá¯ááœáẠáááºáá±á·áá»áºáááºážá á®áá»á¬ážááẠáááºááŸáááá¬ááŸááááŸáááŸáá·áº áá¯ááºáááºážá ááºá¡á¯ááºá á¯ááᯠá¡ááºááááºáá¯ááºááẠááŒá áºááá¯ááºáá»á±ááŸááááŸá áá¯á¶ážááŒááºáá¬ááœááºá
áá«áá«áá²á NiFi ááœáẠá¡ááá¯á¡áá»á±á¬áẠá
á®ážáááºážááŸá¯áá±ážááá¯á·ááŒááºážá¡ááœáẠáá»ááºážáááºááŸá¯ 3 áá¯ááᯠáá±á¬áºááŒáá²á·ááŒá®ážá developer áá
áºáŠážááŒá¯á¶ááœá±á·áááá¯ááºááá·áº á¡áá¹ááá¬ááºáá»á¬ážááŸáá·áº á¡ááá¯á¡áá»á±á¬ááºáá±ážááá¯á·ááŒááºážá¡ááœáẠá¡áá¯ááºáá¯ááºáá±á¬áá¯ááºáá
áºáá¯ááᯠáá¶á·ááá¯ážáá±ážáá¬ážáá«áááºá áá®á¡ááŒá±á¬ááºážá¡áá¬ááᯠá
áááºáááºá
á¬ážáááºááá¯áááºá
source: www.habr.com