Az adat-előállító vezérlőfolyamatának ismertetése
Mi az a vezérlési folyamat?
A vezérlési folyamat folyamattevékenységek vezénylése, amely magában foglalja a láncolási tevékenységeket egy sorrendben, elágaztatást, paramétereket definiál a folyamat szintjén, és argumentumokat ad át, miközben igény szerint vagy eseményindítóból invokálás közben használja a folyamatot.
A vezérlési folyamat tartalmazhat hurkos tárolókat is, amelyek a ciklustároló minden iterációjára vonatkozóan átadhatnak információkat.
Ha egy For Each ciklust használ vezérlőfolyamat-tevékenységként, az Azure Data Factory ezzel a módszerrel több tevékenységet is elindíthat párhuzamosan. Így összetett és iteratív feldolgozási logikát hozhat létre az Azure Data Factoryvel létrehozott folyamatokon belül, amely támogatja a különböző adatintegrációs minták létrehozását, például egy modern adattárház létrehozását.
A gyakori vezérlési folyamatok némelyikét az alábbi szakaszok ismertetik.
Láncolási tevékenységek
Az Azure Data Factoryben a folyamaton belül egymás után láncolási műveleteket is végezhet. A dependsOn tulajdonságot egy tevékenységdefinícióban használhatja egy felsőbb rétegbeli tevékenységgel való láncra.
Elágaztatási tevékenységek
Az Azure Data Factory használatával elágaztatási tevékenységeket hozhat létre egy folyamaton belül. Az elágaztatási tevékenységre példa az If-condition tevékenység, amely hasonló a programozási nyelvekben megadott if-utasításhoz. Az elágaztatási tevékenység kiértékeli a tevékenységek egy készletét, és ha a feltétel igaznak bizonyul, a rendszer végrehajtja a tevékenységek egy készletét. Ha a kiértékelése hamis, akkor egy másik tevékenységkészlet lesz végrehajtva.
Parameters
A paraméterek folyamatszinten határozhatók meg, az argumentumok pedig a folyamat igény szerinti meghívása során vagy egy eseményindítóból adhatók át. A tevékenységek ezután felhasználják a paraméterben tárolt argumentumokat, miközben a folyamatnak átadják őket.
Egyéniállapot-átadás
Az egyéni állapotátadást az Azure Data Factory teszi lehetővé. Az egyéni állapotátadás olyan tevékenység, amely kimenetet hozott létre, vagy annak a tevékenységnek az állapotát, amelyet egy későbbi tevékenységnek kell felhasználnia a folyamatban. Például egy tevékenység JSON-definíciójában elérheti az előző tevékenység kimenetét. Az egyéni állapotátadással olyan munkafolyamatokat hozhat létre, amelyekben az értékek áthaladnak a tevékenységeken.
Tárolók hurkolása
Az olyan vezérlési folyamat ciklustárolói, mint a ForEach-tevékenység, az ismétlést definiálják egy folyamatban. Lehetővé teszi a gyűjtemények iterálását, és meghatározott tevékenységeket futtat a meghatározott ciklusban. Hasonlóan működik, mint a programozási nyelvekben használt "minden hurkolási struktúra esetében". Az egyes tevékenységek mellett létezik egy Until tevékenység is. Ez a funkció hasonló a programozásban használt do-until hurokhoz. Ez azt jelenti, hogy egy ciklusban futtat egy tevékenységcsoportot (műveletet), amíg a feltétel (addig) nem teljesül.
Eseményindító-alapú folyamatok
A folyamatokat igény szerinti (eseményalapú, például blob utáni) vagy falióra-idő válthatja ki.
Folyamat meghívása egy másik folyamatból
A Folyamat végrehajtása tevékenység az Azure Data Factoryvel lehetővé teszi, hogy egy Data Factory-folyamat meghívjon egy másik folyamatot.
Változási folyamatok
A deltafolyamatok használatával kapcsolatos használati esetek különbözeti terhelések. Az ETL-mintákban a deltabetöltések csak a folyamat korábbi iterációja óta megváltozott adatokat töltik be. Az olyan képességek, mint a keresési tevékenység és a rugalmas ütemezés segítenek a változásbetöltési feladatok kezelésében. Keresési tevékenység használata esetén bármely külső forrásból beolvassa vagy megkeresi a rekord- vagy táblanév értékét. Erre a kimenetre a későbbi tevékenységek is hivatkozhatnak.
Egyéb vezérlőfolyamatok
Sokkal több vezérlési folyamat van. További hasznos tevékenységekhez tekintse meg a következő elemeket:
Webes tevékenység: Az Azure Data Factory webes tevékenysége vezérlőfolyamatokkal meghívhat egy egyéni RESTendpointot egy Data Factory-folyamatból. Az adathalmazok és a társított szolgáltatások átadhatók, hogy a tevékenység fel tudja használni.
Metaadat-tevékenység lekérése: A Metaadatok lekérése tevékenység lekéri az Azure Data Factoryben lévő adatok metaadatait.