Referenční metadata triggeru v spuštěních kanálu

PLATÍ PRO: Azure Data Factory Azure Synapse Analytics

Tip

Vyzkoušejte si službu Data Factory v Microsoft Fabric, řešení pro analýzy typu all-in-one pro podniky. Microsoft Fabric zahrnuje všechno od přesunu dat až po datové vědy, analýzy v reálném čase, business intelligence a vytváření sestav. Přečtěte si, jak začít používat novou zkušební verzi zdarma.

Tento článek popisuje, jak se dají při spuštění kanálu použít metadata triggeru, například čas spuštění triggeru.

Kanál někdy potřebuje pochopit a číst metadata z triggeru, který ho vyvolá. Například při spuštění triggeru přeskakujícího okna na základě počátečního a koncového času okna kanál zpracovává různé datové řezy nebo složky. Ve službě Azure Data Factory používáme parametrizaci a systémové proměnné k předávání metadat z triggerů do kanálů.

Tento vzor je užitečný zejména pro aktivační události pro přeskakující okno, kde trigger poskytuje počáteční a koncový čas okna a vlastní triggery událostí, kde trigger analyzuje a zpracovává hodnoty ve vlastním definovaném datovém poli.

Poznámka:

Různé typy triggerů poskytují různé informace o metadatech. Další informace naleznete v tématu Systémové proměnné.

Uživatelské rozhraní Data Factory

V této části se dozvíte, jak předat informace o metadatech z triggerů do kanálů v uživatelském rozhraní služby Data Factory.

1. Přejděte na plátno pro vytváření obsahu a upravte kanál.

2. Výběrem prázdného plátna zobrazíte nastavení kanálu. Nevybírejte žádnou aktivitu. Možná budete muset vytáhnout podokno nastavení z dolní části plátna, protože může být sbalené.

3. Vyberte kartu Parametry a vyberte + Nový a přidejte parametry.

   

4. Přidejte do kanálu triggery výběrem + Aktivační událost.

5. Vytvořte nebo připojte trigger ke kanálu a vyberte OK.

6. Po výběru možnosti OK se zobrazí další stránka Nová aktivační událost se seznamem parametrů zadaných pro kanál, jak je znázorněno na následujícím snímku obrazovky. Na této stránce vyplňte metadata triggeru pro každý parametr. K načtení informací o triggeru použijte formát definovaný v systémových proměnných . Nemusíte vyplňovat informace pro všechny parametry. Stačí vyplnit hodnoty, které budou předpokládat hodnoty metadat triggeru. Tady například přiřadíme čas spuštění triggeru .parameter_1

   

7. Pokud chcete použít hodnoty v kanálu, použijte v definicích kanálu parametry, jako @pipeline().parameters.parameterNamenapříklad , ne systémové proměnné. Například v tomto případě ke čtení času spuštění triggeru odkazujeme @pipeline().parameters.parameter_1.

Schéma JSON

Pokud chcete předat informace o triggeru pro spuštění kanálu, musí se aktivační událost i JSON kanálu aktualizovat pomocí oddílu parameters .

Definice kanálu

properties V části přidejte do oddílu parameters definice parametrů.

{
    "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"
}

Definice triggeru

pipelines V části přiřaďte hodnoty parametrů v oddíluparameters. Nemusíte vyplňovat informace pro všechny parametry. Stačí vyplnit hodnoty, které budou předpokládat hodnoty metadat triggeru.

{
    "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"
            }
        }
    }
}

Použití informací o triggeru v kanálu

Pokud chcete použít hodnoty v kanálu, použijte v definicích kanálu parametry, jako @pipeline().parameters.parameterNamenapříklad , ne systémové proměnné.

Související obsah

Další informace o aktivačních událostech najdete v tématu Spouštění kanálů a triggery.