Metafunkciók az adatfolyamok leképezésében

A: Azure Data Factory Azure Synapse Analytics

Tipp.

Data Factory a Microsoft Fabric a Azure Data Factory következő generációja, egyszerűbb architektúrával, beépített AI-vel és új funkciókkal. Ha még nem ismerkedik az adatintegrációval, kezdje a Fabric Data Factoryvel. A meglévő ADF-számítási feladatok Fabric frissíthetnek az adatelemzés, a valós idejű elemzés és a jelentéskészítés új képességeinek eléréséhez.

Az adatfolyamok Azure Data Factory folyamatokban és Azure Synapse Analytics folyamatokban is elérhetők. Ez a cikk az adatfolyamok leképezésére vonatkozik. Ha még nem ismerkedik az átalakításokkal, tekintse meg az Adatok átalakítása leképezési adatfolyamokkal című bevezető cikket.

Ez a cikk az Azure Data Factory és Azure Synapse Analytics által támogatott metafunkciók részleteit ismerteti az adatfolyamok leképezésében.

Metafunkciós lista

A metafunkciók elsősorban az adatfolyam metaadatain működnek.

Metafunkció Task
byItem Egy struktúra vagy egy struktúra tömbjének egy részhalmazát keresi meg. Ha több egyezés van, az első egyezés lesz visszaadva. Ha nincsenek egyezések, a rendszer visszaad egy NULL értéket. A visszaadott értéket a típuskonvertálási műveletek (például ? date és ? string) egyikével kell átalakítani. A címoszlopok nevei csak a tervezés során kizárólag a nevük alapján ismertek. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat
szerző:Origin Kiválaszt egy oszlopértéket név szerint a forrásstreamben. A második argumentum a forrásstream neve. Ha több egyezés van, az első egyezés lesz visszaadva. Ha nincsenek egyezések, a rendszer visszaad egy NULL értéket. A visszaadott értéket a típuskonvertálási függvények (például TO_DATE és TO_STRING) egyikével kell konvertálni. A címoszlopok nevei csak a tervezés során kizárólag a nevük alapján ismertek. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
szerző:Origins Kiválaszt egy oszloptömböt név szerint a streamben. A második argumentum az a stream, amelyből származik. Ha több egyezés van, az első egyezés lesz visszaadva. Ha nincsenek egyezések, a rendszer visszaad egy NULL értéket. A visszaadott értéket a típuskonvertálási függvények (például TO_DATE és TO_STRING) egyikével kell konvertálni. A címoszlopok nevei csak a tervezés során kizárólag a nevük alapján ismertek. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
byName Kiválaszt egy oszlopértéket név szerint a streamben. Második argumentumként megadhat egy választható streamnevet. Ha több egyezés van, az első egyezés lesz visszaadva. Ha nincsenek egyezések, a rendszer visszaad egy NULL értéket. A visszaadott értéket a típuskonvertálási függvények (például TO_DATE és TO_STRING) egyikével kell konvertálni. A címoszlopok nevei csak a tervezés során kizárólag a nevük alapján ismertek. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
byNames Kiválaszt egy oszloptömböt név szerint a streamben. Második argumentumként megadhat egy választható streamnevet. Ha több egyezés van, az első egyezés lesz visszaadva. Ha nincs egyezés egy oszlophoz, a teljes kimenet egy NULL érték. A visszaadott értékhez típuskonvertálási függvény szükséges (például toDate és toString). A címoszlopok nevei csak a tervezés során kizárólag a nevük alapján ismertek. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
byPath Megkeresi a hierarchikus elérési utat név szerint a streamben. Második argumentumként megadhat egy választható streamnevet. Ha nem található ilyen elérési út, NULL értéket ad vissza. A tervezési időben ismert oszlopneveket vagy elérési útvonalakat csak a nevük vagy a pontozott jelölési útvonaluk alapján érhetjük el. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
byPosition Kiválaszt egy oszlopértéket a stream relatív (1 alapú) pozíciója alapján. Ha a pozíció hatókörön kívül esik, akkor egy NULL értéket ad vissza. A visszaadott értéket a típuskonvertálási függvények (például TO_DATE és TO_STRING) egyikével kell konvertálni. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
hasPath Ellenőrzi, hogy létezik-e név alapján egy bizonyos hierarchikus elérési út a streamben. Második argumentumként megadhat egy választható streamnevet. A tervezési időben ismert oszlopneveket vagy elérési útvonalakat csak a nevük vagy a pontozott jelölési útvonaluk alapján érhetjük el. A számított bemenetek nem támogatottak, de paraméterhelyettesítéseket is használhat.
originColumns Lekéri egy forrásfolyam összes kimeneti oszlopát, ahol az oszlopok létre lettek hozva. Más függvényhez kell csatolni.
rontás A bináris értéket hexa sztring formában adja vissza.
unhex A karakterlánc-ábrázolásból felold egy bináris értéket. Használhatja a sha2 és md5 segítségével, hogy sztringet bináris ábrázolássá alakítson át.