Hogyan működik az Apache Nifi - böngésszen az adatfolyamán, ne fulladjon bele

Bevezetés

Ez egy őrült vízfolyás. Ahogy az alkalmazás egy őrült adatfolyammal foglalkozik. Az adatok átirányítása egyik tárolóból a másikba, érvényesítési szabályok alkalmazása és az adatkezelés kérdéseinek kezelése, a megbízhatóság a Big Data ökoszisztémában nehéz helyrehozni, ha mindezt egyedül végzi.

Jó hír, nem kell a semmiből felépítenie az adatfolyam-megoldást - az Apache NiFi visszakapta a hátát!

A cikk végén NiFi-szakértő lesz - készen áll az adatvezeték megépítésére.

Amivel foglalkozom ebben a cikkben:

  • Mi az Apache NiFi, milyen helyzetben kell használni, és melyek a legfontosabb fogalmak, amelyeket meg kell érteni a NiFi-ben.

Amire nem térek ki:

  • A NiFi-fürt telepítése, telepítése, felügyelete, biztonsága és adminisztrációja.

Az Ön kényelme érdekében itt található a tartalomjegyzék, nyugodtan menjen egyenesen oda, ahová a kíváncsisága visz. Ha Ön elsőként használ egy NiFi-t, akkor ajánlott átnézni ezt a cikket a megadott sorrendben.

Tartalomjegyzék

  • I - Mi az Apache NiFi?

    - A NiFi meghatározása

    - Miért használja a NiFi-t?

  • II - Apache Nifi mikroszkóp alatt

    - FlowFile

    - Processzor

    - Folyamatcsoport

    - Csatlakozás

    - Áramlásszabályozó

  • Következtetés és cselekvésre ösztönzés

Mi az Apache NiFi?

Az Apache Nifi projekt webhelyén a következő definíció található:

Könnyen használható, hatékony és megbízható rendszer az adatok feldolgozására és terjesztésére.

Elemezzük az ott található kulcsszavakat.

A NiFi meghatározása

Adatok feldolgozása és terjesztése

Ez a Nifi lényege. Adatokat mozgat a rendszerekben, és eszközöket ad az adatok feldolgozásához.

A Nifi nagyon sokféle adatforrással és formátummal képes foglalkozni. Az adatokat egy forrásból veszi be, átalakítja és más adatgyűjtőbe tolja.

Könnyen kezelhető

A processzorok - a dobozok - csatlakozókkal összekötve - a nyilak áramlást hoznak létre . Az N iFi flow-alapú programozási élményt kínál.

A Nifi lehetővé teszi, hogy egy pillanat alatt megértsük azokat az adatfolyam-műveleteket, amelyek megvalósításához több száz sornyi forráskód szükséges.

Tekintsük az alábbi csővezetéket:

A fenti adatáramlás NiFi-ben történő lefordításához lépjen a NiFi grafikus felhasználói felületére, húzza át három összetevőt a vászonra, és

Ez az. Két perc alatt elkészül.

Ha most ugyanarra a célra írsz kódot, akkor valószínűleg több száz sor hosszú lesz ahhoz, hogy hasonló eredményt érj el.

A folyamat lényegét nem kód segítségével ragadja meg, mint egy folyamat-alapú megközelítésnél. A Nifi kifejezőbb egy adatcsatorna kiépítéséhez; erre készült .

Erős

A NiFi számos processzort kínáldobozon kívül (a Nifi 1.9.2-ben 293). Egy óriás vállán állsz. Azok a szabványos processzorok kezelik a felmerülő használati esetek túlnyomó részét.

A NiFi nagyon párhuzamos, de belső része magában foglalja a kapcsolódó összetettséget. A processzorok magas szintű absztrakciót kínálnak, amely elrejti a párhuzamos programozás eredendő összetettségét. A processzorok egyidejűleg futnak, és a processzor több szálát átfedheti, hogy megbirkózzon a terheléssel.

A párhuzamosság egy olyan Pandora doboza, amelyet nem akar megnyitni. A NiFi kényelmesen megvédi a csővezetékgyártót a párhuzamosság összetettségétől.

Megbízható

A NiFi-t alátámasztó elmélet nem új keletű; szilárd elméleti horgonyokkal rendelkezik. Hasonló az olyan modellekhez, mint a SEDA.

