Metadati del trigger di riferimento nelle esecuzioni della pipeline

SI APPLICA A: Azure Data Factory Azure Synapse Analytics

Suggerimento

Provare Data Factory in Microsoft Fabric, una soluzione di analisi completa per le aziende. Microsoft Fabric copre tutti gli elementi, dallo spostamento dei dati all'analisi scientifica dei dati, all'analisi in tempo reale, alla business intelligence e alla creazione di report. Scopri come avviare gratuitamente una nuova versione di valutazione .

Questo articolo descrive come usare i metadati del trigger, ad esempio l'ora di inizio del trigger, nell'esecuzione della pipeline.

La pipeline a volte deve comprendere e leggere i metadati dal trigger che lo richiama. Ad esempio, con l'esecuzione di trigger finestra a cascata, in base all'ora di inizio e di fine della finestra, la pipeline elabora sezioni o cartelle di dati diverse. In Azure Data Factory si usano parametrizzazione e variabile di sistema per passare i metadati dal trigger alla pipeline.

Questo modello è particolarmente utile per il trigger finestra a cascata, in cui il trigger fornisce l'ora di inizio e di fine della finestra e il trigger di evento personalizzato, in cui l'analisi e l'elaborazione dei valori dei trigger nel campo dati definito personalizzato.

Nota

Un tipo di trigger diverso fornisce informazioni sui metadati diverse. Per altre informazioni, vedere Variabile di sistema

Interfaccia utente di Data Factory

Questa sezione illustra come passare le informazioni sui metadati dal trigger alla pipeline all'interno dell'interfaccia utente di Azure Data Factory.

1. Passare all'area di disegno di creazione e modificare una pipeline

2. Selezionare nell'area di disegno vuota per visualizzare le impostazioni della pipeline. Non selezionare alcuna attività. Potrebbe essere necessario estrarre il pannello di impostazione dalla parte inferiore dell'area di disegno, perché potrebbe essere stato compresso

3. Selezionare la sezione Parametri e selezionare + Nuovo per aggiungere parametri

   

4. Aggiungere trigger alla pipeline facendo clic su + Trigger.

5. Creare o collegare un trigger alla pipeline e selezionare OK

6. Dopo aver selezionato OK, viene visualizzata un'altra pagina Nuovo trigger con un elenco dei parametri specificati per la pipeline, come illustrato nello screenshot seguente. In tale pagina compilare i metadati del trigger per ogni parametro. Usare il formato definito in Variabile di sistema per recuperare le informazioni sul trigger. Non è necessario inserire le informazioni per tutti i parametri, ma solo quelle che presuppongono valori di metadati trigger. Ad esempio, qui si assegna l'ora di inizio dell'esecuzione del trigger a parameter_1.

   

7. Per usare i valori nella pipeline, usare i parametri @pipeline().parameters.parameterName, non la variabile di sistema, nelle definizioni della pipeline. Ad esempio, in questo caso, per leggere l'ora di inizio del trigger, si farà riferimento @pipeline().parameters.parameter_1a .

Schema JSON

Per passare le informazioni sul trigger alle esecuzioni della pipeline, è necessario aggiornare sia il trigger che il json della pipeline con la sezione parametri .

Definizione della pipeline

Nella sezione properties aggiungere definizioni di parametri alla sezione parameters

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

Definizione del trigger

Nella sezione pipeline assegnare i valori dei parametri nella sezione parametri . Non è necessario inserire le informazioni per tutti i parametri, ma solo quelle che presuppongono valori di metadati trigger.

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

Usare le informazioni sul trigger nella pipeline

Per usare i valori nella pipeline, usare i parametri @pipeline().parameters.parameterName, non la variabile di sistema, nelle definizioni della pipeline.

Contenuto correlato

Per informazioni dettagliate sui trigger, vedere Esecuzione e trigger di pipeline.