ืคึผืจืึธื”ืึธืกื˜ืขืจ > ื‘ืœืึธื’ > ืึทื“ืžื™ื ื™ืกื˜ืจืึทืฆื™ืข > ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi

ื”ืขืœื ืึทืœืขืžืขืŸ!

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi

ื“ื™ ืึทืจื‘ืขื˜ ืื™ื– ื•ื•ื™ ื’ื™ื™ื˜ - ืขืก ืื™ื– ืึท ืœื•ื™ืคืŸ ื’ืขื•ื•ื™ื–ืŸ ืื™ืŸ ื“ื™ ื‘ื™ืœื“ ืื•ื™ื‘ืŸ, ื•ื•ืึธืก ื“ืึทืจืฃ ื–ื™ื™ืŸ ืจืึธื•ืœื“ ืื•ื™ืก ืฆื• N ืกืขืจื•ื•ืขืจืก ืžื™ื˜ ืึทืคึผืึทื˜ืฉื™ ื ื™ืคื™. ืœื•ื™ืคืŸ ืคึผืจื•ื‘ื™ืจืŸ - ืึท ื˜ืขืงืข ืื™ื– ื“ื–ืฉืขื ืขืจื™ื™ื˜ืึทื“ ืื•ืŸ ื’ืขืฉื™ืงื˜ ืฆื• ืืŸ ืื ื“ืขืจ NiFi ื‘ื™ื™ึทืฉืคึผื™ืœ. ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ืึทืงืขืจื– ืžื™ื˜ ื“ื™ NiFi ืžืึทืคึผืข ืฆื• ืžืึทืคึผืข ืคึผืจืึธื˜ืึธืงืึธืœ.

NiFi Site to Site (S2S) ืื™ื– ืึท ื–ื™ื›ืขืจ, ื”ืขื›ืกื˜ ืงื•ืกื˜ืึธืžื™ื–ืึทื‘ืœืข ื•ื•ืขื’ ืฆื• ืึทืจื™ื‘ืขืจืคื™ืจืŸ ื“ืึทื˜ืŸ ืฆื•ื•ื™ืฉืŸ NiFi ื™ื ืกื˜ืึทื ืกื™ื–. ื–ืขืŸ ื•ื•ื™ S2S ืึทืจื‘ืขื˜ ื“ืึทืงื™ื•ืžืขื ื˜ื™ื™ืฉืึทืŸ ืื•ืŸ ืขืก ืื™ื– ื•ื•ื™ื›ื˜ื™ืง ืฆื• ื’ืขื“ืขื ืงืขืŸ ืฆื• ืฉื˜ืขืœืŸ ื“ื™ื™ืŸ NiFi ื‘ื™ื™ึทืฉืคึผื™ืœ ืฆื• ืœืึธื–ืŸ S2S ื–ืขืŸ ื“ืึธ.

ื•ื•ืขืŸ ืขืก ืงื•ืžื˜ ืฆื• ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ื ื™ืฆืŸ S2S, ืื™ื™ืŸ ื‘ื™ื™ึทืฉืคึผื™ืœ ืื™ื– ื’ืขืจื•ืคืŸ ืึท ืงืœื™ืขื ื˜, ื“ื™ ืจื’ืข ืื™ื– ืึท ืกืขืจื•ื•ืขืจ. ื“ืขืจ ืงืœื™ืขื ื˜ ืกืขื ื“ื– ื“ืึทื˜ืŸ, ื“ืขืจ ืกืขืจื•ื•ืขืจ ื ืขืžื˜ ืขืก. ืฆื•ื•ื™ื™ ื•ื•ืขื’ืŸ ืฆื• ืฉื˜ืขืœืŸ ืึทืจื•ื™ืฃ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ืฆื•ื•ื™ืฉืŸ ื–ื™ื™:

  1. ืฉื˜ื•ืคึผ. ื“ืึทื˜ืŸ ื–ืขื ืขืŸ ื’ืขืฉื™ืงื˜ ืคึฟื•ืŸ ื“ืขื ืงืœื™ืขื ื˜ ื‘ื™ื™ึทืฉืคึผื™ืœ ืžื™ื˜ ืึท ืจื™ืžืึธื•ื˜ ืคึผืจืึทืกืขืก ื’ืจื•ืคืข (ืจืคึผื’). ืื•ื™ืฃ ื“ื™ ืกืขืจื•ื•ืขืจ ื‘ื™ื™ึทืฉืคึผื™ืœ, ื“ืึทื˜ืŸ ื–ืขื ืขืŸ ื‘ืืงื•ืžืขืŸ ืžื™ื˜ ื“ื™ ื™ื ืคึผื•ื˜ ืคึผืึธืจื˜
  2. ืฆื™ืขืŸ. ื“ืขืจ ืกืขืจื•ื•ืขืจ ื‘ืืงื•ืžื˜ ื“ืึทื˜ืŸ ื ื™ืฆืŸ ื“ื™ ืจืคึผื’, ื“ืขืจ ืงืœื™ืขื ื˜ ืกืขื ื“ื– ื ื™ืฆืŸ ื“ื™ ืจืขื–ื•ืœื˜ืึทื˜ ืคึผืึธืจื˜.


ืœื•ื™ืคืŸ ืคึฟืึทืจ ืจืึธื•ืœื™ื ื’ ืื™ื– ืกื˜ืึธืจื“ ืื™ืŸ ื“ื™ ืึทืคึผืึทื˜ืฉื™ ืจืขื’ื™ืกื˜ืจื™.

Apache NiFi ืจืขื’ื™ืกื˜ืจื™ ืื™ื– ืึท ืกืึทื‘-ืคึผืจืึธื™ืขืงื˜ ืคื•ืŸ Apache NiFi ื•ื•ืึธืก ื’ื™ื˜ ืึท ืœื•ื™ืคืŸ ืกื˜ืึธืจื™ื“ื–ืฉ ืื•ืŸ ื•ื•ืขืจื™ื™ื™ืฉืึทืŸ ื’ืขืฆื™ื™ึทื’. ื ืžื™ืŸ ืคื•ืŸ GIT. ืื™ื ืคึฟืึธืจืžืึทืฆื™ืข ื•ื•ืขื’ืŸ ื™ื ืกื˜ืึธืœื™ื ื’, ืงืึทื ืคื™ื’ื™ืขืจื™ื ื’ ืื•ืŸ ืืจื‘ืขื˜ืŸ ืžื™ื˜ ื“ื™ ืจืขื’ื™ืกื˜ืจื™ ืงืขื ืขืŸ ื–ื™ื™ืŸ ื’ืขืคึฟื•ื ืขืŸ ืื™ืŸ ื‘ืึทืึทืžื˜ืขืจ ื“ืึทืงื™ื•ืžืขื ื˜ื™ื™ืฉืึทืŸ. ืœื•ื™ืคืŸ ืคึฟืึทืจ ืกื˜ืึธืจื™ื“ื–ืฉ ืื™ื– ืงืึทืžื‘ื™ื™ื ื“ ืื™ืŸ ืึท ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข ืื•ืŸ ืกื˜ืึธืจื“ ืื™ืŸ ื“ื™ ืจืขื’ื™ืกื˜ืจื™ ืื™ืŸ ื“ืขื ืคืึธืจืขื. ืžื™ืจ ื•ื•ืขืœืŸ ืฆื•ืจื™ืงืงื•ืžืขืŸ ืฆื• ื“ืขื ืฉืคึผืขื˜ืขืจ ืื™ืŸ ื“ืขื ืึทืจื˜ื™ืงืœ.

ืื™ืŸ ื“ื™ ืึธื ื”ื™ื™ื‘, ื•ื•ืขืŸ N ืื™ื– ืึท ืงืœื™ื™ืŸ ื ื•ืžืขืจ, ื“ื™ ืœื•ื™ืคืŸ ืื™ื– ืื™ื‘ืขืจื’ืขื’ืขื‘ืŸ ืื•ืŸ ื“ืขืจื”ื™ื™ึทื ื˜ื™ืงื˜ ื“ื•ืจืš ื”ืึทื ื˜ ืื™ืŸ ืึท ื’ืœื™ื™ึทืš ืฆื™ื™ื˜.

ืึธื‘ืขืจ ื•ื•ื™ N ื•ื•ืืงืกื˜, ืขืก ื–ืขื ืขืŸ ืžืขืจ ืคืจืื‘ืœืขืžืขืŸ:

  1. ืขืก ื ืขืžื˜ ืžืขืจ ืฆื™ื™ื˜ ืฆื• ื“ืขืจื”ื™ื™ึทื ื˜ื™ืงืŸ ื“ื™ ืœื•ื™ืคืŸ. ืื™ืจ ื“ืึทืจืคึฟืŸ ืฆื• ื’ื™ื™ืŸ ืฆื• ืึทืœืข ืกืขืจื•ื•ืขืจืก
  2. ืขืก ื–ืขื ืขืŸ ืขืจืจืึธืจืก ืึทืคึผื“ื™ื™ื˜ื™ื ื’ ื˜ืขืžืคึผืœืึทื˜ืขืก. ื“ื ื”ืื‘ืŸ ื–ื™ื™ ื“ืขืจื”ื™ื™ึทื ื˜ื™ืงื˜, ืื‘ืขืจ ื“ื ื”ืื‘ืŸ ื–ื™ื™ ืคืืจื’ืขืกืŸ
  3. ืžืขื ื˜ืฉ ื˜ืขื•ืช ื•ื•ืขืŸ ืคึผืขืจืคืึธืจืžื™ื ื’ ืึท ื’ืจื•ื™ืก ื ื•ืžืขืจ ืคื•ืŸ ืขื ืœืขืš ืึทืคึผืขืจื™ื™ืฉืึทื ื–

ืึทืœืข ื“ืขื ื‘ืจืขื ื’ื˜ ืื•ื ื“ื– ืฆื• ื“ื™ ืคืึทืงื˜ ืึทื– ืขืก ืื™ื– ื ื™ื™ื˜ื™ืง ืฆื• ืึธื˜ืึทืžื™ื™ื˜ ื“ืขื ืคึผืจืึธืฆืขืก. ืื™ืš ื”ืึธื‘ืŸ ื’ืขืคืจื•ื•ื•ื˜ ื“ื™ ืคืืœื’ืขื ื“ืข ื•ื•ืขื’ืŸ ืฆื• ืกืึธืœื•ื•ืข ื“ืขื ืคึผืจืึธื‘ืœืขื:

  1. ื ื™ืฆืŸ MiNiFi ืึทื ืฉื˜ืึธื˜ ืคื•ืŸ NiFi
  2. NiFi CLI
  3. NiPyAPI

ื ื™ืฆืŸ MiNiFi

