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

Referencia-eseményindító metaadatai a folyamatfuttatásokban

  • 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!

Ez a cikk azt ismerteti, hogyan használhatók az eseményindító metaadatai, például az eseményindító kezdési időpontja egy folyamatfuttatásban.

A folyamatoknak néha meg kell érteniük és be kell olvasniuk a metaadatokat a meghívó eseményindítóból. Ha például egy átfedésben lévő ablak eseményindítója fut, az ablak kezdési és befejezési ideje alapján a folyamat különböző adatszeleteket vagy mappákat dolgoz fel. Az Azure Data Factoryben paraméterezési és rendszerváltozókkal továbbítjuk a metaadatokat az eseményindítókról a folyamatokra.

Ez a minta különösen hasznos az ablakos eseményindítóknál, ahol az eseményindító megadja az ablak kezdési és befejezési idejét, valamint az egyéni eseményindítókat, ahol az eseményindító elemzi és feldolgozza az értékeket egy egyénileg definiált adatmezőben.

Feljegyzés

A különböző triggertípusok különböző metaadat-információkat biztosítanak. További információ: Rendszerváltozók.

A Data Factory felhasználói felülete

Ez a szakasz bemutatja, hogyan továbbíthat metaadat-információkat az eseményindítókról a folyamatokra a Data Factory felhasználói felületén (UI).

  1. Lépjen a Szerzői vászonra , és szerkessze a folyamatot.

  2. Válassza ki az üres vásznon a folyamatbeállítások megjelenítéséhez. Ne jelöljön ki semmilyen tevékenységet. Előfordulhat, hogy fel kell húznia a beállításpanelt a vászon aljáról, mert összecsukható lehet.

  3. Válassza a Paraméterek lapot, és válassza az + Új lehetőséget paraméterek hozzáadásához.

    Képernyőkép egy folyamatbeállításról, amely bemutatja, hogyan definiálhat paramétereket egy folyamatban.

  4. Eseményindítók hozzáadása a folyamathoz a +Trigger lehetőség kiválasztásával.

  5. Hozzon létre vagy csatoljon egy eseményindítót a folyamathoz, és válassza az OK gombot.

  6. Az OK gomb kiválasztása után megjelenik egy másik Új eseményindító lap, amelyen a folyamathoz megadott paraméterek listája látható az alábbi képernyőképen látható módon. Ezen a lapon adja meg az egyes paraméterek eseményindító metaadatait. A rendszerváltozókban definiált formátum használatával kérje le az eseményindító adatait. Nem kell minden paraméter adatait megadnia. Csak adja meg azokat, amelyek metaadat-értékeket feltételeznek. Itt például az eseményindító futási kezdési idejét rendeljük hozzá parameter_1.

    Képernyőkép az eseményindító futtatási paramétereinek oldaláról, amely bemutatja, hogyan adhatja át az eseményindító adatait a folyamatparamétereknek.

  7. A folyamat értékeinek használatához használjon olyan paramétereket, mint például @pipeline().parameters.parameterNamea rendszerváltozók, a folyamatdefiníciókban. Ebben az esetben például az eseményindító kezdési időpontjának olvasásához hivatkozunk @pipeline().parameters.parameter_1.

JSON-séma

A folyamatfuttatások eseményindító-információinak átadásához az eseményindítót és a folyamat JSON-t is frissíteni kell a parameters szakaszsal.

Folyamatdefiníció

properties A szakasz alatt adjon hozzá paraméterdefiníciókat a parameters szakaszhoz.

{
    "name": "demo_pipeline",
    "properties": {
        "activities": [
            {
                "name": "demo_activity",
                "type": "WebActivity",
                "dependsOn": [],
                "policy": {
                    "timeout": "7.00:00:00",
                    "retry": 0,
                    "retryIntervalInSeconds": 30,
                    "secureOutput": false,
                    "secureInput": false
                },
                "userProperties": [],
                "typeProperties": {
                    "url": {
                        "value": "@pipeline().parameters.parameter_2",
                        "type": "Expression"
                    },
                    "method": "GET"
                }
            }
        ],
        "parameters": {
            "parameter_1": {
                "type": "string"
            },
            "parameter_2": {
                "type": "string"
            },
            "parameter_3": {
                "type": "string"
            },
            "parameter_4": {
                "type": "string"
            },
            "parameter_5": {
                "type": "string"
            }
        },
        "annotations": [],
        "lastPublishTime": "2021-02-24T03:06:23Z"
    },
    "type": "Microsoft.DataFactory/factories/pipelines"
}

Triggerdefiníció

pipelines A szakasz alatt rendeljen paraméterértékeket a parameters szakaszhoz. Nem kell minden paraméter adatait megadnia. Csak adja meg azokat, amelyek metaadat-értékeket feltételeznek.

{
    "name": "trigger1",
    "properties": {
        "annotations": [],
        "runtimeState": "Started",
        "pipelines": [
            {
                "pipelineReference": {
                    "referenceName": "demo_pipeline",
                    "type": "PipelineReference"
                },
                "parameters": {
                    "parameter_1": "@trigger().startTime"
                }
            }
        ],
        "type": "ScheduleTrigger",
        "typeProperties": {
            "recurrence": {
                "frequency": "Minute",
                "interval": 15,
                "startTime": "2021-03-03T04:38:00Z",
                "timeZone": "UTC"
            }
        }
    }
}

Eseményindító-információk használata egy folyamatban

A folyamatok értékeinek használatához használjon olyan paramétereket, mint például @pipeline().parameters.parameterNamea rendszerváltozók, a folyamatdefiníciókban.

Kapcsolódó tartalom

Az eseményindítókkal kapcsolatos további információkért lásd a folyamat végrehajtását és az eseményindítókat.