Egy adatfolyam-rendszer esetében az egyik fő témakör a megbízhatóság. Biztos akar lenni abban, hogy a valahova elküldött adatokat ténylegesen fogadják.

A NiFi magas szintű megbízhatóságot ér el több olyan mechanizmus révén, amelyek a rendszer állapotát bármikor nyomon követik. Ezek a mechanizmusok konfigurálhatók, így megfelelő kompromisszumokat hozhat létre az alkalmazások által megkívánt késés és áteresztőképesség között.

A NiFi származási és származási jellemzőivel követi nyomon az egyes adatok történetét. Lehetővé teszi annak megismerését, hogy milyen átalakulás történik az egyes információknál.

Az Apache Nifi által javasolt adatvonal-megoldás kiváló eszköznek bizonyul egy adatcsatorna auditálásához. Az adatvonal tulajdonságai elengedhetetlenek a nagy adatok és az AI rendszerek iránti bizalom megerősítéséhez olyan kontextusban, ahol a transznacionális szereplők, például az Európai Unió iránymutatásokat javasolnak a pontos adatfeldolgozás támogatására.

Miért használja a Nifi-t?

Először szeretném világossá tenni, hogy nem a NiFi evangelizálásához vagyok itt. Célom, hogy elegendő elemet kapjak, hogy megalapozott döntést hozzon az adatvezeték építésének legjobb módjáról.

Hasznos szem előtt tartani a nagy adat négy V-jét a megoldás méretezésekor.

  • Hangerő - Milyen skálán működik? Nagyságrendi sorrendben közelebb állsz néhány GigaByte-hoz vagy több száz PetaByte-hoz?
  • Változatosság - Hány adatforrása van? Az adatai strukturáltak? Ha igen, gyakran változik-e a séma?
  • Sebesség - Milyen gyakorisággal dolgoznak fel eseményeket? Hitelkártyás fizetésekről van szó? IoT-eszköz által küldött napi teljesítményjelentés?
  • Valódiság - Megbízhat az adatokban? Alternatív megoldásként több tisztítási műveletet kell végrehajtania, mielőtt manipulálná?

A NiFi zökkenőmentesen nyer adatokat több adatforrásból, és mechanizmusokat biztosít az adatok különböző sémáinak kezelésére. Így akkor ragyog, ha nagy változatosság van az adatokban.

A Nifi különösen akkor értékes, ha az adatok alacsony pontosságúak . Mivel több processzort biztosít az adatok tisztításához és formázásához.

Konfigurációs lehetőségeivel a Nifi a hangerő / sebesség szituációk széles skáláját képes kezelni.

Az adatátviteli megoldások alkalmazásainak növekvő listája

Új szabályozások, a tárgyak internetének térnyerése és az általa generált adatáramlás hangsúlyozzák az olyan eszközök fontosságát, mint az Apache NiFi.

  • A mikroszolgáltatások divatosak. Azokban a lazán kapcsolt szolgáltatásokban az adatok a szolgáltatások közötti szerződés. A Nifi robusztus módszer az adatok átirányítására a szolgáltatások között.
  • A tárgyak interneteadatok sokaságát hozza a felhőbe. Az adatok beolvasása és hitelesítése a széltől a felhőig rengeteg új kihívást jelent, amelyeket a NiFi hatékonyan képes kezelni (elsősorban a MiniFi, az éleszközök NiFi projektje révén).
  • Új iránymutatásokat és szabályozásokat vezetnek be a Big Data gazdaság kiigazítására. A fokozódó monitoring összefüggésében elengedhetetlen, hogy a vállalkozások világos áttekintést kapjanak adatcsatornájukról. A NiFi adatvonal például hasznos lehet az előírások betartása felé vezető úton.

Áthidalja a szakadékot a big data szakértők és a többiek között

Amint azt a felhasználói felület is láthatja, a NiFi-ben kifejezett adatáram kiválóan alkalmas az adatvezeték kommunikációjára. Ez segíthet a szervezet tagjai számára, hogy jobban megismerjék az adatcsatornában zajló eseményeket.

  • Egy elemző betekintést kér arra, hogy miért érkeznek ide ezek az adatok? Üljetek össze és járjuk át az áramlást. Öt perc alatt megérted valakivel az Extract Transform and Load -ETL- csővezetéket.
  • Visszajelzést szeretne társaitól az Ön által létrehozott új hibakezelési folyamatról? A NiFi tervezési döntést hoz, hogy a hibaköröket az érvényes kimenetelnek valószínûnek tekinti. Arra számíthat, hogy az áttekintés rövidebb lesz, mint a hagyományos kódellenőrzés.

