ສະບາຍດີທຸກຄົນ!

ວຽກງານແມ່ນດັ່ງຕໍ່ໄປນີ້ - ມີການໄຫຼສະແດງໃຫ້ເຫັນໃນຮູບຂ້າງເທິງ, ເຊິ່ງຈໍາເປັນຕ້ອງໄດ້ rolled ອອກໄປຫາ N servers ກັບ. Apache NiFi. ການທົດສອບການໄຫຼ - ໄຟລ໌ກໍາລັງຖືກສ້າງຂື້ນແລະຖືກສົ່ງໄປຫາຕົວຢ່າງ NiFi ອື່ນ. ການໂອນຂໍ້ມູນເກີດຂຶ້ນໂດຍໃຊ້ NiFi Site to Site protocol.

NiFi Site to Site (S2S) ເປັນວິທີທີ່ປອດໄພ, ສາມາດປັບແຕ່ງໄດ້ສູງໃນການໂອນຂໍ້ມູນລະຫວ່າງ NiFi instances. ເບິ່ງວິທີການເຮັດວຽກຂອງ S2S ເອກະສານ ແລະມັນເປັນສິ່ງສໍາຄັນທີ່ຈະຈື່ຈໍາທີ່ຈະຕັ້ງຄ່າຕົວຢ່າງ NiFi ຂອງທ່ານເພື່ອອະນຸຍາດໃຫ້ S2S ເຫັນ ທີ່ນີ້.

ໃນເວລາທີ່ມັນມາກັບການໂອນຂໍ້ມູນໂດຍໃຊ້ S2S, ຕົວຢ່າງຫນຶ່ງເອີ້ນວ່າລູກຄ້າ, ທີສອງແມ່ນເຄື່ອງແມ່ຂ່າຍ. ລູກຄ້າສົ່ງຂໍ້ມູນ, ເຄື່ອງແມ່ຂ່າຍໄດ້ຮັບມັນ. ສອງ​ວິ​ທີ​ການ​ຕັ້ງ​ຄ່າ​ການ​ໂອນ​ຂໍ້​ມູນ​ລະ​ຫວ່າງ​ເຂົາ​ເຈົ້າ​:

1. Push. ຂໍ້​ມູນ​ຖືກ​ສົ່ງ​ຈາກ​ຕົວ​ຢ່າງ​ລູກ​ຄ້າ​ໂດຍ​ການ​ນໍາ​ໃຊ້ Remote Process Group (RPG). ໃນຕົວຢ່າງເຊີບເວີ, ຂໍ້ມູນແມ່ນໄດ້ຮັບໂດຍໃຊ້ Input Port
2. ດຶງ. ເຊີບເວີໄດ້ຮັບຂໍ້ມູນໂດຍໃຊ້ RPG, ລູກຄ້າສົ່ງໂດຍໃຊ້ພອດ Output.

ການໄຫຼເຂົ້າສໍາລັບການມ້ວນແມ່ນເກັບໄວ້ໃນ Apache Registry.

Apache NiFi Registry ແມ່ນໂຄງການຍ່ອຍຂອງ Apache NiFi ທີ່ສະຫນອງການເກັບຮັກສາການໄຫຼເຂົ້າແລະເຄື່ອງມືສະບັບ. ປະເພດຂອງ GIT. ຂໍ້​ມູນ​ກ່ຽວ​ກັບ​ການ​ຕິດ​ຕັ້ງ​, ການ​ຕັ້ງ​ຄ່າ​ແລະ​ການ​ເຮັດ​ວຽກ​ກັບ​ການ​ຈົດ​ທະ​ບຽນ​ສາ​ມາດ​ພົບ​ເຫັນ​ຢູ່​ໃນ​ ເອກະສານທາງການ. Flow ສໍາລັບການເກັບຮັກສາແມ່ນລວມເຂົ້າກັນເປັນກຸ່ມຂະບວນການແລະເກັບຮັກສາໄວ້ໃນລີຈິດຊີໃນຮູບແບບນີ້. ພວກເຮົາຈະກັບຄືນໄປຫາເລື່ອງນີ້ຕໍ່ມາໃນບົດຄວາມ.

ໃນຕອນເລີ່ມຕົ້ນ, ເມື່ອ N ເປັນຈໍານວນນ້ອຍໆ, ການໄຫຼເຂົ້າໄດ້ຖືກສົ່ງແລະປັບປຸງດ້ວຍມືໃນເວລາທີ່ເຫມາະສົມ.

ແຕ່ເມື່ອ N ເຕີບໂຕ, ມີບັນຫາຫຼາຍ:

