Pijplijnuitvoering en triggers in Azure Data Factory of Azure Synapse Analytics

  • Artikel

VAN TOEPASSING OP: Azure Data Factory Azure Synapse Analytics

Tip

Probeer Data Factory uit in Microsoft Fabric, een alles-in-één analyseoplossing voor ondernemingen. Microsoft Fabric omvat alles, van gegevensverplaatsing tot gegevenswetenschap, realtime analyses, business intelligence en rapportage. Meer informatie over het gratis starten van een nieuwe proefversie .

Een pijplijnuitvoering in Azure Data Factory en Azure Synapse definieert een exemplaar van een pijplijnuitvoering. Stel dat u een pijplijn hebt die wordt uitgevoerd om 8:00 uur, 9:00 uur en 10:00 uur. In dit geval wordt de pijplijn drie keer afzonderlijk uitgevoerd, ook wel pijplijnuitvoeringen genoemd. Elke pijplijnuitvoering heeft een unieke id. Een uitvoerings-id is een GUID die de betreffende specifieke pijplijnuitvoering definieert.

Pijplijnuitvoeringen worden doorgaans geïnstantieerd doordat argumenten worden doorgegeven aan parameters die u in de pijplijn definieert. U kunt een pijplijn handmatig uitvoeren of door middel van een trigger. Dit artikel bevat informatie over beide manieren om een pijplijn uit te voeren.

Triggers maken met de gebruikersinterface

Als u handmatig een pijplijn wilt activeren of een nieuwe geplande, tumblingvenster, opslag gebeurtenis of aangepaste gebeurtenistrigger wilt configureren, selecteert u Trigger toevoegen bovenaan de pijplijneditor.

Shows how to add a new trigger with UI from the pipeline editor.

Als u ervoor kiest om de pijplijn handmatig te activeren, wordt deze onmiddellijk uitgevoerd. Als u Nieuw/Bewerken kiest, wordt u gevraagd om een bestaande trigger te kiezen die u wilt bewerken of een nieuwe trigger te maken.

Shows the add triggers window highlighting where to create a new trigger.

U ziet het venster triggerconfiguratie, zodat u het triggertype kunt kiezen.

Shows the new trigger configuration window with the type dropdown showing the various types of triggers you can create.

Meer informatie over geplande, tumblingvensters, opslagevenementen en aangepaste gebeurtenistriggers hieronder.

Handmatige uitvoering (op aanvraag) met JSON

De handmatige uitvoering van een pijplijn wordt ook wel een uitvoering op aanvraag genoemd.

Stel dat u een eenvoudige pijplijn met de naam copyPipeline hebt die u wilt uitvoeren. De pijplijn heeft één activiteit, waarmee items worden gekopieerd uit een bronmap in Azure Blob Storage naar een doelmap in dezelfde opslagplaats. In de volgende JSON-definitie wordt dit voorbeeld getoond:

{
    "name": "copyPipeline",
    "properties": {
        "activities": [
            {
                "type": "Copy",
                "typeProperties": {
                    "source": {
                        "type": "BlobSource"
                    },
                    "sink": {
                        "type": "BlobSink"
                    }
                },
                "name": "CopyBlobtoBlob",
                "inputs": [
                    {
                        "referenceName": "sourceBlobDataset",
                        "type": "DatasetReference"
                    }
                ],
                "outputs": [
                    {
                        "referenceName": "sinkBlobDataset",
                        "type": "DatasetReference"
                    }
                ]
            }
        ],
        "parameters": {
            "sourceBlobContainer": {
                "type": "String"
            },
            "sinkBlobContainer": {
                "type": "String"
            }
        }
    }
}

In de JSON-definitie heeft de pijplijn twee parameters: sourceBlobContainer en sinkBlobContainer. Tijdens runtime geeft u waarden door aan deze parameters.

U kunt de pijplijn handmatig uitvoeren met een van de volgende methoden:

  • .NET SDK
  • Azure PowerShell-module
  • REST-API
  • Python SDK