Használnod kellene? Igen nem Talán?

A NiFi márkája is könnyen használható. Mégis, ez egy vállalati adatfolyam platform. Teljes körű szolgáltatásokat kínál, amelyekből csak csökkentett részhalmazra lehet szüksége. Új eszköz hozzáadása a veremhez nem jóindulatú.

Ha a semmiből indul és néhány adatot kezel megbízható adatforrásokból, akkor érdemesebb beállítania az Átváltás kivonása és Betöltés - ETL csővezetékét. Lehet, hogy csak egy adatbázis adatcseréje és néhány adat-előkészítő szkript szükséges.

Másrészt, ha olyan környezetben dolgozik, ahol a meglévő big data megoldások vannak használatban (legyen szó tárolásról, feldolgozásról vagy üzenetküldésről), a NiFi jól integrálódik velük, és valószínűleg gyors győzelem. Kihasználhatja a dobozon kívüli csatlakozókat azokra a Big Data megoldásokra.

Könnyű feltéveszteni új megoldásokat. Sorolja fel követelményeit, és válassza ki a lehető legegyszerűbben az Ön igényeinek megfelelő megoldást .

Most, hogy megláttuk az Apache NiFi nagyon magas képét, megnézzük annak kulcsfontosságú fogalmait, és boncolgatjuk a belsejét.

Apache Nifi mikroszkóp alatt

A „NiFi dobozok és nyíl programozás” lehet, hogy kommunikál a nagy kép. Ha azonban a NiFi-vel kell működnie, akkor érdemes többet megértenie a működéséről.

Ebben a második részben sémákkal magyarázom az Apache NiFi kritikus fogalmait. Ez a fekete dobozos modell utólag nem lesz fekete doboz.

Kicsomagolni az Apache NiFi-t

Amikor elindítja a NiFi-t, ráér a webes felületére. A webes felhasználói felület az a terv, amelyre megtervezi és vezérli az adatcsatornáját.

A Nifi-ben processzorokat állít össze, amelyeket kapcsolatok kötnek össze . A korábban bemutatott minta adatfolyamban három processzor van.

A NiFi vászon felhasználói felülete az a keret, amelyben a csővezeték-készítő fejlődik.

A Nifi terminológia értelmezése

Az adatfolyam Nifi-ben történő kifejezéséhez először el kell sajátítania a nyelvét. Semmi gond, néhány kifejezés elég ahhoz, hogy megértsük a mögötte álló koncepciót.

A fekete dobozok hívják processzorok, és egymásnak darabokat információt elemzi FlowFiles keresztül sorok azonos nevű kapcsolatokat . Végül a FlowFile vezérlő felelős az összetevők közötti erőforrások kezeléséért.

Vizsgáljuk meg, hogyan működik ez a motorháztető alatt.

FlowFile

A NiFi-ben a FlowFilea csővezeték processzorain keresztül mozgó információs csomag.

A FlowFile két részből áll:

  • Attribútumok , amelyek kulcs / érték párok. Például a fájlnév, a fájl elérési útja és az egyedi azonosító szabványos attribútum.
  • Tartalom , a bájtfolyamra való hivatkozás alkotja a FlowFile tartalmat.

A FlowFile nem tartalmazza magát az adatot. Ez súlyosan korlátozná a csővezeték áteresztőképességét.

Ehelyett a FlowFile tartalmaz egy mutatót, amely a helyi tároló bizonyos helyén tárolt adatokra hivatkozik. Ezt a helyet Tartalomtárnak hívják .

A tartalom eléréséhez a FlowFile igényli az erőforrást a Tartalomtárból. A későbbiekben nyomon követik a lemez pontos eltolását onnan, ahol a tartalom található, és visszafolyásolja azt a FlowFile-be.

Nem minden processzornak kell hozzáférnie a FlowFile tartalmához a műveletek végrehajtásához - például két FlowFile tartalmának összesítéséhez nem szükséges a tartalmukat a memóriába tölteni.

Amikor egy processzor módosítja a FlowFile tartalmát, a korábbi adatok megmaradnak. A NiFi írásra másol, módosítja a tartalmat, miközben új helyre másolja. Az eredeti információ sértetlen marad a Tartalomtárban.

