Várakozási tevékenység végrehajtása az Azure Data Factoryben és a Synapse Analyticsben

Cikk
12/09/2023

Ha Wait tevékenységet használ egy folyamatban, akkor a folyamat kivárja a megadott időtartamot, és csak az után folytatja a további tevékenységek futtatását.

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Várakozási tevékenység létrehozása felhasználói felülettel

Ha várakozási tevékenységet szeretne használni egy folyamatban, hajtsa végre a következő lépéseket:

Keressen rá a Várakozás gombra a folyamattevékenységek panelen, és húzza a várakozási tevékenységet a folyamatvászonra.
Jelölje ki az új várakozási tevékenységet a vásznon, ha még nincs kijelölve, és a Gépház lapot a részletek szerkesztéséhez.
Adjon meg néhány másodpercet, amíg a tevékenység várakozni szeretne. Ez lehet egy literális szám, vagy a dinamikus kifejezések, függvények, rendszerváltozók vagy más tevékenységek kimeneteinek bármilyen kombinációja.

Syntax

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

Típustulajdonságok

Property	Leírás	Megengedett értékek	Szükséges
név	`Wait` A tevékenység neve.	Sztring	Igen
típus	Várakozás értékre kell állítani.	Sztring	Igen
waitTimeInSeconds	A folyamat által a feldolgozás folytatása előtt várakozó másodpercek száma.	Egész	Igen

Példa

Megjegyzés:

Ez a szakasz JSON-definíciókat és PowerShell-mintaparancsokat tartalmaz a folyamat futtatásához. A folyamat Azure PowerShell- és JSON-definíciókkal történő létrehozásához szükséges részletes útmutatást az alábbi oktatóanyagban találja : adat-előállító létrehozása az Azure PowerShell használatával.

Várakozási tevékenységgel rendelkező folyamat

Ebben a példában a folyamat két tevékenységgel rendelkezik: Until and Wait. A várakozási tevékenység úgy van konfigurálva, hogy egy másodpercig várjon. A folyamat egy ciklusban futtatja a webes tevékenységet egy másodperc várakozási idővel az egyes futtatások között.

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

Lásd az egyéb támogatott vezérlési folyamatokat: