Wachtactiviteit uitvoeren in Azure Data Factory en Synapse Analytics

Als u een Wait Activity in een pijplijn gebruikt, wacht de pijplijn tot de opgegeven periode voorbij is voordat de volgende activiteiten worden uitgevoerd.

Van toepassing op: Azure Data Factory Azure Synapse Analytics

Tip

Data Factory in Microsoft Fabric is de volgende generatie van Azure Data Factory, met een eenvoudigere architectuur, ingebouwde AI en nieuwe functies. Als u nieuw bent in gegevensintegratie, begint u met Fabric Data Factory. Bestaande ADF-workloads kunnen upgraden naar Fabric om toegang te krijgen tot nieuwe mogelijkheden voor gegevenswetenschap, realtime analyses en rapportage.

Een wachtactiviteit maken met de gebruikersinterface

Voer de volgende stappen uit om een wachtactiviteit in een pijplijn te gebruiken:

  1. Zoek naar Wachten in het deelvenster Activiteiten van de pijplijn en sleep een wachtactiviteit naar het pijplijncanvas.

  2. Selecteer de nieuwe wachtactiviteit op het canvas als deze nog niet is geselecteerd en het tabblad Instellingen om de details ervan te bewerken.

    Toont de gebruikersinterface voor een wachtactiviteit.

  3. Voer een aantal seconden in waarop de activiteit moet wachten. Dit kan een letterlijk getal zijn of een combinatie van dynamische expressies, functies, systeemvariabelen of uitvoer van andere activiteiten.

Syntaxis

{
    "name": "MyWaitActivity",
    "type": "Wait",
    "typeProperties": {
        "waitTimeInSeconds": 1
    }
}

Typeeigenschappen

Eigenschap Beschrijving Toegestane waarden Vereist
naam Naam van de Wait activiteit. String Ja
type Moet zijn ingesteld op Wachten. String Ja
wachttijdInSeconden Het aantal seconden dat de pijplijn wacht voordat de verwerking wordt voortgezet. Geheel getal Ja

Voorbeeld

Notitie

Deze sectie bevat JSON-definities en PowerShell-voorbeeldopdrachten om de pijplijn uit te voeren. Zie tutorial: een data factory maken met behulp van Azure PowerShell voor een overzicht van stapsgewijze instructies voor het maken van een pijplijn met behulp van Azure PowerShell- en JSON-definities.

Pijplijn met wachtactiviteit

In dit voorbeeld heeft de pijplijn twee activiteiten: Tot en Wachten. De wachtactiviteit is geconfigureerd om één seconde te wachten. De pijplijn voert de webactiviteit uit in een lus met één seconde wachttijd tussen elke uitvoering.

{
    "name": "DoUntilPipeline",
    "properties": {
        "activities": [
            {
                "type": "Until",
                "typeProperties": {
                    "expression": {
                        "value": "@equals('Failed', coalesce(body('MyUnauthenticatedActivity')?.status, actions('MyUnauthenticatedActivity')?.status, 'null'))",
                        "type": "Expression"
                    },
                    "timeout": "00:10:00",
                    "activities": [
                        {
                            "name": "MyUnauthenticatedActivity",
                            "type": "WebActivity",
                            "typeProperties": {
                                "method": "get",
                                "url": "https://www.fake.com/",
                                "headers": {
                                    "Content-Type": "application/json"
                                }
                            },
                            "dependsOn": [
                                {
                                    "activity": "MyWaitActivity",
                                    "dependencyConditions": [ "Succeeded" ]
                                }
                            ]
                        },
                        {
                            "type": "Wait",
                            "typeProperties": {
                                "waitTimeInSeconds": 1
                            },
                            "name": "MyWaitActivity"
                        }
                    ]
                },
                "name": "MyUntilActivity"
            }
        ]
    }
}

Gerelateerde inhoud

Bekijk andere ondersteunde controlestroomactiviteiten:

  • Last updated on