Creare un trigger per l'esecuzione di una pipeline in una finestra a cascata

SI APPLICA A: Azure Data Factory Azure Synapse Analytics

Questo articolo descrive la procedura per creare, avviare e monitorare un trigger di finestra a cascata. Per informazioni generali sui trigger e i tipi supportati, vedere Esecuzione e trigger di pipeline.

I trigger di finestra a cascata vengono attivati in base a un intervallo di tempo periodico a partire da un'ora di inizio specificata, mantenendo al tempo stesso lo stato. Le finestre a cascata sono costituite da una serie di intervalli temporali di dimensioni fisse, contigui e non sovrapposti. Un trigger di finestra a cascata ha una relazione uno a uno con una pipeline e può fare riferimento solo a una singola pipeline.

Un trigger periodico è un'alternativa più pesante per un trigger di pianificazione. Offre una gamma di funzionalità per scenari complessi, ad esempio dipendenze da altri trigger periodici, ripetizione dell'esecuzione di un processo non riuscito e impostazione della ripetizione dei tentativi dell'utente per le pipeline. Per una migliore comprensione della differenza tra un trigger di pianificazione e un trigger periodico, vedere Confronto tra tipi di trigger.

Esperienza del portale di Azure Data Factory e Azure Synapse

1. Per creare un trigger periodico nel portale di Azure, selezionare la scheda Trigger e quindi selezionare Nuovo.
2. Dopo l'apertura del riquadro di configurazione del trigger, selezionare Finestra a cascata. Definire quindi le proprietà del trigger periodico.
3. Al termine selezionare Salva.

Proprietà del tipo di trigger di finestra a cascata

Una finestra a cascata ha le proprietà del tipo di trigger seguenti:

{
    "name": "MyTriggerName",
    "properties": {
        "type": "TumblingWindowTrigger",
        "runtimeState": "<<Started/Stopped/Disabled - readonly>>",
        "typeProperties": {
            "frequency": <<Minute/Hour>>,
            "interval": <<int>>,
            "startTime": "<<datetime>>",
            "endTime": <<datetime - optional>>,
            "delay": <<timespan - optional>>,
            "maxConcurrency": <<int>> (required, max allowed: 50),
            "retryPolicy": {
                "count": <<int - optional, default: 0>>,
                "intervalInSeconds": <<int>>,
            },
            "dependsOn": [
                {
                    "type": "TumblingWindowTriggerDependencyReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan - optional>>,
                    "referenceTrigger": {
                        "referenceName": "MyTumblingWindowDependency1",
                        "type": "TriggerReference"
                    }
                },
                {
                    "type": "SelfDependencyTumblingWindowTriggerReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan>>
                }
            ]
        },
        "pipeline": {
            "pipelineReference": {
                "type": "PipelineReference",
                "referenceName": "MyPipelineName"
            },
            "parameters": {
                "parameter1": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowStartTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "parameter2": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowEndTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "parameter3": "https://mydemo.azurewebsites.net/api/demoapi"
            }
        }
    }
}

La tabella seguente fornisce una panoramica generale degli elementi JSON principali correlati alla ricorrenza e alla pianificazione di un trigger periodico.

Variabili di sistema WindowStart e WindowEnd

È possibile usare le variabili di sistema WindowStart e WindowEnd del trigger periodico nella definizione della pipeline, ovvero per una parte di una query. Passare le variabili di sistema come parametri alla pipeline nella definizione del trigger. L'esempio seguente mostra come passare tali variabili come parametri.

{
    "name": "MyTriggerName",
    "properties": {
        "type": "TumblingWindowTrigger",
            ...
        "pipeline": {
            "pipelineReference": {
                "type": "PipelineReference",
                "referenceName": "MyPipelineName"
            },
            "parameters": {
                "MyWindowStart": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowStartTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                },
                "MyWindowEnd": {
                    "type": "Expression",
                    "value": "@{concat('output',formatDateTime(trigger().outputs.windowEndTime,'-dd-MM-yyyy-HH-mm-ss-ffff'))}"
                }
            }
        }
    }
}

Per usare i valori delle variabili di sistema WindowStart e WindowEnd nella definizione della pipeline, usare i parametri MyWindowStart e MyWindowEnd di conseguenza.

Ordine di esecuzione delle finestre in uno scenario di recupero delle informazioni

Se il trigger startTime risale al passato, in base alla formula M=(CurrentTime- TriggerStartTime)/TumblingWindowSize, il trigger genera {M} backfill(past) esecuzioni in parallelo, rispettando la concorrenza dei trigger, prima di eseguire le esecuzioni future. L'ordine di esecuzione per le finestre è deterministico, dagli intervalli meno recenti ai più recenti. Attualmente non è possibile modificare questo comportamento.

Elementi TriggerResource esistenti

I punti seguenti si applicano all'aggiornamento degli elementi TriggerResource esistenti:

• Il valore per l'elemento frequency (o dimensioni della finestra) del trigger insieme all'elemento interval non può essere modificato dopo la creazione del trigger. Questa restrizione è necessaria per il corretto funzionamento delle riesecuzioni di triggerRun e delle valutazioni delle dipendenze.
• Se il valore per l'elemento endTime del trigger viene modificato (aggiunto o aggiornato), lo stato delle finestre che sono già elaborate non viene reimpostato. Il trigger rispetta il nuovo valore endTime. Se il nuovo valore endTime è precedente alle finestre già eseguite, il trigger si interrompe. In caso contrario, il trigger si interrompe quando viene rilevato il nuovo valore endTime.

Tentativi assegnati dall'utente delle pipeline

In caso di errori della pipeline, un trigger periodico può ritentare l'esecuzione della pipeline di riferimento automaticamente usando gli stessi parametri di input, senza l'intervento dell'utente. Usare la proprietà retryPolicy nella definizione del trigger per specificare questa azione.

Dipendenza del trigger periodico

Se ci si vuole assicurare che un trigger periodico venga eseguito solo dopo l'esecuzione corretta di un altro trigger periodico nella data factory, creare una dipendenza di trigger periodico.

Annullare l'esecuzione di una finestra a cascata

È possibile annullare le esecuzioni per un trigger periodico se lo stato della finestra specifica è In attesa, In attesa della dipendenza o In esecuzione:

• Se lo stato della finestra è In esecuzione, annullare l'Esecuzione della pipeline associata. L'esecuzione del trigger viene contrassegnata come Annullata successivamente.
• Se lo stato della finestra è In attesa o In attesa della dipendenza, è possibile annullare la finestra da Monitoraggio.

È anche possibile rieseguire una finestra annullata. La riesecuzione accetta le definizioni pubblicate più recenti del trigger. Le dipendenze per la finestra specificata vengono rivalutate alla riesecuzione.

Esempio per Azure PowerShell e l'interfaccia della riga di comando di Azure

Per monitorare le esecuzioni di trigger e pipeline nel portale di Azure, vedere Monitorare le esecuzioni di pipeline.

Contenuto correlato

• Esecuzione e trigger della pipeline
• Creare una dipendenza del trigger periodico
• Riferimento ai metadati del trigger nelle esecuzioni della pipeline