Példa

Vegyünk egy processzort, amely tömöríti a FlowFile tartalmát. Az eredeti tartalom a Tartalomtárban marad, és egy új bejegyzés jön létre a tömörített tartalom számára.

A Tartalomtár a visszatérítést végül a tömörített tartalomra adja vissza. A FlowFile frissül, hogy a tömörített adatokra mutasson.

Az alábbi rajz összefoglalja a példát egy processzorral, amely tömöríti a FlowFiles tartalmát.

Megbízhatóság

A NiFi azt állítja, hogy megbízható, hogyan működik a gyakorlatban?Az összes jelenleg használt FlowFile attribútumát, valamint a tartalmukra való hivatkozást a FlowFile adattár tárolja.

A folyamat minden lépésében a Flowfile módosítását először a FlowFile adattárban rögzítik egy előre írható naplóban, mielőtt végrehajtanák.

A FlowFile adattár minden, a rendszerben jelenleg létező FlowFile esetében tárolja:

  • A FlowFile attribútumok
  • Mutató a FlowFile-tárban található FlowFile tartalmára
  • A FlowFile állapota. Például: melyik sorba tartozik a Flowfile ebben a pillanatban.

A FlowFile adattár biztosítja az áramlás legfrissebb állapotát; így hatékony eszköz a kiesésből való kilábaláshoz.

A NiFi egy másik eszközt kínál a folyamatban lévő összes FlowFile teljes történetének nyomon követésére: a Provenance Repository-t.

Provence Repository

Minden alkalommal, amikor egy FlowFile-t módosítanak, a NiFi ebben a pillanatban pillanatképet készít a FlowFile-ről és annak összefüggéseiről. A NiFi pillanatképének neve Provence-esemény . A Providence Repository rögzíti a Providence eseményeket.

A származás lehetővé teszi számunkra, hogy nyomon kövessük az adatok származását, és kiépítsük a teljes felügyeleti láncot minden NiFi-ben feldolgozott információ esetében.

Amellett, hogy az adatok teljes vonalvezetését kínálja, a Providence Repository felajánlja az adatok bármikor történő visszajátszását.

Várjon, mi a különbség a FlowFile-tár és a Providence-tár között?

A FlowFile-adattár és a Provenance Repository ötlete meglehetősen hasonló, de nem ugyanazzal a kérdéssel foglalkoznak.

  • A FlowFile adattár egy napló, amely csak a rendszerben lévő FlowFiles legújabb állapotát tartalmazza. Ez a legfrissebb kép az áramlásról, és lehetővé teszi a kiesés gyors felépülését.
  • A Providence Repository viszont kimerítőbb, mivel minden áramlásban lévő FlowFile teljes életciklusát nyomon követi.

Ha csak a legfrissebb képe van a FlowFile adattárral ellátott rendszerről, a Providence Repository egy fényképgyűjteményt - videót ad . Visszatérhet a múlt bármely pillanatára, kivizsgálhatja az adatokat, és egy adott időn belül visszajátszhatja a műveleteket. Ez biztosítja az adatok teljes származását.

FlowFile processzor

A processzor egy fekete doboz, amely műveletet hajt végre. A processzorok hozzáférhetnek a FlowFile attribútumaihoz és tartalmához, hogy mindenféle műveletet végezhessenek. Ezek lehetővé teszik, hogy számos műveletet hajtson végre adatbevitel, szabványos adatátalakítási / ellenőrzési feladatok során, és ezeket az adatokat különféle adatgyűjtőkbe mentse.

A NiFi sok processzorral érkezik, amikor telepíti. Ha nem találja a legmegfelelőbbet a felhasználási esetéhez, akkor is meg lehet építeni saját processzorát. Az egyedi processzorok írása nem tartozik e blogbejegyzés körébe.

A processzorok magas szintű absztrakciók, amelyek egy feladatot teljesítenek. Ez az absztrakció nagyon kényelmes, mert megvédi a csővezeték gyártót az egyidejű programozás és a hibakezelési mechanizmusok megvalósításának eredendő nehézségeitől.

A processzorok több konfigurációs beállítással rendelkező interfészt tárnak fel a viselkedésük finomhangolása érdekében.

Ezen processzorok tulajdonságai jelentik az utolsó kapcsolatot a NiFi és az alkalmazás követelményeinek üzleti realitása között.