ApacheMiNify ืื™ื– ืึท ืกื•ื‘ืคึผืจืึธื™ืขืงื˜ ืคื•ืŸ Apache NiFi. MiNiFy ืื™ื– ืึท ืกืึธืœื™ื“ ืึทื’ืขื ื˜ ื•ื•ืึธืก ื ื™ืฆื˜ ื“ื™ ื–ืขืœื‘ืข ืคึผืจืึทืกืขืกืขืจื– ื•ื•ื™ NiFi, ืึทืœืึทื•ื™ื ื’ ืื™ืจ ืฆื• ืฉืึทืคึฟืŸ ื“ื™ ื–ืขืœื‘ืข ืœื•ื™ืคืŸ ื•ื•ื™ ืื™ืŸ NiFi. ื“ื™ ืœื™ื™ื˜ื ืึทืก ืคื•ืŸ ื“ื™ ืึทื’ืขื ื˜ ืื™ื– ืึทื˜ืฉื™ื•ื•ื“, ืฆื•ื•ื™ืฉืŸ ืื ื“ืขืจืข, ืจืขื›ื˜ ืฆื• ื“ืขื ืคืึทืงื˜ ืึทื– MiNiFy ื”ืื˜ ื ื™ืฉื˜ ืึท ื’ืจืึทืคื™ืงืึทืœ ืฆื•ื‘ื™ื ื“ ืคึฟืึทืจ ื“ื™ ืœื•ื™ืคืŸ ืงืึทื ืคื™ื’ื™ืขืจื™ื™ืฉืึทืŸ. ื“ื™ ืคืขืœืŸ ืคื•ืŸ MiNiFy ืคื•ืŸ ืึท ื’ืจืึทืคื™ืงืึทืœ ืฆื•ื‘ื™ื ื“ ืžื™ื˜ืœ ืึทื– ืขืก ืื™ื– ื ื™ื™ื˜ื™ืง ืฆื• ืกืึธืœื•ื•ืข ื“ื™ ืคึผืจืึธื‘ืœืขื ืคื•ืŸ ืœื•ื™ืคืŸ ืขืงืกืคึผืจืขืก ืื™ืŸ ืžื™ื ื™ืคื™. ื–ื™ื ื˜ MiNiFy ืื™ื– ืึทืงื˜ื™ื•ื•ืœื™ ื’ืขื ื™ืฆื˜ ืื™ืŸ IOT, ืขืก ื–ืขื ืขืŸ ืคื™ืœืข ืงืึทืžืคึผืึธื•ื ืึทื ืฅ ืื•ืŸ ื“ืขืจ ืคึผืจืึธืฆืขืก ืคื•ืŸ ื“ืขืœื™ื•ื•ืขืจื™ื ื’ ืœื•ื™ืคืŸ ืฆื• ืœืขืฆื˜ ืžื™ื ื™ืคื™ ื™ื ืกื˜ืึทื ืกื™ื– ืžื•ื–ืŸ ื–ื™ื™ืŸ ืึธื˜ืึทืžื™ื™ื˜ื™ื“. ืึท ื‘ืึทืงืึทื ื˜ ืึทืจื‘ืขื˜, ืจืขื›ื˜?

ืืŸ ืื ื“ืขืจ ืกื•ื‘ืคึผืจืึธื™ืขืงื˜, MiNiFi C2 Server, ื•ื•ืขื˜ ื”ืขืœืคึฟืŸ ืกืึธืœื•ื•ืข ื“ืขื ืคึผืจืึธื‘ืœืขื. ื“ืขืจ ืคึผืจืึธื“ื•ืงื˜ ืื™ื– ื‘ื“ืขื” ืฆื• ื–ื™ื™ืŸ ื“ื™ ื”ื•ื™ืคื˜ ืคื•ื ื˜ ืื™ืŸ ื“ื™ ื“ื™ืคึผืœื•ื™ืžืึทื ื˜ ืึทืจืงืึทื˜ืขืงื˜ืฉืขืจ. ื•ื•ื™ ืฆื• ืงืึทื ืคื™ื’ื™ืขืจ ื“ื™ ืกื•ื•ื™ื•ื•ืข - ื“ื™ืกืงืจื™ื™ื‘ื“ ืื™ืŸ ื“ืขื ืึทืจื˜ื™ืงืœ ืื•ื™ืฃ Habrรฉ ืื•ืŸ ื“ื™ ืื™ื ืคึฟืึธืจืžืึทืฆื™ืข ืื™ื– ื’ืขื ื•ื’ ืฆื• ืกืึธืœื•ื•ืข ื“ื™ ืคึผืจืึธื‘ืœืขื. MiNiFi ืื™ืŸ ืงืึทื ื“ื–ืฉืึทื ื’ืงืฉืึทืŸ ืžื™ื˜ ื“ื™ C2 ืกืขืจื•ื•ืขืจ ืื•ื™ื˜ืึธืžืึทื˜ื™ืฉ ื“ืขืจื”ื™ื™ึทื ื˜ื™ืงื˜ ื–ื™ื™ืŸ ืงืึทื ืคื™ื’ื™ืขืจื™ื™ืฉืึทืŸ. ื“ืขืจ ื‘ืœื•ื™ื– ืฉื˜ืขืจื•ื ื’ ืคื•ืŸ ื“ืขื ืฆื•ื’ืึทื ื’ ืื™ื– ืึทื– ืื™ืจ ื”ืึธื‘ืŸ ืฆื• ืฉืึทืคึฟืŸ ื˜ืขืžืคึผืœืึทื˜ืขืก ืื•ื™ืฃ ื“ื™ C2 ืกืขืจื•ื•ื™ืจืขืจ, ืึท ืคึผืฉื•ื˜ ื™ื‘ืขืจื’ืขื‘ืŸ ืฆื• ื“ื™ ืจืขื’ื™ืกื˜ืจื™ ืื™ื– ื ื™ืฉื˜ ื’ืขื ื•ื’.

ื“ื™ ืึธืคึผืฆื™ืข ื“ื™ืกืงืจื™ื™ื‘ื“ ืื™ืŸ ื“ืขื ืึทืจื˜ื™ืงืœ ืื•ื™ื‘ืŸ ืึทืจื‘ืขื˜ ืื•ืŸ ืื™ื– ื ื™ืฉื˜ ืฉื•ื•ืขืจ ืฆื• ื™ื ืกื˜ืจื•ืžืขื ื˜, ืึธื‘ืขืจ ืžื™ืจ ืžื•ื–ืŸ ื ื™ืฉื˜ ืคืึทืจื’ืขืกืŸ ื“ื™ ืคืืœื’ืขื ื“ืข:

  1. minifi ื˜ื•ื˜ ื ื™ืฉื˜ ื”ืึธื‘ืŸ ืึทืœืข ืคึผืจืึทืกืขืกืขืจื– ืคึฟื•ืŸ nifi
  2. ืงืคึผื• ื•ื•ืขืจืกื™ืขืก ืื™ืŸ ืžื™ื ื™ืคื™ ืึธืคึผืฉื˜ื™ื™ ื”ื™ื ื˜ืขืจ ืงืคึผื• ื•ื•ืขืจืกื™ืขืก ืื™ืŸ ื ื™ืคื™.