1. ມັນໃຊ້ເວລາຫຼາຍກວ່າທີ່ຈະປັບປຸງການໄຫຼເຂົ້າ. ທ່ານຈໍາເປັນຕ້ອງໄປຫາເຄື່ອງແມ່ຂ່າຍທັງຫມົດ
2. ມີຂໍ້ຜິດພາດໃນການປັບປຸງແມ່ແບບ. ທີ່ນີ້ພວກເຂົາປັບປຸງ, ແຕ່ໃນທີ່ນີ້ພວກເຂົາລືມ
3. ຄວາມຜິດພາດຂອງມະນຸດໃນເວລາທີ່ປະຕິບັດຈໍານວນຂະຫນາດໃຫຍ່ຂອງການດໍາເນີນງານທີ່ຄ້າຍຄືກັນ

ທັງຫມົດນີ້ນໍາພວກເຮົາໄປສູ່ຄວາມຈິງທີ່ວ່າມັນເປັນສິ່ງຈໍາເປັນເພື່ອອັດຕະໂນມັດຂະບວນການ. ຂ້ອຍໄດ້ພະຍາຍາມວິທີຕໍ່ໄປນີ້ເພື່ອແກ້ໄຂບັນຫານີ້:

1. ໃຊ້ MiNiFi ແທນ NiFi
2. NiFi CLI
3. NiPyAPI

ໃຊ້ MiNiFi

ApacheMiNify ແມ່ນໂຄງການຍ່ອຍຂອງ Apache NiFi. MiNiFy ແມ່ນຕົວແທນທີ່ຫນາແຫນ້ນທີ່ໃຊ້ໂປເຊດເຊີດຽວກັນກັບ NiFi, ຊ່ວຍໃຫ້ທ່ານສາມາດສ້າງການໄຫຼເຂົ້າດຽວກັນກັບ NiFi. ຄວາມສະຫວ່າງຂອງຕົວແທນແມ່ນບັນລຸໄດ້, ໃນບັນດາສິ່ງອື່ນໆ, ເນື່ອງຈາກຄວາມຈິງທີ່ວ່າ MiNiFy ບໍ່ມີການໂຕ້ຕອບຮູບພາບສໍາລັບການຕັ້ງຄ່າການໄຫຼ. ການຂາດການໂຕ້ຕອບແບບກາຟິກຂອງ MiNiFy ຫມາຍຄວາມວ່າມັນເປັນສິ່ງຈໍາເປັນເພື່ອແກ້ໄຂບັນຫາການສົ່ງກະແສໃນ minifi. ນັບຕັ້ງແຕ່ MiNiFy ຖືກນໍາໃຊ້ຢ່າງຫ້າວຫັນໃນ IOT, ມີຫຼາຍອົງປະກອບແລະຂະບວນການສົ່ງກະແສໄປຫາຕົວຢ່າງ minifi ສຸດທ້າຍຕ້ອງອັດຕະໂນມັດ. ວຽກທີ່ຄຸ້ນເຄີຍ, ບໍ່ແມ່ນບໍ?

ໂຄງການຍ່ອຍອື່ນ, MiNiFi C2 Server, ຈະຊ່ວຍແກ້ໄຂບັນຫານີ້. ຜະລິດຕະພັນນີ້ມີຈຸດປະສົງເພື່ອເປັນຈຸດສູນກາງໃນສະຖາປັດຕະຍະກໍາຂອງການນໍາໃຊ້. ວິທີການ configure ສະພາບແວດລ້ອມ - ອະທິບາຍໃນ ບົດຂຽນນີ້ ກ່ຽວກັບ Habre ແລະຂໍ້ມູນແມ່ນພຽງພໍທີ່ຈະແກ້ໄຂບັນຫາ. MiNiFi ສົມທົບກັບເຊີບເວີ C2 ປັບປຸງການຕັ້ງຄ່າຂອງມັນໂດຍອັດຕະໂນມັດ. ຂໍ້ບົກຜ່ອງພຽງແຕ່ຂອງວິທີການນີ້ແມ່ນວ່າທ່ານຕ້ອງສ້າງແມ່ແບບໃນ C2 Server, ສັນຍາງ່າຍໆກັບທະບຽນແມ່ນບໍ່ພຽງພໍ.

ທາງເລືອກທີ່ອະທິບາຍໄວ້ໃນບົດຄວາມຂ້າງເທິງແມ່ນເຮັດວຽກແລະບໍ່ຍາກທີ່ຈະປະຕິບັດ, ແຕ່ພວກເຮົາບໍ່ຄວນລືມສິ່ງຕໍ່ໄປນີ້:

1. minifi ບໍ່ມີໂປເຊດເຊີທັງຫມົດຈາກ nifi
2. ລຸ້ນ CPU ໃນ Minifi ຊ້າກວ່າລຸ້ນ CPU ໃນ NiFi.

ໃນເວລາຂຽນ, NiFi ຮຸ່ນຫຼ້າສຸດແມ່ນ 1.9.2. ໂປເຊດເຊີລຸ້ນ MiNiFi ຫຼ້າສຸດແມ່ນ 1.7.0. ໂປເຊດເຊີສາມາດຖືກເພີ່ມໃສ່ MiNiFi, ແຕ່ເນື່ອງຈາກຄວາມແຕກຕ່າງຂອງລຸ້ນລະຫວ່າງໂປເຊດເຊີ NiFi ແລະ MiNiFi, ນີ້ອາດຈະບໍ່ເຮັດວຽກ.

NiFi CLI

ຕັດສິນໂດຍ ລາຍລະອຽດ ເຄື່ອງມືຢູ່ໃນເວັບໄຊທ໌ທາງການ, ນີ້ແມ່ນເຄື່ອງມືສໍາລັບການອັດຕະໂນມັດການໂຕ້ຕອບລະຫວ່າງ NiFI ແລະ NiFi Registry ໃນຂົງເຂດການຈັດສົ່ງການໄຫຼຫຼືການຄຸ້ມຄອງຂະບວນການ. ດາວໂຫລດເຄື່ອງມືນີ້ເພື່ອເລີ່ມຕົ້ນ. ຈາກນີ້.

ດໍາເນີນການຜົນປະໂຫຍດ

./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 ຕົວມັນເອງ (ຕົວລະບຸການໄຫຼ). ຂໍ້​ມູນ​ນີ້​ສາ​ມາດ​ໄດ້​ຮັບ​ໂດຍ​ຜ່ານ 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

ຈຸດສໍາຄັນແມ່ນວ່າທຸກ instance nifi ສາມາດຖືກກໍານົດເປັນເຈົ້າພາບທີ່ພວກເຮົາມ້ວນກຸ່ມຂະບວນການ.

ກຸ່ມຂະບວນການເພີ່ມດ້ວຍໂປເຊດເຊີທີ່ຢຸດເຊົາ, ພວກເຂົາຕ້ອງໄດ້ຮັບການເລີ່ມຕົ້ນ

#> nifi pg-start -pgid 7f522a13-016e-1000-e504-d5b15587f2f3 -u http://nifi:8080

ຍິ່ງໃຫຍ່, ໂປເຊດເຊີໄດ້ເລີ່ມຕົ້ນແລ້ວ. ຢ່າງໃດກໍຕາມ, ອີງຕາມເງື່ອນໄຂຂອງບັນຫາ, ພວກເຮົາຕ້ອງການຕົວຢ່າງ NiFi ເພື່ອສົ່ງຂໍ້ມູນໄປຫາຕົວຢ່າງອື່ນໆ. ໃຫ້ສົມມຸດວ່າວິທີການ Push ໄດ້ຖືກເລືອກເພື່ອໂອນຂໍ້ມູນໄປຍັງເຄື່ອງແມ່ຂ່າຍ. ເພື່ອຈັດລະບຽບການໂອນຂໍ້ມູນ, ມັນຈໍາເປັນຕ້ອງເປີດໃຊ້ການໂອນຂໍ້ມູນ (ເປີດໃຊ້ການສົ່ງຂໍ້ມູນ) ໃນກຸ່ມຂະບວນການໄລຍະໄກ (RPG), ເຊິ່ງລວມຢູ່ໃນການໄຫຼຂອງພວກເຮົາ.

ໃນເອກະສານໃນ CLI ແລະແຫຼ່ງອື່ນໆ, ຂ້ອຍບໍ່ພົບວິທີທີ່ຈະເປີດໃຊ້ການໂອນຂໍ້ມູນ. ຖ້າທ່ານຮູ້ວິທີເຮັດແນວນີ້, ກະລຸນາຂຽນໃນຄໍາເຫັນ.