REST-API

In de volgende voorbeeldopdracht ziet u hoe u uw pijplijn handmatig uitvoert met behulp van de REST API:

POST
https://management.azure.com/subscriptions/mySubId/resourceGroups/myResourceGroup/providers/Microsoft.DataFactory/factories/myDataFactory/pipelines/copyPipeline/createRun?api-version=2017-03-01-preview

Zie Snelstart: een Azure data factory en pijplijn maken door de REST-API te gebruiken voor het volledige voorbeeld.

Azure PowerShell

Notitie

Het wordt aanbevolen de Azure Az PowerShell-module te gebruiken om te communiceren met Azure. Zie Azure PowerShell installeren om aan de slag te gaan. Raadpleeg Azure PowerShell migreren van AzureRM naar Az om te leren hoe u naar de Azure PowerShell-module migreert.

In de volgende voorbeeldopdracht wordt getoond hoe u de pijplijn handmatig kunt uitvoeren met behulp van Azure PowerShell:

Invoke-AzDataFactoryV2Pipeline -DataFactory $df -PipelineName "Adfv2QuickStartPipeline" -ParameterFile .\PipelineParameters.json -ResourceGroupName "myResourceGroup"

U kunt parameters doorgeven in de hoofdtekst van de nettolading van de aanvraag. In de .NET SDK, in Azure Powershell en in de Python SDK geeft u waarden in een woordenlijst door als een argument naar de aanroep:

{
  "sourceBlobContainer": "MySourceFolder",
  "sinkBlobContainer": "MySinkFolder"
}

De nettolading van de reactie is een unieke ID van de pijplijnuitvoering:

{
  "runId": "0448d45a-a0bd-23f3-90a5-bfeea9264aed"
}

Zie Snelstart: een data factory in Azure maken met behulp van Azure PowerShell voor een volledig voorbeeld.

.NET SDK

In de volgende voorbeeldoproep ziet u hoe u uw pijplijn handmatig uitvoert met behulp van de .NET SDK:

client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroup, dataFactoryName, pipelineName, parameters)

Zie Snelstart: een data factory en pijplijn maken met behulp van .NET SDK voor een volledig voorbeeld.

Notitie

U kunt de .NET SDK gebruiken om pijplijnen aan te roepen vanuit Azure Functions, vanuit uw webservices, enzovoort.

Uitvoering activeren met JSON

Triggers zijn een andere manier om een pijplijnuitvoering te starten. Triggers zijn verwerkingseenheden die bepalen wanneer een pijplijnuitvoering moet worden gestart. Momenteel ondersteunt de service drie typen triggers:

  • Schematrigger: een trigger die een pijplijn volgens een wandklokschema aanroept.

  • Tumblingvenstertrigger: een trigger die volgens een periodiek interval werkt terwijl de status behouden blijft.

  • Trigger op basis van gebeurtenissen: een trigger die reageert op een gebeurtenis.

Pijplijnen en triggers hebben een veel-op-veelrelatie (behalve voor de tumblingvenstertrigger). Meerdere triggers kunnen één pijplijn starten en één trigger kan meerdere pijplijnen starten. In de volgende triggerdefinitie verwijst de eigenschap pijplijnen naar een lijst met pijplijnen die worden geactiveerd door de bijbehorende trigger. In de definitie van de eigenschap zijn waarden opgenomen voor de pijplijnparameters.

Basisdefinitie voor trigger

{
    "properties": {
        "name": "MyTrigger",
        "type": "<type of trigger>",
        "typeProperties": {...},
        "pipelines": [
            {
                "pipelineReference": {
                    "type": "PipelineReference",
                    "referenceName": "<Name of your pipeline>"
                },
                "parameters": {
                    "<parameter 1 Name>": {
                        "type": "Expression",
                        "value": "<parameter 1 Value>"
                    },
                    "<parameter 2 Name>": "<parameter 2 Value>"
                }
            }
        ]
    }
}