Az ördög a részletekben rejlik, és a csővezeték-építők idejük nagy részét a tulajdonságok finomhangolásával töltik, hogy megfeleljenek a várható viselkedésnek.

Méretezés

Minden processzorhoz megadhatja az egyidejűleg futtatni kívánt párhuzamos feladatok számát. A Flow Controller így több erőforrást oszt le ennek a processzornak, növelve annak teljesítményét. A processzorok megosztják a szálakat. Ha az egyik processzor több szálat kér, akkor a többi processzor kevesebb szálat tud végrehajtani. A Flow Controller szálak kiosztásának részletei itt érhetők el.

Vízszintes méretezés. A méretezés másik módja a NiFi-fürt csomópontjainak számának növelése. A fürtöző szerverek lehetővé teszik a feldolgozási képesség növelését áruhardver használatával.

Process Group

Ez egyenes most, amikor láttuk, hogy melyek a processzorok.

Egy csomó processzor a kapcsolataikkal együtt egy folyamatcsoportot alkothat. Hozzáad egy bemeneti és egy kimeneti portot, hogy azok adatokat fogadhassanak és küldhessenek.

A processzorcsoportok egyszerű módon hozhatnak létre új processzorokat a meglévőkből.

Kapcsolatok

A kapcsolatok a processzorok közötti várakozási sorok. Ezek a sorok lehetővé teszik a processzorok számára, hogy eltérő sebességgel lépjenek kapcsolatba. A csatlakozások különböző kapacitásúak lehetnek, mivel különböző méretű vízvezetékek léteznek.

Mivel a processzorok az elvégzett műveletektől függően különböző sebességgel fogyasztanak és állítanak elő adatokat, a kapcsolatok a FlowFiles puffereként működnek.

Korlátozott, hogy hány adat lehet a kapcsolatban. Hasonlóképpen, ha a vízvezeték tele van, már nem tölthet vizet, vagy túlcsordul.

A NiFi-ben korlátokat állíthat be a kapcsolatokon átmenő FlowFiles számra és összesített tartalmuk méretére.

Mi történik, ha több adatot küld, mint amennyit a kapcsolat képes kezelni?

Ha a FlowFiles száma vagy az adatmennyiség meghaladja a megadott küszöbértéket, akkor ellennyomást alkalmazunk. A Flow Controller addig nem ütemezi az előző processzor újbóli futtatását, amíg nincs hely a sorban.

Tegyük fel, hogy két processzor között legfeljebb 10 000 FlowFile áll rendelkezésre. Valamikor a kapcsolatnak 7 000 eleme van. Rendben van, mivel a határ 10 000. A P1 továbbra is küldhet adatokat a P2- n keresztüli kapcsolaton keresztül .

Tegyük fel, hogy az egyik processzor 4000 új FlowFile-t küld a kapcsolatnak.

7 0000 + 4 000 = 11 000 → 10 000 FlowFiles csatlakozási küszöb felett vagyunk.

A határértékek puha határértékek, vagyis meghaladhatók. Ha azonban az előző processzor lesz , a P1 ütemezése csak akkor történik meg, ha a csatlakozó visszaáll a küszöbérték alá - 10 000 FlowFiles.

Ez az egyszerűsített példa nagy képet ad az ellennyomás működéséről.

Be szeretné állítani a kezelendő adatok mennyiségének és sebességének megfelelő kapcsolati küszöbértékeket. Ne feledje a négy V-t .

A határ túllépésének ötlete furcsának tűnhet. Amikor a FlowFiles vagy a kapcsolódó adatok száma meghaladja a küszöbértéket, akkor egy csere mechanizmus lép működésbe.

Egy másik példa az ellennyomásra: ez a levélszál segíthet.

A FlowFiles prioritása

A NiFi csatlakozói jól konfigurálhatók. Kiválaszthatja, hogyan állítsa a FlowFiles fontossági sorrendjét a sorba, hogy eldöntse, melyiket dolgozza fel a következő lépésben.

A rendelkezésre álló lehetőségek között van például a First In First Out megbízás - a FIFO. Azonban akár a FlowFile által választott attribútumot is felhasználhatja a bejövő csomagok rangsorolására.

Áramlásszabályozó

A Flow Controller az a ragasztó, amely mindent összehoz. Kiosztja és kezeli a szálakat a processzorok számára. Ez hajtja végre az adatfolyamot.