ເນື່ອງຈາກພວກເຮົາມີ bash ແລະພວກເຮົາພ້ອມທີ່ຈະໄປທີ່ສຸດ, ພວກເຮົາຈະຊອກຫາທາງອອກ! ທ່ານສາມາດນໍາໃຊ້ NiFi API ເພື່ອແກ້ໄຂບັນຫານີ້. ໃຫ້ໃຊ້ວິທີຕໍ່ໄປນີ້, ພວກເຮົາເອົາ ID ຈາກຕົວຢ່າງຂ້າງເທິງ (ໃນກໍລະນີຂອງພວກເຮົາມັນແມ່ນ 7f522a13-016e-1000-e504-d5b15587f2f3). ລາຍລະອຽດຂອງ NiFi API Methods ທີ່ນີ້.

ໃນຮ່າງກາຍ, ທ່ານຈໍາເປັນຕ້ອງຜ່ານ JSON, ຂອງແບບຟອມຕໍ່ໄປນີ້:

{
    "revision": {
	    "clientId": "value",
	    "version": 0,
	    "lastModifier": "value"
	},
    "state": "value",
    "disconnectedNodeAcknowledged": true
}

ພາລາມິເຕີທີ່ຕ້ອງຕື່ມໃສ່ເພື່ອ "ເຮັດວຽກ":
ລັດ - ສະ​ຖາ​ນະ​ພາບ​ການ​ໂອນ​ຂໍ້​ມູນ​. ມີ TRANSMITTING ເພື່ອເປີດໃຊ້ການໂອນຂໍ້ມູນ, STOPPED ເພື່ອປິດການໃຊ້ງານ
ສະບັບພາສາ - ຮຸ່ນໂປເຊດເຊີ

ຮຸ່ນຈະເລີ່ມຕົ້ນເປັນ 0 ເມື່ອສ້າງ, ແຕ່ຕົວກໍານົດການເຫຼົ່ານີ້ສາມາດໄດ້ຮັບໂດຍໃຊ້ວິທີການ

ສໍາລັບຜູ້ຮັກຂອງສະຄິບ bash, ວິທີການນີ້ອາດຈະເບິ່ງຄືວ່າເຫມາະສົມ, ແຕ່ມັນຍາກສໍາລັບຂ້ອຍ - script bash ບໍ່ແມ່ນ favorite ຂອງຂ້ອຍ. ວິທີການຕໍ່ໄປແມ່ນຫນ້າສົນໃຈແລະສະດວກກວ່າໃນຄວາມຄິດເຫັນຂອງຂ້ອຍ.

NiPyAPI

NiPyAPI ເປັນຫ້ອງສະຫມຸດ Python ສໍາລັບການພົວພັນກັບຕົວຢ່າງ NiFi. ໜ້າເອກະສານ ມີຂໍ້ມູນທີ່ຈໍາເປັນເພື່ອເຮັດວຽກກັບຫ້ອງສະຫມຸດ. ການເລີ່ມຕົ້ນໄວແມ່ນອະທິບາຍຢູ່ໃນ ຮ່າງ ໃນ github.

script ຂອງພວກເຮົາສໍາລັບການເປີດຕົວການຕັ້ງຄ່າແມ່ນໂຄງການ Python. ໃຫ້ກ້າວໄປສູ່ການເຂົ້າລະຫັດ.
ຕັ້ງຄ່າ config ສໍາລັບການເຮັດວຽກຕໍ່ໄປ. ພວກເຮົາຈະຕ້ອງການຕົວກໍານົດການດັ່ງຕໍ່ໄປນີ້:

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

ໃນຂັ້ນຕອນນີ້, ທ່ານຍັງສາມາດເພີ່ມການກວດສອບວ່າລີຈິດຊີໄດ້ຖືກເພີ່ມເຂົ້າໄປໃນຕົວຢ່າງແລ້ວ, ສໍາລັບນີ້ທ່ານສາມາດນໍາໃຊ້ວິທີການ.

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_group

ໃນບລັອກກ່ຽວກັບ CLI, ມັນຖືກຂຽນວ່າການໂອນຂໍ້ມູນບໍ່ໄດ້ເປີດໃຊ້ໂດຍອັດຕະໂນມັດໃນກຸ່ມຂະບວນການຫ່າງໄກສອກຫຼີກ? ເມື່ອປະຕິບັດສະຄິບ, ຂ້ອຍພົບບັນຫານີ້ຄືກັນ. ໃນເວລານັ້ນ, ຂ້ອຍບໍ່ສາມາດເລີ່ມຕົ້ນການໂອນຂໍ້ມູນໂດຍໃຊ້ API ແລະຂ້ອຍໄດ້ຕັດສິນໃຈຂຽນໄປຫາຜູ້ພັດທະນາຫ້ອງສະຫມຸດ NiPyAPI ແລະຂໍຄໍາແນະນໍາ / ການຊ່ວຍເຫຼືອ. ນັກພັດທະນາຕອບຂ້ອຍ, ພວກເຮົາໄດ້ປຶກສາຫາລືບັນຫາແລະລາວຂຽນວ່າລາວຕ້ອງການເວລາທີ່ຈະ "ກວດເບິ່ງບາງສິ່ງບາງຢ່າງ". ແລະໃນປັດຈຸບັນ, ສອງສາມມື້ຕໍ່ມາ, ອີເມວມາຮອດທີ່ຟັງຊັນ Python ຖືກຂຽນໄວ້ເພື່ອແກ້ໄຂບັນຫາການເລີ່ມຕົ້ນຂອງຂ້ອຍ !!! ໃນເວລານັ້ນ, ຮຸ່ນ NiPyAPI ແມ່ນ 0.13.3 ແລະ, ແນ່ນອນ, ບໍ່ມີຫຍັງຢູ່ໃນມັນ. ແຕ່ໃນສະບັບ 0.14.0, ເຊິ່ງໄດ້ຖືກປ່ອຍອອກມາເມື່ອບໍ່ດົນມານີ້, ຟັງຊັນນີ້ໄດ້ຖືກລວມເຂົ້າໃນຫ້ອງສະຫມຸດແລ້ວ. ພົບກັນ

nipyapi.canvas.set_remote_process_group_transmission

ດັ່ງນັ້ນ, ດ້ວຍການຊ່ວຍເຫຼືອຂອງຫ້ອງສະຫມຸດ NiPyAPI, ພວກເຮົາເຊື່ອມຕໍ່ການລົງທະບຽນ, ມ້ວນເຖິງການໄຫຼເຂົ້າ, ແລະແມ້ກະທັ້ງການເລີ່ມຕົ້ນຂອງໂປເຊດເຊີແລະການໂອນຂໍ້ມູນ. ຫຼັງຈາກນັ້ນ, ທ່ານສາມາດ comb ລະຫັດ, ເພີ່ມທຸກປະເພດຂອງການກວດສອບ, ການບັນທຶກ, ແລະນັ້ນແມ່ນມັນ. ແຕ່ນັ້ນແມ່ນເລື່ອງທີ່ແຕກຕ່າງກັນຫມົດ.

ທາງເລືອກອັດຕະໂນມັດທີ່ຂ້ອຍພິຈາລະນາ, ສຸດທ້າຍເບິ່ງຄືວ່າຂ້ອຍມີປະສິດທິພາບຫຼາຍທີ່ສຸດ. ກ່ອນອື່ນ ໝົດ, ນີ້ແມ່ນລະຫັດ python, ເຊິ່ງທ່ານສາມາດຝັງລະຫັດໂຄງການຊ່ວຍແລະໃຊ້ປະໂຫຍດຢ່າງເຕັມທີ່ຈາກພາສາການຂຽນໂປຼແກຼມ. ອັນທີສອງ, ໂຄງການ NiPyAPI ກໍາລັງພັດທະນາຢ່າງຫ້າວຫັນແລະໃນກໍລະນີຂອງບັນຫາທີ່ທ່ານສາມາດຂຽນໄປຫາຜູ້ພັດທະນາ. ອັນທີສາມ, NiPyAPI ຍັງເປັນເຄື່ອງມືທີ່ມີຄວາມຍືດຫຍຸ່ນຫຼາຍສໍາລັບການພົວພັນກັບ NiFi ໃນການແກ້ໄຂບັນຫາທີ່ສັບສົນ. ຕົວຢ່າງ, ໃນການກໍານົດວ່າແຖວຂໍ້ຄວາມໃນປັດຈຸບັນຫວ່າງເປົ່າຢູ່ໃນການໄຫຼແລະວ່າມັນເປັນໄປໄດ້ທີ່ຈະປັບປຸງກຸ່ມຂະບວນການ.

ຫມົດ​ເທົ່າ​ນີ້. ຂ້າພະເຈົ້າໄດ້ອະທິບາຍ 3 ວິທີການຂອງການສົ່ງກະແສອັດຕະໂນມັດໃນ NiFi, ຂຸມທີ່ຜູ້ພັດທະນາອາດຈະພົບແລະໃຫ້ລະຫັດເຮັດວຽກສໍາລັບການຈັດສົ່ງອັດຕະໂນມັດ. ຖ້າທ່ານສົນໃຈຫົວຂໍ້ນີ້ຄືກັບຂ້ອຍ - ຂຽນ!

ແຫຼ່ງຂໍ້ມູນ: www.habr.com