Trigger plannen met JSON

Schematriggers voeren pijplijnen uit volgens een wandklokschema. De trigger ondersteunt periodieke en geavanceerde kalenderopties. De trigger ondersteunt bijvoorbeeld intervallen zoals 'wekelijks' of 'maandag om 17:00 uur en donderdag om 19:00 uur'. De schematrigger is flexibel omdat het gegevenssetpatroon agnostisch is en de trigger geen onderscheid maakt tussen tijdreeks- en niet-tijdreeksgegevens.

Zie Een trigger maken waarmee een pijplijn volgens een planning wordt uitgevoerd voor meer informatie over schematriggers en voor voorbeelden.

Schematrigger: definitie

Wanneer u een schematrigger maakt, geeft u het schema en een terugkeerpatroon op met behulp van een JSON-definitie.

Als u wilt dat de schematrigger een pijplijnuitvoering activeert, moet u een verwijzing naar de betreffende pijplijn opnemen in de definitie van de trigger. Pijplijnen en triggers hebben een veel-op-veel-relatie. Meerdere triggers kunnen één pijplijn activeren. Eén trigger kan meerdere pijplijnen activeren.

{
  "properties": {
    "type": "ScheduleTrigger",
    "typeProperties": {
      "recurrence": {
        "frequency": <<Minute, Hour, Day, Week, Year>>,
        "interval": <<int>>, // How often to fire
        "startTime": <<datetime>>,
        "endTime": <<datetime>>,
        "timeZone": "UTC",
        "schedule": { // Optional (advanced scheduling specifics)
          "hours": [<<0-24>>],
          "weekDays": [<<Monday-Sunday>>],
          "minutes": [<<0-60>>],
          "monthDays": [<<1-31>>],
          "monthlyOccurrences": [
            {
              "day": <<Monday-Sunday>>,
              "occurrence": <<1-5>>
            }
          ]
        }
      }
    },
  "pipelines": [
    {
      "pipelineReference": {
        "type": "PipelineReference",
        "referenceName": "<Name of your pipeline>"
      },
      "parameters": {
        "<parameter 1 Name>": {
          "type": "Expression",
          "value": "<parameter 1 Value>"
        },
        "<parameter 2 Name>": "<parameter 2 Value>"
      }
    }
  ]}
}

Belangrijk

De eigenschap parameters is een verplichte eigenschap van het element pijplijnen. Als de pijplijn geen parameters aanneemt, dient u een lege JSON-definitie op te nemen voor de eigenschap parameters.

Schemaoverzicht

De volgende tabel bevat een overzicht van de belangrijkste schema-elementen die betrekking hebben op het terugkeerpatroon en het schema van een trigger:

JSON-eigenschap Beschrijving
startTime Een datum/tijdwaarde. Voor eenvoudige schema's is de waarde startTime van toepassing op de eerste gebeurtenis. In complexe schema's begint de trigger niet eerder dan de opgegeven waarde voor startTime.
endTime De einddatum en -tijd voor de trigger. De trigger wordt na de opgegeven einddatum en -tijd niet uitgevoerd. De waarde voor de eigenschap kan niet in het verleden liggen.
timeZone De tijdzone. Zie Een trigger maken waarmee een pijplijn volgens een schema wordt uitgevoerd voor een lijst met ondersteunde tijdzones.
recurrence Een recurrence-object bepaalt de regels voor het terugkeerpatroon van de trigger. Het recurrence-object ondersteunt de elementen frequency, interval, endTime, count en schedule. Als een recurrence-object wordt gedefinieerd, is het element frequency vereist. De overige elementen van het recurrence-object zijn optioneel.
frequency Hiermee geeft u de frequentie aan waarmee de trigger wordt uitgevoerd. De ondersteunde waarden omvatten 'minuut', 'uur', 'dag', 'week' en 'maand'.
interval Een positief geheel getal dat het interval voor de waarde frequency aangeeft. De waarde frequency bepaalt hoe vaak de trigger wordt uitgevoerd. Als interval bijvoorbeeld 3 is en frequency 'week', dan wordt de trigger elke drie weken uitgevoerd.
schedule Het terugkeerschema voor de trigger. Een trigger met een opgegeven waarde voor frequency wijzigt het terugkeerpatroon op basis van een terugkeerschema. De eigenschap property bevat wijzigingen voor het terugkeerpatroon en zijn gebaseerd op minuten, uren, weekdagen, maanddagen en weeknummer.