ืื™ืŸ ื“ืขืจ ืฆื™ื™ื˜ ืคื•ืŸ ืฉืจื™ื™ื‘ืŸ, ื“ื™ ืœืขืฆื˜ืข ื•ื•ืขืจืกื™ืข ืคื•ืŸ โ€‹โ€‹โ€‹โ€‹Nifi ืื™ื– 1.9.2. ื“ื™ ืคึผืจืึทืกืขืกืขืจ ื•ื•ืขืจืกื™ืข ืคื•ืŸ โ€‹โ€‹ื“ื™ ืœืขืฆื˜ืข MiNiFi ื•ื•ืขืจืกื™ืข ืื™ื– 1.7.0. ืคึผืจืึทืกืขืกืขืจื– ืงืขื ืขืŸ ื–ื™ื™ืŸ ืžื•ืกื™ืฃ ืฆื• MiNiFi, ืึธื‘ืขืจ ืจืขื›ื˜ ืฆื• ื•ื•ืขืจืกื™ืข ื“ื™ืกืงืจืขืคึผืึทื ืกื™ื– ืฆื•ื•ื™ืฉืŸ NiFi ืื•ืŸ MiNiFi ืคึผืจืึทืกืขืกืขืจื–, ื“ืึธืก ืงืขืŸ ื ื™ืฉื˜ ืึทืจื‘ืขื˜ืŸ.

NiFi CLI

ืื•ื™ื‘ ืžืฉืคื˜ืŸ ืœื•ื™ื˜ ื‘ืึทืฉืจื™ื™ึทื‘ื•ื ื’ ืื•ื™ืฃ ื“ืขืจ ื‘ืึทืึทืžื˜ืขืจ ื•ื•ืขื‘ื–ื™ื™ื˜ืœ, ื“ืึธืก ืื™ื– ืึท ื’ืขืฆื™ื™ึทื’ ืคึฟืึทืจ ืึธื˜ืึทืžื™ื™ื˜ื™ื ื’ ื“ื™ ื™ื ื˜ืขืจืึทืงืฉืึทืŸ ืฆื•ื•ื™ืฉืŸ NiFI ืื•ืŸ NiFi ืจืขื’ื™ืกื˜ืจื™ ืื™ืŸ ื“ื™ ืคืขืœื“ ืคื•ืŸ ืœื•ื™ืคืŸ ืขืงืกืคึผืจืขืก ืึธื“ืขืจ ืคึผืจืึธืฆืขืก ืคืึทืจื•ื•ืึทืœื˜ื•ื ื’. ืืจืืคืงืืคื™ืข ื“ืขื ื’ืขืฆื™ื™ึทื’ ืฆื• ืึธื ื”ื™ื™ื‘ืŸ. ืคื•ื  ื“ืึทื ืขื˜.

ืงืึทื˜ืขืจ ื“ื™ ื ื•ืฆืŸ

./bin/cli.sh
           _     ___  _
 Apache   (_)  .' ..](_)   ,
 _ .--.   __  _| |_  __    )
[ `.-. | [  |'-| |-'[  |  /  
|  | | |  | |  | |   | | '    '
[___||__][___][___] [___]',  ,'
                           `'
          CLI v1.9.2

Type 'help' to see a list of available commands, use tab to auto-complete.

ื›ึผื“ื™ ืื•ื ื“ื– ืฆื• ืœืึธื“ืŸ ื“ื™ ืคืืจืœืื ื’ื˜ ืœื•ื™ืคืŸ ืคื•ืŸ ื“ื™ ืจืขื’ื™ืกื˜ืจื™, ืžื™ืจ ื“ืึทืจืคึฟืŸ ืฆื• ื•ื•ื™ืกืŸ ื“ื™ ื™ื“ืขื ื˜ื™ืคื™ืขืจืก ืคื•ืŸ ื“ื™ ืขืžืขืจ (ืขืžืขืจ ื™ื“ืขื ื˜ื™ืคื™ืขืจ) ืื•ืŸ ื“ื™ ืœื•ื™ืคืŸ ื–ื™ืš (ืœื•ื™ืคืŸ ื™ื“ืขื ื˜ื™ืคื™ืขืจ). ื“ื™ ื“ืึทื˜ืŸ ืงืขื ืขืŸ ื–ื™ื™ืŸ ื‘ืืงื•ืžืขืŸ ื“ื•ืจืš ื“ื™ ืงืœื™ ืึธื“ืขืจ ืื™ืŸ ื“ื™ NiFi ืจืขื’ื™ืกื˜ืจื™ ื•ื•ืขื‘ ืฆื•ื‘ื™ื ื“. ื“ื™ ื•ื•ืขื‘ ืฆื•ื‘ื™ื ื“ ืงื•ืงื˜ ื•ื•ื™ ื“ืึธืก:

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache 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 ื‘ื™ื™ึทืฉืคึผื™ืœ ืงืขื ืขืŸ ื–ื™ื™ืŸ ืกืคึผืขืกื™ืคื™ืขื“ ื•ื•ื™ ื“ืขืจ ื‘ืึทืœืขื‘ืึธืก ืฆื• ื•ื•ืึธืก ืžื™ืจ ื–ืขืžืœ ื“ื™ ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข.

ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข ืฆื•ื’ืขื’ืขื‘ืŸ ืžื™ื˜ ืคืืจืฉื˜ืืคื˜ ืคึผืจืึทืกืขืกืขืจื–, ื–ื™ื™ ื“ืึทืจืคึฟืŸ ืฆื• ื–ื™ื™ืŸ ืกื˜ืึทืจื˜ืขื“

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

ื’ืจื•ื™ืก, ื“ื™ ืคึผืจืึทืกืขืกืขืจื– ื”ืึธื‘ืŸ ืกื˜ืึทืจื˜ืขื“. ืึธื‘ืขืจ, ืœื•ื™ื˜ ื“ื™ ื‘ืื“ื™ื ื’ื•ื ื’ืขืŸ ืคื•ืŸ ื“ืขื ืคึผืจืึธื‘ืœืขื, ืžื™ืจ ื“ืึทืจืคึฟืŸ NiFi ื™ื ืกื˜ืึทื ืกื™ื– ืฆื• ืฉื™ืงืŸ ื“ืึทื˜ืŸ ืฆื• ืื ื“ืขืจืข ื™ื ืกื˜ืึทื ืกื™ื–. ื–ืืœ ืก ื™ื‘ืขืจื ืขืžืขืŸ ืึทื– ื“ื™ ืคึผื•ืฉ ืื•ืคึฟืŸ ืื™ื– ืื•ื™ืกื“ืขืจื•ื•ื™ื™ืœื˜ ืฆื• ืึทืจื™ื‘ืขืจืคื™ืจืŸ ื“ืึทื˜ืŸ ืฆื• ื“ื™ ืกืขืจื•ื•ืขืจ. ืื™ืŸ ืกื“ืจ ืฆื• ืึธืจื’ืึทื ื™ื–ื™ืจืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ, ืขืก ืื™ื– ื ื™ื™ื˜ื™ืง ืฆื• ื’ืขื‘ืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ (ื’ืขื‘ืŸ ื˜ืจืึทื ืกืžื™ื˜ื™ื ื’) ืื•ื™ืฃ ื“ื™ ืฆื•ื’ืขืœื™ื™ื’ื˜ ืจื™ืžืึธื•ื˜ ืคึผืจืึทืกืขืก ื’ืจื•ืคืข (RPG), ื•ื•ืึธืก ืื™ื– ืฉื•ื™ืŸ ืึทืจื™ื™ึทื ื’ืขืจืขื›ื ื˜ ืื™ืŸ ืื•ื ื“ื–ืขืจ ืœื•ื™ืคืŸ.

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi

ืื™ืŸ ื“ื™ ื“ืึทืงื™ื•ืžืขื ื˜ื™ื™ืฉืึทืŸ ืื™ืŸ ื“ื™ CLI ืื•ืŸ ืื ื“ืขืจืข ืžืงื•ืจื™ื, ืื™ืš ืงืขืŸ ื ื™ืฉื˜ ื’ืขืคึฟื™ื ืขืŸ ืึท ื•ื•ืขื’ ืฆื• ื’ืขื‘ืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ. ืื•ื™ื‘ ืื™ืจ ื•ื•ื™ืกืŸ ื•ื•ื™ ืฆื• ื˜ืึธืŸ ื“ืึธืก, ื‘ื™ื˜ืข ืฉืจื™ื™ึทื‘ืŸ ืื™ืŸ ื“ื™ ื‘ืึทืžืขืจืงื•ื ื’ืขืŸ.

ื–ื™ื ื˜ ืžื™ืจ ื”ืึธื‘ืŸ ื‘ืึทืฉ ืื•ืŸ ืžื™ืจ ื–ืขื ืขืŸ ื’ืจื™ื™ื˜ ืฆื• ื’ื™ื™ืŸ ืฆื• ื“ื™ ืกื•ืฃ, ืžื™ืจ ื•ื•ืขืœืŸ ื’ืขืคึฟื™ื ืขืŸ ืึท ื•ื•ืขื’ ืื•ื™ืก! ืื™ืจ ืงืขื ืขืŸ ื ื•ืฆืŸ ื“ื™ NiFi API ืฆื• ืกืึธืœื•ื•ืข ื“ืขื ืคึผืจืึธื‘ืœืขื. ืœืึธืžื™ืจ ื ื•ืฆืŸ ื“ื™ ืคืืœื’ืขื ื“ืข ืื•ืคึฟืŸ, ืžื™ืจ ื ืขืžืขืŸ ื“ื™ ืฉื™ื™ึทืŸ ืคึฟื•ืŸ ื“ื™ ื‘ื™ื™ืฉืคื™ืœืŸ ืื•ื™ื‘ืŸ (ืื™ืŸ ืื•ื ื“ื–ืขืจ ืคืึทืœ ืขืก ืื™ื– 7f522a13-016e-1000-e504-d5b15587f2f3). ื‘ืึทืฉืจื™ื™ึทื‘ื•ื ื’ ืคื•ืŸ NiFi API ืžืขื˜ื”ืึธื“ืก ื“ืึธ.

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi
ืื™ืŸ ื“ืขื ื’ื•ืฃ, ืื™ืจ ื“ืึทืจืคึฟืŸ ืฆื• ืคืึธืจืŸ JSON ืคื•ืŸ ื“ื™ ืคืืœื’ืขื ื“ืข ืคืึธืจืขื:

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

ืคึผืึทืจืึทืžืขื˜ืขืจืก ื•ื•ืึธืก ืžื•ื–ืŸ ื–ื™ื™ืŸ ืึธื ื’ืขืคื™ืœื˜ ืฆื• "ืึทืจื‘ืขื˜":
ื–ืขื ืขืŸ - ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ืกื˜ืึทื˜ื•ืก. ื‘ื ื™ืžืฆื: ื˜ืจืึทื ืกืžื™ื˜ื™ื ื’ ืฆื• ื’ืขื‘ืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ, ืกื˜ืึทืคึผื˜ ืฆื• ื“ื™ืกื™ื™ื‘ืึทืœ
ื•ื•ืขืจืกื™ืข - ืคึผืจืึทืกืขืกืขืจ ื•ื•ืขืจืกื™ืข

ื•ื•ืขืจืกื™ืข ื•ื•ืขื˜ ืคืขืœื™ืงื™ื™ึทื˜ ืฆื• 0 ื•ื•ืขืŸ ื‘ืืฉืืคืŸ, ืึธื‘ืขืจ ื“ื™ ืคึผืึทืจืึทืžืขื˜ืขืจืก ืงืขื ืขืŸ ื–ื™ื™ืŸ ื‘ืืงื•ืžืขืŸ ืžื™ื˜ ื“ืขื ืื•ืคึฟืŸ

ืœื•ื™ืคืŸ ื“ืขืœื™ื•ื•ืขืจื™ ืึทื•ื˜ืึธืžืึทื˜ื™ืึธืŸ ืื™ืŸ Apache NiFi

ืคึฟืึทืจ ืœื™ื‘ื”ืื‘ืขืจืก ืคื•ืŸ ื‘ืึทืฉ ืกืงืจื™ืคึผืก, ื“ืขื ืื•ืคึฟืŸ ืงืขืŸ ื•ื™ืกืงื•ืžืขืŸ ืคึผืึทืกื™ืง, ืึธื‘ืขืจ ืขืก ืื™ื– ืฉื•ื•ืขืจ ืคึฟืึทืจ ืžื™ืจ - ื‘ืึทืฉ ืกืงืจื™ืคึผืก ื–ืขื ืขืŸ ื ื™ืฉื˜ ืžื™ื™ืŸ ื‘ืึทืœื™ื‘ืกื˜ืข. ื“ืขืจ ื•ื•ื™ื™ึทื˜ืขืจ ื•ื•ืขื’ ืื™ื– ืžืขืจ ื˜ืฉื™ืงืึทื•ื•ืข ืื•ืŸ ืžืขืจ ื‘ืึทืงื•ื•ืขื ืื™ืŸ ืžื™ื™ืŸ ืžื™ื™ื ื•ื ื’.

NiPyAPI

NiPyAPI ืื™ื– ืึท ืคึผื™ื˜ื”ืึธืŸ ื‘ื™ื‘ืœื™ืึธื˜ืขืง ืคึฟืึทืจ ื™ื ื˜ืขืจืึทืงื˜ื™ื ื’ ืžื™ื˜ NiFi ื™ื ืกื˜ืึทื ืกื™ื–. ื“ืึทืงื™ื•ืžืขื ื˜ื™ื™ืฉืึทืŸ ื‘ืœืึทื˜ ื›ึผื•ืœืœ ื“ื™ ื ื™ื™ื˜ื™ืง ืื™ื ืคึฟืึธืจืžืึทืฆื™ืข ืฆื• ืึทืจื‘ืขื˜ืŸ ืžื™ื˜ ื“ืขืจ ื‘ื™ื‘ืœื™ืึธื˜ืขืง. ืฉื ืขืœ ืึธื ื”ื™ื™ื‘ ืื™ื– ื“ื™ืกืงืจื™ื™ื‘ื“ ืื™ืŸ ื“ืขืจ ืคึผืœืึทืŸ ืื•ื™ืฃ ื’ื™ื˜ื”ื•ื‘.

ืื•ื ื“ื–ืขืจ ืฉืจื™ืคื˜ ืคึฟืึทืจ ืจืึธื•ืœื™ื ื’ ืื•ื™ืก ื“ื™ ืงืึทื ืคื™ื’ื™ืขืจื™ื™ืฉืึทืŸ ืื™ื– ืึท ืคึผื™ื˜ื”ืึธืŸ ืคึผืจืึธื’ืจืึทื. ื–ืืœ ืก ืžืึทืš ืื•ื™ืฃ ืฆื• ืงืึธื“ื™ืจื•ื ื’.
ืฉื˜ืขืœืŸ ื“ื™ ืงืึทื ืคื™ื’ื™ืขืจื™ื™ืฉืึทื ื– ืคึฟืึทืจ ื•ื•ื™ื™ึทื˜ืขืจ ืึทืจื‘ืขื˜. ืžื™ืจ ื•ื•ืขืœืŸ ื“ืึทืจืคึฟืŸ ื“ื™ ืคืืœื’ืขื ื“ืข ืคึผืึทืจืึทืžืขื˜ืขืจืก:

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 ื‘ื™ื™ึทืฉืคึผื™ืœ

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

ืื•ืŸ ื“ืขืžืึธืœื˜ ืžื™ืจ ืงืขื ืขืŸ ื–ื•ื›ืŸ, ืœืžืฉืœ, ื“ื•ืจืš ื ืึธืžืขืŸ.

ืื™ืš ื•ื•ืขืœ ื ื™ืฉื˜ ื‘ืึทืฉืจื™ื™ึทื‘ืŸ ื“ืขื ืคึผืจืึธืฆืขืก ืคื•ืŸ ืึทืคึผื“ื™ื™ื˜ื™ื ื’ ื“ื™ ืžื•ืกื˜ืขืจ, ืื™ืš ื•ื•ืขืœ ื ืึธืจ ื–ืึธื’ืŸ ืึทื– ืื•ื™ื‘ ืคึผืจืึทืกืขืกืขืจื– ื–ืขื ืขืŸ ืžื•ืกื™ืฃ ืื™ืŸ ื“ื™ ื ื™ื™ึทืข ื•ื•ืขืจืกื™ืข ืคื•ืŸ โ€‹โ€‹ื“ื™ ืžื•ืกื˜ืขืจ, ืขืก ื–ืขื ืขืŸ ืงื™ื™ืŸ ืคืจืื‘ืœืขืžืขืŸ ืžื™ื˜ ื“ืขื ื‘ื™ื™ึทื–ื™ื™ึทืŸ ืคื•ืŸ ืึทืจื˜ื™ืงืœืขืŸ ืื™ืŸ ื“ื™ ืงื™ื•ื–. ืึธื‘ืขืจ ืื•ื™ื‘ ื“ื™ ืคึผืจืึทืกืขืกืขืจื– ื–ืขื ืขืŸ ืึทื•ื•ืขืงื’ืขื ื•ืžืขืŸ, ืขืก ืงืขืŸ ื–ื™ื™ืŸ ืึท ืคึผืจืึธื‘ืœืขื (ื ื™ืคื™ ื˜ื•ื˜ ื ื™ืฉื˜ ืœืึธื–ืŸ ื“ื™ ื‘ืึทื–ื™ื™ึทื˜ื™ืงื•ื ื’ ืคื•ืŸ ื“ื™ ืคึผืจืึทืกืขืกืขืจ ืื•ื™ื‘ ืึท ืึธื ื–ืึธื’ ืจื™ื™ ืื™ื– ืึทืงื™ื•ืžื™ืึทืœื™ื™ื˜ื™ื“ ืื™ืŸ ืคืจืึธื ื˜ ืคื•ืŸ ืื™ื). ืื•ื™ื‘ ืื™ืจ ื–ืขื ื˜ ืื™ื ื˜ืขืจืขืกื™ืจื˜ ืื™ืŸ ื•ื•ื™ ืื™ืš ืกืึทืœื•ื•ื“ ื“ืขื ืคึผืจืึธื‘ืœืขื - ืฉืจื™ื™ึทื‘ืŸ ืฆื• ืžื™ืจ, ื‘ื™ื˜ืข, ืžื™ืจ ื•ื•ืขืœืŸ ื“ื™ืกืงื•ื˜ื™ืจืŸ ื“ืขื ืคื•ื ื˜. ืงืึธื ื˜ืึทืงื˜ ืื™ืŸ ื“ื™ ืกื•ืฃ ืคื•ืŸ ื“ืขื ืึทืจื˜ื™ืงืœ. ื–ืืœ ืก ืžืึทืš ืื•ื™ืฃ ืฆื• ื“ื™ ืฉืจื™ื˜ ืคื•ืŸ ืึทื“ื™ื ื’ ืึท ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข.

ื•ื•ืขืŸ ื“ื™ื‘ืึทื’ื™ื ื’ ื“ื™ ืฉืจื™ืคื˜, ืื™ืš ื’ืขืคึฟื•ื ืขืŸ ืึท ืคึผื™ืงื™ื•ืœื™ืขืจืึทื˜ื™ ืึทื– ื“ื™ ืœืขืฆื˜ืข ื•ื•ืขืจืกื™ืข ืคื•ืŸ โ€‹โ€‹ืœื•ื™ืคืŸ ืื™ื– ื ื™ื˜ ืฉื˜ืขื ื“ื™ืง ืคึผื•ืœื“ ืึทืจื•ื™ืฃ, ืึทื–ื•ื™ ืื™ืš ืจืขืงืึธืžืขื ื“ื™ืจืŸ ืฆื• ืงืึธื ื˜ืจืึธืœื™ืจืŸ ื“ื™ ื•ื•ืขืจืกื™ืข ืขืจืฉื˜ืขืจ:

nipyapi.versioning.get_latest_flow_ver

ืคืึทืจืœื™ื™ื’ืŸ ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข:

nipyapi.versioning.deploy_flow_version

ืžื™ืจ ืึธื ื”ื™ื™ื‘ืŸ ื“ื™ ืคึผืจืึทืกืขืกืขืจื–:

nipyapi.canvas.schedule_process_group

ืื™ืŸ ื“ื™ ื‘ืœืึธืง ื•ื•ืขื’ืŸ CLI, ืขืก ืื™ื– ื’ืขื•ื•ืขืŸ ื’ืขืฉืจื™ื‘ืŸ ืึทื– ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ืื™ื– ื ื™ืฉื˜ ืื•ื™ื˜ืึธืžืึทื˜ื™ืฉ ืขื ื™ื™ื‘ืึทืœื“ ืื™ืŸ ื“ื™ ื•ื•ื™ื™ึทื˜ ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข? ื•ื•ืขืŸ ื™ืžืคึผืœืึทืžืขื ื™ื ื’ ื“ื™ ืฉืจื™ืคื˜, ืื™ืš ื’ืขืคึผืœืึธื ื˜ืขืจื˜ ื“ืขื ืคึผืจืึธื‘ืœืขื ืื•ื™ืš. ืื™ืŸ ื“ืขืจ ืฆื™ื™ื˜, ืื™ืš ืงืขืŸ ื ื™ืฉื˜ ืึธื ื”ื™ื™ื‘ืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ ื ื™ืฆืŸ ื“ื™ API ืื•ืŸ ืื™ืš ื‘ืึทืฉืœืึธืกืŸ ืฆื• ืฉืจื™ื™ึทื‘ืŸ ืฆื• ื“ื™ ื“ืขื•ื•ืขืœืึธืคึผืขืจ ืคื•ืŸ ื“ื™ NiPyAPI ื‘ื™ื‘ืœื™ืึธื˜ืขืง ืื•ืŸ ืคืจืขื’ืŸ ืคึฟืึทืจ ืขืฆื” / ื”ื™ืœืฃ. ื“ืขืจ ื“ืขื•ื•ืขืœืึธืคึผืขืจ ื”ืื˜ ืžื™ืจ ื’ืขืขื ื˜ืคืขืจื˜, ืžื™ืจ ื“ื™ืกืงืึทืกื˜ ื“ืขื ืคึผืจืึธื‘ืœืขื ืื•ืŸ ืขืจ ื’ืขืฉืจื™ื‘ืŸ ืึทื– ืขืจ ื“ืืจืฃ ืฆื™ื™ื˜ ืฆื• "ื˜ืฉืขืง ืขืคึผืขืก". ืื•ืŸ ืื™ืฆื˜, ืึท ืคึผืึธืจ ืคื•ืŸ ื˜ืขื’ ืฉืคึผืขื˜ืขืจ, ืึท ื‘ืœื™ืฆืคึผืึธืกื˜ ืขืจื™ื™ื•ื•ื– ืื™ืŸ ื•ื•ืึธืก ืึท ืคึผื™ื˜ื”ืึธืŸ ืคึฟื•ื ืงืฆื™ืข ืื™ื– ื’ืขืฉืจื™ื‘ืŸ ื•ื•ืึธืก ืกืึทืœื•ื•ื– ืžื™ื™ืŸ ืกื˜ืึทืจื˜ืึทืคึผ ืคึผืจืึธื‘ืœืขื !!! ืื™ืŸ ื“ืขืจ ืฆื™ื™ื˜, ื“ื™ NiPyAPI ื•ื•ืขืจืกื™ืข ืื™ื– ื’ืขื•ื•ืขืŸ 0.13.3 ืื•ืŸ, ืคื•ืŸ ืงื•ืจืก, ืขืก ืื™ื– ื’ืึธืจื ื™ืฉื˜ ืคื•ืŸ ื“ื™ ืžื™ืŸ ืื™ืŸ ืขืก. ืึธื‘ืขืจ ืื™ืŸ ื•ื•ืขืจืกื™ืข 0.14.0, ื•ื•ืึธืก ืื™ื– ืœืขืฆื˜ื ืก ื‘ืืคืจื™ื™ื˜, ื“ื™ ืคึฟื•ื ืงืฆื™ืข ืื™ื– ืฉื•ื™ืŸ ืึทืจื™ื™ึทื ื’ืขืจืขื›ื ื˜ ืื™ืŸ ื“ืขืจ ื‘ื™ื‘ืœื™ืึธื˜ืขืง. ื˜ืจืขืคืŸ

nipyapi.canvas.set_remote_process_group_transmission

ืึทื–ื•ื™, ืžื™ื˜ ื“ื™ ื”ื™ืœืฃ ืคื•ืŸ ื“ื™ NiPyAPI ื‘ื™ื‘ืœื™ืึธื˜ืขืง, ืžื™ืจ ืงืึธื ื ืขืงื˜ืขื“ ื“ื™ ืจืขื’ื™ืกื˜ืจื™, ืจืึธื•ืœื“ ืึทืจื•ื™ืฃ ื“ื™ ืœื•ื™ืคืŸ ืื•ืŸ ืืคื™ืœื• ืกื˜ืึทืจื˜ืขื“ ื“ื™ ืคึผืจืึทืกืขืกืขืจื– ืื•ืŸ ื“ืึทื˜ืŸ ืึทืจื™ื‘ืขืจืคื™ืจืŸ. ื“ืขืจื ืึธืš ืื™ืจ ืงืขื ืขืŸ ืงืึทื ื“ื™ ืงืึธื“, ืœื™ื™ื’ืŸ ืึทืœืข ืžื™ื ื™ื ืคื•ืŸ ื˜ืฉืขืงืก, ืœืึธื’ื™ื ื’, ืื•ืŸ ืึทื– ืก ืขืก. ืึธื‘ืขืจ ื“ืึธืก ืื™ื– ื’ืึธืจ ืึทืŸ ืึทื ื“ืขืจ ื’ืขืฉื™ื›ื˜ืข.

ืคื•ืŸ ื“ื™ ืึธื˜ืึทืžื™ื™ืฉืึทืŸ ืึธืคึผืฆื™ืขืก ืื™ืš ื‘ืึทื˜ืจืึทื›ื˜ืŸ, ื“ื™ ืœืขืฆื˜ืข ื’ืขื•ื•ืขืŸ ืฆื• ืžื™ืจ ื“ื™ ืžืขืจืกื˜ ืขืคืขืงื˜ื™ื•ื•. ืคื™ืจืกื˜ืœื™, ื“ืึธืก ืื™ื– ื ืึธืš ืคึผื™ื˜ื”ืึธืŸ ืงืึธื“, ืื™ืŸ ื•ื•ืึธืก ืื™ืจ ืงืขื ืขืŸ ื™ืžื‘ืขื“ ืึทื’ื–ื™ืœื™ืขืจื™ ืคึผืจืึธื’ืจืึทื ืงืึธื“ ืื•ืŸ ื’ืขื ื™ืกืŸ ืึทืœืข ื“ื™ ื‘ืขื ืขืคื™ืฅ ืคื•ืŸ ืึท ืคึผืจืึธื’ืจืึทืžืžื™ื ื’ ืฉืคึผืจืึทืš. ืฆื•ื•ื™ื™ื˜ื ืก, ื“ื™ NiPyAPI ืคึผืจื•ื™ืขืงื˜ ืื™ื– ืึทืงื˜ื™ื•ื•ืœื™ ื“ืขื•ื•ืขืœืึธืคึผื™ื ื’ ืื•ืŸ ืื™ืŸ ืคืึทืœ ืคื•ืŸ ืคึผืจืึธื‘ืœืขืžืก ืื™ืจ ืงืขื ืขืŸ ืฉืจื™ื™ึทื‘ืŸ ืฆื• ื“ื™ ื“ืขื•ื•ืขืœืึธืคึผืขืจ. ื“ืจื™ื˜ื ืก, NiPyAPI ืื™ื– ื ืึธืš ืึท ืžืขืจ ืคืœืขืงืกืึทื‘ืึทืœ ื’ืขืฆื™ื™ึทื’ ืคึฟืึทืจ ื™ื ื˜ืขืจืึทืงื˜ื™ื ื’ ืžื™ื˜ NiFi ืื™ืŸ ืกืึทืœื•ื•ื™ื ื’ ืงืึธืžืคึผืœืขืงืก ืคึผืจืึธื‘ืœืขืžืก. ืคึฟืึทืจ ื‘ื™ื™ึทืฉืคึผื™ืœ, ืื™ืŸ ื“ื™ื˜ืขืจืžืึทื ื™ื ื’ ืฆื™ ื“ื™ ืึธื ื–ืึธื’ ืงื™ื•ื– ื–ืขื ืขืŸ ืื™ืฆื˜ ืœื™ื™ื“ื™ืง ืื™ืŸ ื“ื™ ืœื•ื™ืคืŸ ืื•ืŸ ืฆื™ ืขืก ืื™ื– ืžืขื’ืœืขืš ืฆื• ื“ืขืจื”ื™ื™ึทื ื˜ื™ืงืŸ ื“ื™ ืคึผืจืึธืฆืขืก ื’ืจื•ืคึผืข.

ืึทื– ืก ืึทืœืข. ืื™ืš ื“ื™ืกืงืจื™ื™ื‘ื“ 3 ืึทืคึผืจืึธื•ื˜ืฉื™ื– ืฆื• ืึธื˜ืึทืžื™ื™ื˜ื™ื ื’ ืœื•ื™ืคืŸ ืขืงืกืคึผืจืขืก ืื™ืŸ NiFi, ืคึผื™ื˜ืคืึธืœื– ืึทื– ืึท ื“ืขื•ื•ืขืœืึธืคึผืขืจ ืงืขืŸ ื˜ืจืขืคืŸ, ืื•ืŸ ืฆื•ื’ืขืฉื˜ืขืœื˜ ืืจื‘ืขื˜ืŸ ืงืึธื“ ืคึฟืึทืจ ืึธื˜ืึทืžื™ื™ื˜ื™ื ื’ ืขืงืกืคึผืจืขืก. ืื•ื™ื‘ ืื™ืจ ื–ืขื ื˜ ืคึผื•ื ืงื˜ ื•ื•ื™ ืื™ื ื˜ืขืจืขืกื™ืจื˜ ืื™ืŸ ื“ืขื ื˜ืขืžืข ื•ื•ื™ ืื™ืš ื‘ื™ืŸ - ืฉืจื™ื™ึทื‘ืŸ!

ืžืงื•ืจ: www.habr.com

ืœื™ื™ื’ืŸ ืึท ื‘ืึทืžืขืจืงื•ื ื’