A Flow Controller lehetővé teszi a Controller Services hozzáadását is.

Ezek a szolgáltatások megkönnyítik a megosztott erőforrások, például az adatbázis-kapcsolatok vagy a felhőszolgáltatói hitelesítő adatok kezelését. A vezérlői szolgáltatások démonok. A háttérben futnak, és konfigurációt, erőforrásokat és paramétereket biztosítanak a processzorok végrehajtásához.

Például használhat egy AWS hitelesítő adatok szolgáltató szolgáltatást annak lehetővé tétele érdekében, hogy szolgáltatásai kölcsönhatásba léphessenek az S3 csoportokkal anélkül, hogy aggódnia kellene a hitelesítő adatok miatt a processzor szintjén.

A processzorokhoz hasonlóan a vezérlőszolgáltatások sokasága már eleve elérhető.

A vezérlőszolgáltatások további tartalmát megtekintheti ebben a cikkben.

Következtetés és cselekvésre ösztönzés

A cikk során megvitattuk a NiFi vállalati adatfolyam megoldást. Most már jól ismeri, hogy mit csinál a NiFi, és hogyan tudja kihasználni az adatátirányítási funkciókat az alkalmazások számára.

Ha ezt olvassa, gratulálok! Most már többet tud a NiFi-ről, mint a világ népességének 99,99% -a.

Gyakorlat teszi a mestert. Elsajátítja az összes olyan fogalmat, amely szükséges a saját csővezeték építéséhez. Egyszerűsítsd; először működjön.

Íme egy lista az izgalmas forrásokról, amelyeket a munkatapasztalatomon túl összeállítottam a cikk megírásához.

Erőforrások ?

A nagyobb kép

Mivel az adatcsatorna bonyolult ökoszisztémában történő megtervezése több területen való jártasságot igényel, nagyon ajánlom az Adatigényes alkalmazások tervezése című könyvet.Martin Kleppmanntól. Ez lefedi az alapokat.

  • A Martin könyvében idézett összes hivatkozást tartalmazó csalólap elérhető a Github repóban.

Ez a csalólap kiváló hely a kezdéshez, ha már tudja, milyen témát szeretne alaposan tanulmányozni, és minőségi anyagokat szeretne találni.

Az Apache Nifi alternatívái

Egyéb adatfolyam-megoldások léteznek.

Nyílt forráskód:

  • A patakok hasonlóak a NiFi-hez; jó összehasonlítás érhető el ezen a blogon

A meglévő felhőszolgáltatók többsége adatfolyam-megoldásokat kínál. Ezek a megoldások könnyen integrálhatók a felhőszolgáltató által használt más termékekkel. Ugyanakkor szilárdan összeköti Önt egy adott eladóval.

  • Azure Data Factory, egy Microsoft-megoldás
  • Az IBM rendelkezik az InfoSphere DataStage programmal
  • Az Amazon a Data Pipeline nevű eszközt javasolja
  • A Google felajánlja Dataflow-ját
  • Az Alibaba cloud bemutatja a DataWorks szolgáltatást hasonló funkciókkal

NiFi-val kapcsolatos források

  • A hivatalos Nifi dokumentáció és különösen a Nifi mélyreható rész aranybányák.
  • A Nifi felhasználók levelezőlistájába történő regisztráció szintén nagyszerű módja a tájékoztatásnak - például ez a beszélgetés magyarázza az ellennyomást.
  • Hortonworks, nagy adatátviteli megoldások szolgáltatója, a közösségi weboldal tele megnyerő források és hogyan kell az Apache Nifi.

    - Ez a cikk elmélyülten ismerteti a csatlakozókat, a kupachasználatot és az ellennyomást.

    - Ez megosztja a bevált módszereket a NiFi-klaszter telepítésekor.

  • A NiFi blog sok betekintést nyújt a NiFi használati szokásaiba, valamint tippeket ad a csővezetékek építéséhez.
  • Claim Check minta magyarázata
  • Az Apache Nifi elmélete nem új keletű, a Nifi Doc-ban hivatkozott Seda rendkívül releváns

    - Matt Welsh. Berkeley. SEDA: A jól kondicionált, méretezhető internetes szolgáltatások architektúrája [online]. Letöltve: 2019. április 21., innen: //www.mdw.la/papers/seda-sosp01.pdf