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

Vonatkozik: 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 frissíthetők Fabric használatával, hogy elérjék az adatkutatás, a valós idejű elemzés és a jelentéskészítés új képességeit.

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 csővezetékeknek néha meg kell érteniük és be kell olvasniuk a metaadatokat az azt meghívó eseményindítóból. Ha például egy csúszó ablak eseményindító meghajtja, az ablak kezdési és befejezési ideje alapján a folyamat különböző adatszeleteket vagy mappákat dolgoz fel. A Azure Data Factory paraméterezést és rendszerváltozókat használunk a metaadatok triggerekből folyamatokba való továbbításához.

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 pipeline-t.

  2. Válassza ki az üres vásznat 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 azokat töltse ki, amelyek trigger metaadat-értékeket kapnak. 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ékek felhasználásához használjon paramétereket, például @pipeline().parameters.parameterName és ne rendszerváltozókat, 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.

Csővezetékdefiní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_1",
                        "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"
}

Trigger definíció

pipelines A szakasz alatt rendeljen paraméterértékeket a parameters szakaszhoz. Nem kell minden paraméter adatait megadnia. Csak azokat töltse ki, amelyek trigger metaadat-értékeket kapnak.

{
    "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 csővezetékben

A pipeline értékeinek használatához a paramétereket, nem pedig a rendszerváltozókat, használd 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.

  • Last updated on