Voorbeeld van schedule-trigger

{
  "properties": {
    "name": "MyTrigger",
    "type": "ScheduleTrigger",
    "typeProperties": {
      "recurrence": {
        "frequency": "Hour",
        "interval": 1,
        "startTime": "2017-11-01T09:00:00-08:00",
        "endTime": "2017-11-02T22:00:00-08:00"
      }
    },
    "pipelines": [{
        "pipelineReference": {
          "type": "PipelineReference",
          "referenceName": "SQLServerToBlobPipeline"
        },
        "parameters": {}
      },
      {
        "pipelineReference": {
          "type": "PipelineReference",
          "referenceName": "SQLServerToAzureSQLPipeline"
        },
        "parameters": {}
      }
    ]
  }
}

Standaardschemawaarden, limieten en voorbeelden

JSON-eigenschap Type Vereist Default value Geldige waarden Opmerking
startTime tekenreeks Ja None Datums en tijden volgens ISO 8601 "startTime" : "2013-01-09T09:30:00-08:00"
recurrence object Ja None Een recurrence-object "recurrence" : { "frequency" : "monthly", "interval" : 1 }
interval Nummer Nee 1 1 tot 1000 "interval":10
endTime tekenreeks Ja None Een datum/tijdwaarde die een toekomstig tijdstip aangeeft "endTime" : "2013-02-09T09:30:00-08:00"
schedule object Nee Geen Een schedule-object "schedule" : { "minute" : [30], "hour" : [8,17] }

Eigenschap startTime

In de volgende tabel ziet u hoe de eigenschap startTime de uitvoering van een trigger bepaalt:

startTime-waarde Recurrence zonder schedule Recurrence met schedule
Starttijd ligt in het verleden Berekent de eerstvolgende uitvoering na de starttijd en voert deze op dat moment uit.

Voert volgende uitvoeringen uit die zijn bekend op basis van de tijd waarop de laatste uitvoering heeft plaatsgevonden.

Zie het voorbeeld onder deze tabel.		 De trigger wordt nooit vóór de opgegeven begintijd geactiveerd. De eerste uitvoering is gebaseerd op de planning die wordt berekend op basis van de starttijd.

Volgende uitvoeringen worden op basis van het terugkeerschema uitgevoerd.
Starttijd ligt in de toekomst of op de huidige tijd Uitvoering vindt eenmaal plaats op de opgegeven starttijd.

Voert volgende uitvoeringen uit die zijn bekend op basis van de tijd waarop de laatste uitvoering heeft plaatsgevonden.		 De trigger wordt nooit vóór de opgegeven begintijd geactiveerd. De eerste uitvoering is gebaseerd op de planning die wordt berekend op basis van de starttijd.

Volgende uitvoeringen worden op basis van het terugkeerschema uitgevoerd.

Laten we eens kijken naar een voorbeeld van wat er gebeurt wanneer de startTime in het verleden ligt en er een terugkeerpatroon (recurrence), maar geen schema (schedule) is opgegeven. Neem aan dat de huidige tijd 2017-04-08 13:00 is, de starttijd 2017-04-07 14:00 en het terugkeerpatroon om de dag. (De terugkeerwaarde wordt gedefinieerd door de frequentie-eigenschap in te stellen op 'dag' en de intervaleigenschap op 2.) U ziet dat de waarde startTime zich in het verleden bevindt en vóór de huidige tijd plaatsvindt.

In deze omstandigheden vindt de eerste uitvoering plaats op 2017-04-09 at 14:00. De scheduler-engine berekent uitvoeringen vanaf de startTime. Alle uitvoeringen in het verleden worden genegeerd. De engine gebruikt de eerstvolgende uitvoering die in de toekomst plaatsvindt. In dit scenario is de starttijd 2017-04-07 om 14:00 uur. De volgende uitvoering is twee dagen daarna op 2017-04-09 om 14:00 uur.

De eerste uitvoeringstijd is de hetzelfde, zelfs als startTime 2017-04-05 14:00 of 2017-04-01 14:00 is. Na de eerste uitvoering worden volgende uitvoeringen berekend met behulp van het schema. Daarom vinden de volgende uitvoeringen plaats op 2017-04-11 om 14:00 uur, op 2017-04-13 om 14:00 uur en op 2017-04-15 om 14:00 uur enzovoort.

Ten slotte worden de uren of minuten die niet zijn ingesteld in het schema voor een trigger, de uren of minuten van de eerste uitvoering gebruikt als standaardwaarden.

Eigenschap schedule

U kunt schedule gebruiken om het aantal uitvoeringen door een trigger te beperken. Als een trigger met de frequency 'maand' bijvoorbeeld een schedule-waarde heeft die alleen wordt uitgevoerd op dag 31, wordt de trigger alleen uitgevoerd in maanden die een 31e dag hebben.

Anderzijds kunt u schedule gebruiken om het aantal uitvoeringen door een trigger uit te breiden. Bijvoorbeeld: een trigger met een geplande maandfrequentie voor uitvoering op de maanddagen 1 en 2, wordt uitgevoerd op de eerste en tweede dag van de maand, in plaats van eenmaal per maand.

Als er meerdere planningselementen zijn opgegeven, is de evaluatievolgorde van de grootste tot de kleinste planningsinstelling: weeknummer, maanddag, weekdag, uur, minuut.

In de volgende tabel worden de schedule-elementen in detail beschreven:

JSON-element Beschrijving Geldige waarden
minutes Minuten van het uur waarop de trigger wordt uitgevoerd. - Geheel getal
- Matrix van gehele getallen
hours Uren van de dag waarop de trigger wordt uitgevoerd. - Geheel getal
- Matrix van gehele getallen
weekDays Dagen van de week waarop de trigger wordt uitgevoerd. De waarde kan alleen worden opgegeven met een weekfrequentie.
- maandag
- dinsdag
- woensdag
- donderdag
- vrijdag
- zaterdag
- zondag
- Matrix met dagwaarden (maximale grootte van de matrix is 7)

Dagwaarden zijn niet hoofdlettergevoelig
monthlyOccurrences Dagen van de maand waarop de trigger wordt uitgevoerd. De waarde kan alleen worden opgegeven met een maandfrequentie. - Matrix van monthlyOccurrence-objecten : { "day": day, "occurrence": occurrence }
- Het attribuut day is de dag van de week waarop de trigger wordt uitgevoerd. Zo betekent de eigenschap monthlyOccurrences met een waarde day van {Sunday} dat er elke zondag van de maand een uitvoering is. Het attribuut day is verplicht.
- Het attribuut occurrence slaat op het uitvoeren van de trigger op de opgegeven dag, day, tijdens de maand. Zo betekent de eigenschap monthlyOccurrences met de waarden day en occurrence van {Sunday, -1} dat er elke laatste zondag van de maand een uitvoering is. Het attribuut occurrence is optioneel.
monthDays Dagen van de maand waarop de trigger wordt uitgevoerd. De waarde kan alleen worden opgegeven met een maandfrequentie. - Elke waarde <= -1 en >= -31
- Elke waarde >= 1 en <= 31
- Matrix met waarden

Tumblingvenstertrigger

Tumblingvenstertriggers zijn triggers die vanaf een opgegeven begintijd worden geactiveerd met een periodiek tijdsinterval en die hun status behouden. Tumblingvensters bestaan uit een reeks niet-overlappende en aaneengesloten tijdsintervallen van vaste duur.

Zie Een tumblingvenstertrigger maken voor meer informatie over tumblingvenstertriggers en voor voorbeelden een tumblingvenstertrigger maken.

Voorbeelden van schema's voor uitvoeringen van triggers

Dit gedeelte bevat voorbeelden van schema's met terugkeerpatronen. Dit artikel gaat over het schedule-object en de bijbehorende elementen.

In de voorbeelden wordt ervan uitgegaan dat de intervalwaarde 1 is en dat de frequentiewaarde juist is volgens de planningsdefinitie. De waarde voor frequency kan bijvoorbeeld niet tegelijkertijd 'day' zijn én een wijziging monthDays in het schedule-object hebben. Dit soort beperkingen wordt beschreven in de tabel in het vorige gedeelte.

Opmerking Beschrijving
{"hours":[5]} Wordt elke dag om 5:00 uur uitgevoerd.
{"minutes":[15], "hours":[5]} Wordt elke dag om 5:15 uur uitgevoerd.
{"minutes":[15], "hours":[5,17]} Wordt elke dag om 05:15 en 17:15 uur uitgevoerd.
{"minutes":[15,45], "hours":[5,17]} Wordt elke dag om 05:15, 5:45, 17:15 en 17:45 uur uitgevoerd.
{"minutes":[0,15,30,45]} Wordt elke 15 minuten uitgevoerd.
{hours":[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23]} Wordt elk uur uitgevoerd.

Deze trigger wordt elk uur uitgevoerd. De minuten worden door de waarde startTime bepaald (indien opgegeven). Als er geen waarde is opgegeven, worden de minuten bepaald door de aanmaaktijd. Als de starttijd of aanmaaktijd (afhankelijk van wat van toepassing is) bijvoorbeeld 12:25 uur is, wordt de trigger uitgevoerd om 00:25, 01:25, 02:25, ..., en 23:25 uur.

Dit schema komt overeen met een trigger met frequency 'uur', interval 1 en geen waarde voor schedule. Dit schema kan worden gebruikt met verschillende waarden voor frequency en interval om andere triggers te maken. Als bijvoorbeeld de waarde frequency 'maand' is, dan wordt het schema slechts eenmaal per maand uitgevoerd in plaats van elke dag (als frequency 'dag' is).
{"minutes":[0]} Wordt elk uur op het hele uur uitgevoerd.

Deze trigger wordt elk uur op het hele uur uitgevoerd, te beginnen om 00:00 uur en vervolgens om 1:00 uur, 2:00 uur enzovoort.

Dit schema is gelijkwaardig met een trigger met frequency 'uur' en startTime nul minuten, en met schedule zonder waarde en frequency 'dag'. Als de waarde voor frequency 'week' of 'maand' is, wordt het schema respectievelijk één dag per week of één dag per maand uitgevoerd.
{"minutes":[15]} Wordt 15 minuten na elk uur uitgevoerd.

Deze trigger wordt elke 15 minuten na het hele uur uitgevoerd, te beginnen om 00:15 uur, en vervolgens om 1:15 uur, 2:15 uur, met de laatste uitvoering om 23:15 uur.
{"hours":[17], "weekDays":["saturday"]} Wordt elke week op zaterdag om 17:00 uur uitgevoerd.
{"hours":[17], "weekDays":["monday", "wednesday", "friday"]} Wordt elke week op maandag, woensdag en vrijdag om 17:00 uur uitgevoerd.
{"minutes":[15,45], "hours":[17], "weekDays":["monday", "wednesday", "friday"]} Wordt elke week op maandag, woensdag en vrijdag om 17:15 en 17:45 uur uitgevoerd.
{"minutes":[0,15,30,45], "weekDays":["monday", "tuesday", "wednesday", "thursday", "friday"]} Wordt op weekdagen elke 15 minuten uitgevoerd.
{"minutes":[0,15,30,45], "hours": [9, 10, 11, 12, 13, 14, 15, 16] "weekDays":["monday", "tuesday", "wednesday", "thursday", "friday"]} Wordt op weekdagen elke 15 minuten tussen 9:00 en 16:45 uur uitgevoerd.
{"weekDays":["tuesday", "thursday"]} Wordt op dinsdag en donderdag op de opgegeven begintijd uitgevoerd.
{"minutes":[0], "hours":[6], "monthDays":[28]} Wordt op dag 28 van elke maand om 6:00 uur uitgevoerd (bij een waarde voor frequency van 'maand').
{"minutes":[0], "hours":[6], "monthDays":[-1]} Wordt op de laatste dag van de maand om 6:00 uur uitgevoerd.

Als u een trigger wilt uitvoeren op de laatste dag van een maand, gebruik dan -1 in plaats van dag 28, 29, 30 of 31.
{"minutes":[0], "hours":[6], "monthDays":[1,-1]} Wordt op de eerste en laatste dag van elke maand om 6:00 uur uitgevoerd.
{monthDays":[1,14]} Wordt uitgevoerd op de eerste en veertiende dag van elke maand op de opgegeven begintijd.
{"minutes":[0], "hours":[5], "monthlyOccurrences":[{"day":"friday", "occurrence":1}]} Wordt op de eerste vrijdagdag van elke maand om 5:00 uur uitgevoerd.
{"monthlyOccurrences":[{"day":"friday", "occurrence":1}]} Wordt op de eerste vrijdag van elke maand op de opgegeven begintijd uitgevoerd.
{"monthlyOccurrences":[{"day":"friday", "occurrence":-3}]} Wordt op de derde vrijdag vanaf het eind van de maand elke maand op de opgegeven begintijd uitgevoerd.
{"minutes":[15], "hours":[5], "monthlyOccurrences":[{"day":"friday", "occurrence":1},{"day":"friday", "occurrence":-1}]} Wordt op de eerste en laatste vrijdagdag van elke maand om 5:15 uur uitgevoerd.
{"monthlyOccurrences":[{"day":"friday", "occurrence":1},{"day":"friday", "occurrence":-1}]} Wordt op de eerste en laatste vrijdag van elke maand op de opgegeven begintijd uitgevoerd.
{"monthlyOccurrences":[{"day":"friday", "occurrence":5}]} Wordt op de vijfde vrijdag van elke maand op de opgegeven begintijd uitgevoerd.

Wanneer er geen vijfde vrijdag in een maand voorkomt, wordt de pijplijn niet uitgevoerd. Als u de trigger op de laatste vrijdag van de maand wilt uitvoeren, kunt u voor occurrence de waarde -1 gebruiken in plaats van 5.
{"minutes":[0,15,30,45], "monthlyOccurrences":[{"day":"friday", "occurrence":-1}]} Wordt op de laatste vrijdag van de maand elke 15 minuten uitgevoerd.
{"minutes":[15,45], "hours":[5,17], "monthlyOccurrences":[{"day":"wednesday", "occurrence":3}]} Wordt elke maand op de derde woensdag om 5:15, 5:45, 17:15 en 17:45 uur uitgevoerd.

Vergelijking triggertypen

Tumblingvenstertriggers en de schematrigger werken beide volgens tijdschema's. Hoe verschillen ze van elkaar?

Notitie

De uitvoering van de tumblingvenstertrigger wacht totdat de geactiveerde pijplijnuitvoering is voltooid. De uitvoeringsstatus weerspiegelt de status van de geactiveerde pijplijnuitvoering. Als een geactiveerde pijplijnuitvoering bijvoorbeeld wordt geannuleerd, wordt de bijbehorende tumblingvenstertriggeruitvoering gemarkeerd als geannuleerd. Dit verschilt van het gedrag 'fire and forget' van de schematrigger, die is gemarkeerd als geslaagd zolang een pijplijnuitvoering is gestart.

In de volgende tabel wordt een vergelijking weergegeven tussen de tumblingvenstertrigger en de schematrigger:

Item Tumblingvenstertrigger Schematrigger
Backfill-scenario's Ondersteund. Pijplijnuitvoeringen kunnen voor tijdvensters in het verleden worden gepland. Wordt niet ondersteund. Pijplijnuitvoeringen kunnen alleen worden uitgevoerd in perioden vanaf de huidige tijd.
Betrouwbaarheid 100% betrouwbaarheid. Pijplijnuitvoeringen kunnen vanaf een bepaalde begindatum zonder onderbrekingen worden uitgevoerd voor alle tijdvensters. Minder betrouwbaar.
Mogelijkheid voor nieuwe uitvoerpogingen Ondersteund. Nieuwe pogingen van pijplijnuitvoeringen vinden plaats volgens het standaardbeleid van 0 of volgens een beleid dat de gebruiker in de triggerdefinitie heeft opgegeven. Er worden automatisch nieuwe pogingen uitgevoerd wanneer de pijplijn mislukt vanwege gelijktijdigheids-/server-/beperkingslimieten (dat wil gezegd: statuscodes 400: Gebruikersfout, 429: Te veel aanvragen en 500: Interne serverfout). Wordt niet ondersteund.
Gelijktijdigheid Ondersteund. Gebruikers kunnen expliciet gelijktijdigheidsbeperkingen voor de trigger instellen. Het is mogelijk om tussen de 1 en 50 door triggers geactiveerde pijplijnuitvoeringen gelijktijdig uit te voeren. Wordt niet ondersteund.
Systeemvariabelen @trigger().scheduledTime@trigger().startTimeDaarnaast ondersteunt het ook het gebruik van de systeemvariabelen WindowStart en WindowEnd. Gebruikers kunnen voor de triggerdefinitie gebruikmaken van trigger().outputs.windowStartTime en trigger().outputs.windowEndTime als systeemvariabelen in de trigger. De waarden worden respectievelijk als de begin- en eindtijd van het tijdvenster gebruikt. Voor bijvoorbeeld een tumblingvenstertrigger die elk uur wordt uitgevoerd in het tijdvenster 1:00 uur tot 2:00 uur, is de definitie trigger().outputs.windowStartTime = 2017-09-01T01:00:00Z en trigger().outputs.windowEndTime = 2017-09-01T02:00:00Z. Ondersteunt alleen standaard @trigger().scheduledTime - en @trigger().startTime variabelen.
Pipeline-trigger-relatie Ondersteunt een een-op-een-relatie. Slechts één pijplijn kan worden geactiveerd. Ondersteunt veel-op-veel-relaties. Meerdere triggers kunnen één pijplijn activeren. Eén trigger kan meerdere pijplijnen activeren.

Trigger op basis van gebeurtenissen

Een trigger op basis van gebeurtenissen voert pijplijnen uit als reactie op een gebeurtenis. Er zijn twee soorten triggers op basis van gebeurtenissen.

  • Met de trigger voor opslaggebeurtenissen wordt een pijplijn uitgevoerd op gebeurtenissen die plaatsvinden in een opslagaccount, zoals de aankomst van een bestand of het verwijderen van een bestand in een Azure Blob Storage-account.
  • Aangepaste gebeurtenistriggerprocessen en verwerkt aangepaste artikelen in Event Grid

Zie Opslaggebeurtenistrigger en Aangepaste gebeurtenistrigger voor meer informatie over triggers op basis van gebeurtenissen.

Gerelateerde inhoud

Zie de volgende zelfstudies: