Köra wait-aktivitet i Azure Data Factory och Synapse Analytics

Artikel
12/09/2023

När du använder en Wait-aktivitet i en pipeline väntar pipelinen under den angivna tidsperioden innan körningen återupptas med alla efterföljande aktiviteter.

GÄLLER FÖR: Azure Data Factory Azure Synapse Analytics

Dricks

Prova Data Factory i Microsoft Fabric, en allt-i-ett-analyslösning för företag. Microsoft Fabric omfattar allt från dataflytt till datavetenskap, realtidsanalys, business intelligence och rapportering. Lär dig hur du startar en ny utvärderingsversion kostnadsfritt!

Skapa en vänta-aktivitet med användargränssnittet

Utför följande steg för att använda en vänteaktivitet i en pipeline:

Sök efter Vänta i fönstret Pipelineaktiviteter och dra en Vänta-aktivitet till pipelinearbetsytan.
Välj den nya wait-aktiviteten på arbetsytan om den inte redan är markerad och fliken Inställningar för att redigera dess information.
Ange ett antal sekunder för aktiviteten att vänta. Det kan vara ett literalnummer eller en kombination av dynamiska uttryck, funktioner, systemvariabler eller utdata från andra aktiviteter.

Syntax

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

Typegenskaper

Property	beskrivning	Tillåtna värden	Obligatoriskt
name	Namnet på `Wait` aktiviteten.	String	Ja
type	Måste vara inställt på Vänta.	String	Ja
waitTimeInSeconds	Antalet sekunder som pipelinen väntar innan bearbetningen fortsätter.	Integer	Ja

Exempel

Kommentar

Det här avsnittet innehåller JSON-definitioner och PowerShell-exempelkommandon för att köra pipelinen. En genomgång med stegvisa instruktioner för att skapa en pipeline med hjälp av Azure PowerShell- och JSON-definitioner finns i självstudie: skapa en datafabrik med hjälp av Azure PowerShell.

Pipeline med vänteaktivitet

I det här exemplet har pipelinen två aktiviteter: Tills och Vänta. Wait-aktiviteten har konfigurerats för att vänta en sekund. Pipelinen kör webbaktiviteten i en loop med en sekunds väntetid mellan varje körning.

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

Se andra kontrollflödesaktiviteter som stöds: