Wachtactiviteit uitvoeren in Azure Data Factory en Synapse Analytics

Artikel
12/09/2023

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

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 wachtactiviteit maken met de gebruikersinterface

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

Zoek naar Wachten in het deelvenster Activiteiten van de pijplijn en sleep een wachtactiviteit naar het pijplijncanvas.
Selecteer de nieuwe wachtactiviteit op het canvas als deze nog niet is geselecteerd en het bijbehorende tabblad Instellingen om de details ervan te bewerken.
Voer een aantal seconden in voordat de activiteit moet worden gewacht. 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

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

Opmerking

Notitie

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

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

Bekijk andere ondersteunde controlestroomactiviteiten: