Dela via

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

  • Artikel

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:

  1. Sök efter Vänta i fönstret Pipelineaktiviteter och dra en Vänta-aktivitet till pipelinearbetsytan.

  2. Välj den nya vänteaktiviteten på arbetsytan om den inte redan är markerad och fliken Inställningar för att redigera dess information.

    Visar användargränssnittet för en vänta-aktivitet.

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

Relaterat innehåll

Se andra kontrollflödesaktiviteter som stöds: