Megosztás a következőn keresztül:

Egyéni eseményindító létrehozása folyamat futtatásához az Azure Data Factoryben

  • Cikk

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Az eseményvezérelt architektúra egy gyakori adatintegrációs minta, amely magában foglalja az éles üzemet, az észlelést, a felhasználást és az eseményekre való reagálást. Az adatintegrációs forgatókönyvek gyakran megkövetelik, hogy az Azure Data Factory ügyfelei folyamatokat aktiváljanak bizonyos események bekövetkezésekor. A Data Factory natív integrációja az Azure Event Griddel mostantól egyéni témaköröket tartalmaz. Eseményeket küld egy Event Grid-témakörbe. A Data Factory feliratkozik a témakörre, meghallgatja, majd ennek megfelelően aktiválja a folyamatokat.

A cikkben ismertetett integráció az Azure Event Gridtől függ. Győződjön meg arról, hogy az előfizetés regisztrálva van az Event Grid erőforrás-szolgáltatónál. További információkért lásd az erőforrás-szolgáltatókat és a típusaikat ismertető cikket. Meg kell tudnia csinálni a Microsoft.EventGrid/eventSubscriptions/ műveletet. Ez a művelet az EventGrid EventSubscription Közreműködő beépített szerepkörének része.

Fontos

Ha ezt a funkciót az Azure Synapse Analyticsben használja, győződjön meg arról, hogy előfizetése egy Data Factory-erőforrás-szolgáltatónál is regisztrálva van. Ellenkező esetben megjelenik egy üzenet, amely szerint "egy esemény-előfizetés létrehozása nem sikerült".

Ha a folyamatparamétereket és az egyéni eseményindítókat kombinálja, elemezheti és hivatkozhat az egyéni data hasznos adatokra a folyamatfuttatásokban. Mivel az data egyéni esemény hasznos adatainak mezője egy szabadkéményes JSON-kulcs-érték struktúra, szabályozhatja az eseményvezérelt folyamatfuttatásokat.

Fontos

Ha a paraméterezésben hivatkozott kulcs hiányzik az egyéni esemény hasznos adataiból, trigger run sikertelen lesz. Megjelenik egy üzenet, amely szerint a kifejezés nem értékelhető ki, mert a keyName tulajdonság nem létezik. Ebben az esetben az esemény nem pipeline run aktiválódik.

Egyéni témakör beállítása az Event Gridben

Az egyéni eseményindító a Data Factoryben való használatához először be kell állítania egy egyéni témakört az Event Gridben.

Nyissa meg az Event Gridet, és hozza létre a témakört. Az egyéni témakör létrehozásáról további információt az Event Grid portál oktatóanyagai és az Azure CLI oktatóanyagai tartalmaznak.

Feljegyzés

A munkafolyamat eltér a tárolási esemény eseményindítójától. Itt a Data Factory nem állítja be a témakört.

A Data Factory arra számít, hogy az események az Event Grid eseménysémát követik. Győződjön meg arról, hogy az esemény hasznos adatai a következő mezőkkel rendelkeznek:

[
  {
    "topic": string,
    "subject": string,
    "id": string,
    "eventType": string,
    "eventTime": string,
    "data":{
      object-unique-to-each-publisher
    },
    "dataVersion": string,
    "metadataVersion": string
  }
]

Egyéni eseményindító létrehozása a Data Factory használatával

  1. Lépjen a Data Factorybe, és jelentkezzen be.

  2. Váltson a Szerkesztés lapra. Keresse meg a ceruza ikont.

  3. Válassza az Eseményindító lehetőséget a menüben, majd válassza az Új/Szerkesztés lehetőséget.

  4. Az Eseményindítók hozzáadása lapon válassza az Eseményindító kiválasztása, majd az + Új lehetőséget.

  5. A Típus csoportban válassza az Egyéni események lehetőséget.

    Képernyőkép egy új egyéni eseményindító létrehozásáról a Data Factory felhasználói felületén.

  6. Válassza ki az egyéni témakört az Azure-előfizetés legördülő listájából, vagy manuálisan adja meg az eseménytémakör hatókörét.

    Feljegyzés

    Ha egyéni eseményindítót szeretne létrehozni vagy módosítani a Data Factoryben, egy Azure-fiókot kell használnia a megfelelő Azure-szerepköralapú hozzáférés-vezérléssel (Azure RBAC). Nincs szükség más engedélyre. A Data Factory szolgáltatásnév nem igényel különleges engedélyt az Event Gridhez. A hozzáférés-vezérléssel kapcsolatos további információkért tekintse meg a szerepköralapú hozzáférés-vezérlési szakaszt.

  7. A Subject begins with tulajdonságok Subject ends with lehetővé teszik az eseményindító események szűrését. Mindkét tulajdonság megadása nem kötelező.

  8. Az +Új billentyűkombinációval eseménytípusokat adhat hozzá a szűréshez. Az egyéni eseményindítók listája VAGY kapcsolatot használ. Ha egy eventType tulajdonsággal rendelkező egyéni esemény egyezik a listán szereplővel, a folyamatfuttatás aktiválódik. Az esemény típusa nem érzékeny a kis- és nagybetűkre. Az alábbi képernyőképen például az eseményindító megegyezik az összes copycompleted olyan eseménysel vagy copysucceeded eseménysel, amelynek tárgya gyárakkal kezdődik.

    Képernyőkép az Eseménytípusok és a Tárgyszűrés a Data Factory felhasználói felületén az eseménytípusok és a tárgyszűrés ismertetésére szolgáló Eseményindító szerkesztése lapról.

  9. Az egyéni eseményindítók elemezhetik és elküldhetik az egyéni data hasznos adatokat a folyamatnak. Hozza létre a folyamatparamétereket, majd töltse ki az értékeket a Paraméterek lapon. A formátum @triggerBody().event.data._keyName_ használatával elemezze az adatok hasznos adatait, és adja át az értékeket a folyamatparamétereknek.

    Részletes magyarázatért lásd:

    Képernyőkép a folyamatparaméterek beállításairól.

    Képernyőkép a paraméterek oldalról, amelyen az adatok hasznos adataira hivatkozhat egy egyéni eseményben.

  10. A paraméterek megadása után válassza az OK gombot.

Speciális szűrés

Az egyéni eseményindítók speciális szűrési képességeket támogatnak, hasonlóan az Event Grid speciális szűréséhez. Ezek a feltételes szűrők lehetővé teszik a folyamatok aktiválását az esemény hasznos adatai alapján. Előfordulhat például, hogy az esemény hasznos adatainak egy részleg nevű mezője van, és a folyamat csak akkor aktiválódik, ha a Részleg egyenlő a Pénzügy szolgáltatással. Összetett logikát is megadhat, például az [1, 2, 3, 4, 5] lista dátummezőjét, a listában nem szereplő hónap mezőt [11, 12], és ha a címkemező tartalmazza a [Fiscal Year 2021, FiscalYear2021 vagy FY2021] mezőt.

Az ügyfélesemény-eseményindító speciális szűrőinek beállítását bemutató képernyőkép.

Az egyéni eseményindítók mától támogatják az Event Grid speciális szűrési operátorainak egy részét. A következő szűrőfeltételek támogatottak:

  • NumberIn
  • NumberNotIn
  • NumberLessThan
  • NumberGreaterThan
  • NumberLessThanOrEquals
  • NumberGreaterThanOrEquals
  • BoolEquals
  • StringContains
  • StringBeginsWith
  • StringEndsWith
  • StringIn
  • StringNotIn

Új szűrőfeltételek hozzáadásához válassza az + Új lehetőséget.

Az egyéni eseményindítók ugyanazokat a korlátozásokat is betartják, mint az Event Grid, például:

  • Egyéni eseményindítónként 5 speciális szűrő és 25 szűrőérték az összes szűrőben.
  • Sztringértékenként 512 karakter.
  • 5 érték és in not in operátor.
  • A kulcsok nem tartalmazhatják john.doe@contoso.compéldául a . (pont) karaktert. A kulcsokban jelenleg nem támogatott a feloldó karakterek használata.
  • Ugyanaz a kulcs több szűrőben is használható.

A Data Factory az Event Grid API legújabb általános rendelkezésre állási (GA) verziójára támaszkodik. Ahogy az új API-verziók a GA fázisba kerülnek, a Data Factory kibővíti a fejlettebb szűrési operátorok támogatását.

JSON-séma

Az alábbi táblázat áttekintést nyújt az egyéni eseményindítókhoz kapcsolódó sémaelemekről.

JSON-elem Leírás Típus Megengedett értékek Kötelező
scope Az Event Grid-témakör Azure Resource Manager-erőforrás-azonosítója. Sztring Azure Resource Manager-azonosító Igen.
events Az eseményindítót kiváltó események típusa. Sztringek tömbje Igen, legalább egy érték várható.
subjectBeginsWith A subject mezőnek a kigyulladáshoz megadott mintával kell kezdődnie. A gyárak például csak a gyárakkal kezdődő eseményalanyok eseményindítóját indítják el. Sztring Szám
subjectEndsWith A subject mezőnek a kigyulladáshoz megadott mintával kell végződnie. Sztring Szám
advancedFilters A szűrési feltételt meghatározó JSON-blobok listája. Minden blob megadja key, operatorTypeés values. JSON-blobok listája Szám

Szerepköralapú hozzáférés-vezérlés

A Data Factory az Azure RBAC használatával tiltja meg a jogosulatlan hozzáférést. A megfelelő működéshez a Data Factorynek hozzá kell férnie a következőhöz:

  • Események meghallgatása.
  • Feliratkozás eseményekből származó frissítésekre.
  • Egyéni eseményekhez társított folyamatok aktiválása.

Egyéni eseményindító sikeres létrehozásához vagy frissítéséhez be kell jelentkeznie a Data Factorybe egy megfelelő hozzáféréssel rendelkező Azure-fiókkal. Ellenkező esetben a művelet a "Hozzáférés megtagadva" üzenettel meghiúsul.

A Data Factory nem igényel különleges engedélyt az Event Grid-példányhoz. Emellett nem kell speciális Azure RBAC-szerepkör-engedélyt hozzárendelnie a Data Factory szolgáltatásnévhez a művelethez.

Pontosabban, szüksége van Microsoft.EventGrid/EventSubscriptions/Write engedélyre a /subscriptions/####/resourceGroups//####/providers/Microsoft.EventGrid/topics/someTopics.

  • Amikor az adat-előállítóban (például a fejlesztői környezetben) hoz létre, a bejelentkezett Azure-fióknak rendelkeznie kell az előző engedéllyel.
  • Ha folyamatos integrációval és folyamatos teljesítéssel teszi közzé a közzétételt, az Azure Resource Manager-sablon tesztelési vagy éles üzemben való közzétételéhez használt fióknak rendelkeznie kell az előző engedéllyel.

Kapcsolódó tartalom