Vytvoření závislosti aktivační události pro přeskakující okno

PLATÍ PRO: Azure Data Factory Azure Synapse Analytics

Tip

Vyzkoušejte si službu Data Factory v Microsoft Fabric, řešení pro analýzy typu all-in-one pro podniky. Microsoft Fabric zahrnuje všechno od přesunu dat až po datové vědy, analýzy v reálném čase, business intelligence a vytváření sestav. Přečtěte si, jak začít používat novou zkušební verzi zdarma.

Tento článek obsahuje postup vytvoření závislosti na triggeru pro přeskakující okno. Obecné informace o aktivačních událostech pro přeskakující okno najdete v tématu Vytvoření aktivační události pro přeskakující okno.

Pokud chcete vytvořit řetěz závislostí a ujistit se, že se trigger spustí až po úspěšném spuštění jiné aktivační události ve službě, použijte tuto pokročilou funkci k vytvoření závislosti přeskakujícího okna.

Ukázku, jak vytvořit závislé kanály pomocí triggeru pro přeskakující okno, najdete v následujícím videu:

Vytvoření závislosti v uživatelském rozhraní

Pokud chcete vytvořit závislost na triggeru, vyberte Aktivovat>> Pak zvolte aktivační událost, na které bude záviset odpovídající posun a velikost. Vyberte Dokončit a publikujte změny, které se projeví u závislostí.

Vlastnosti závislostí přeskakujícího okna

Aktivační událost pro přeskakující okno se závislostí má následující vlastnosti:

{
    "name": "MyTriggerName",
    "properties": {
        "type": "TumblingWindowTrigger",
        "runtimeState": <<Started/Stopped/Disabled - readonly>>,
        "typeProperties": {
            "frequency": <<Minute/Hour>>,
            "interval": <<int>>,
            "startTime": <<datetime>>,
            "endTime": <<datetime - optional>>,
            "delay": <<timespan - optional>>,
            "maxConcurrency": <<int>> (required, max allowed: 50),
            "retryPolicy": {
                "count": <<int - optional, default: 0>>,
                "intervalInSeconds": <<int>>,
            },
            "dependsOn": [
                {
                    "type": "TumblingWindowTriggerDependencyReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan - optional>>,
                    "referenceTrigger": {
                        "referenceName": "MyTumblingWindowDependency1",
                        "type": "TriggerReference"
                    }
                },
                {
                    "type": "SelfDependencyTumblingWindowTriggerReference",
                    "size": <<timespan - optional>>,
                    "offset": <<timespan>>
                }
            ]
        }
    }
}

Následující tabulka obsahuje seznam atributů potřebných k definování závislosti přeskakujícího okna.

Název vlastnosti	Popis	Typ	Požaduje se
type	V tomto rozevíracím seznamu se zobrazí všechny existující aktivační události pro přeskakující okno. Zvolte trigger, na který se má závislost zaměřit.	TumblingWindowTriggerDependencyReference nebo SelfDependencyTumblingWindowTriggerReference	Ano
offset	Posun aktivační události závislosti Zadejte hodnotu ve formátu časového rozsahu. Jsou povoleny záporné i kladné posuny. Tato vlastnost je povinná, pokud je trigger v závislosti na sobě. Ve všech ostatních případech je to volitelné. Závislost sama by měla být vždy negativním posunem. Pokud není zadána žádná hodnota, okno je stejné jako samotná aktivační událost.	Časový interval (hh:mm:ss)	Samostatná závislost: Ano Jiné: Ne
size	Velikost přeskakujícího okna závislostí Zadejte kladnou hodnotu časového rozsahu. Tato vlastnost je nepovinná.	Časový interval (hh:mm:ss)	No

Poznámka:

Aktivační událost pro přeskakující okno může záviset na maximálně pěti dalších aktivačních událostech.

Vlastnosti pro přeskakující okno s vlastním závislostem

Ve scénářích, ve kterých by trigger neměl pokračovat do dalšího okna, dokud se předchozí okno úspěšně nedokončí, vytvořte samostatnou závislost. Trigger závislosti na sobě, který závisí na úspěchu předchozích spuštěních v předchozí hodině, má vlastnosti uvedené v následujícím kódu.

Poznámka:

Pokud váš aktivovaný kanál spoléhá na výstup kanálů v dříve aktivovaných oknech, doporučujeme použít pouze trigger přeskakujícího okna, který je závislý na vlastním nastavení. Chcete-li omezit paralelní spuštění triggeru, nastavte maximální souběžnost aktivačních událostí.

{
    "name": "DemoSelfDependency",
    "properties": {
        "runtimeState": "Started",
        "pipeline": {
            "pipelineReference": {
                "referenceName": "Demo",
                "type": "PipelineReference"
            }
        },
        "type": "TumblingWindowTrigger",
        "typeProperties": {
            "frequency": "Hour",
            "interval": 1,
            "startTime": "2018-10-04T00:00:00Z",
            "delay": "00:01:00",
            "maxConcurrency": 50,
            "retryPolicy": {
                "intervalInSeconds": 30
            },
            "dependsOn": [
                {
                    "type": "SelfDependencyTumblingWindowTriggerReference",
                    "size": "01:00:00",
                    "offset": "-01:00:00"
                }
            ]
        }
    }
}

Scénáře a příklady použití

Následující scénáře ukazují použití vlastností závislostí přeskakujícího okna. V těchto příkladech je potřeba, aby žlutá okna byla úspěšně dokončena před aktivací dalšího spouštěče, a přerušované čáry je spojují s oknem, které se aktivuje po jejich dokončení.

Posun závislostí

V těchto příkladech závisí běh 10–11 pro spouštěč A na běhu ze spouštěče B (zvýrazněné žlutě). Když se běh spouštěče B úspěšně dokončí, spouštěč A se spustí.

Tato závislost může být souběžná (můžou být současně) nebo můžou být posunutá (trigger B, který se spouští v jiném čase než trigger A.)

V prvním příkladu má spouštěcí událost 10–11 A souběžnou závislost na spouštěcí události 10–11 B, takže je časový posun 0.

V druhém příkladu má aktivační událost 10–11 A posun závislý na aktivační události 9–10 B, takže je posun -1 hodin.

Velikost závislosti

V těchto příkladech závisí spuštění 10-11 pro trigger A na spuštění triggeru B (zvýrazněné žlutě), po úspěšném dokončení triggeru B se spustí trigger A.

Velikost okna závislostí může být jiná než velikost závislého okna.

V prvním příkladu má aktivační událost 10–11 A časový posun závislý na triggeru 9-10 B. Časový posun je -1 hodina a velikost je neurčená, protože velikost okna závislosti je stejná jako okno triggeru.

V druhém příkladu má aktivační událost 10–11 A posun závislý na aktivační události 9–11 B, takže posun je -1 hodina a velikost je 2 hodiny.

Samostatná závislost

V těchto příkladech závisí spuštění 10–11 pro trigger A na předchozích spuštěních triggeru A. Po úspěšném dokončení zadaných oken z triggeru A se spustí další trigger A.

V prvním příkladu má aktivační událost 10–11 A posun závislý na aktivační události 9–10 A, takže je posun -1 hodina a velikost nezadaná, protože velikost okna závislosti je stejná jako okno aktivační události.

V druhém příkladu má aktivační událost 10–11 A posun závislý na aktivační události 8–10 A, takže je posun -1 hodin a velikost 2 hodiny.

Tento třetí příklad ukazuje denní úlohu (nikoli hodinovou úlohu) bez mezer ve výstupních datových proudech úlohy.

Časové okno 10/2-10/3 má závislost na oknu 10/1-10/2 a spustí se pouze v případě, že se 10/1-10/2 úspěšně dokončí. Posun je -1 den a velikost není zadána, protože velikost okna závislého objektu je stejná jako okno triggeru.

Závislost na jiné aktivační události pro přeskakující okno

Následující příklad ukazuje úlohu každodenního zpracování telemetrie, která závisí na agregaci jiné každodenní úlohy agregující posledních sedm dnů výstupu a generuje sedmidenní streamy posuvných oken.

Když se úspěšně dokončí období 1.10.-8.10. triggeru B, spustí se trigger A v období 7.10.-8.10. Závislost triggeru A má posun -6 dnů a velikost 7 dnů.

Monitorování závislostí

Na stránce monitorování spuštění triggeru můžete monitorovat řetěz závislostí a odpovídající okna. Přejděte do >. Pokud má aktivační událost pro přeskakující okno závislosti, název triggeru nese hypertextový odkaz na zobrazení monitorování závislostí.

Kliknutím na název triggeru zobrazíte závislosti triggeru. V podokně vpravo se zobrazují informace o spuštění triggeru, jako je ID spuštění, čas okna a stav.

Můžete zobrazit stav závislostí a oken pro jednotlivé závislé triggery. Pokud některý z triggerů závislostí selže, musíte ho úspěšně spustit, aby se spustila závislá aktivační událost.

Aktivační událost pro přeskakující okno čeká na závislosti po dobu sedmi dnů před uplynutím časového limitu. Po sedmi dnech se spuštění triggeru nezdaří.

Poznámka:

Aktivační událost pro přeskakující okno se nedá zrušit, když je ve stavu Čekání na závislost . Závislá aktivita se musí dokončit před zrušením aktivační události pro přeskakující okno. Toto omezení je záměrně, aby se zajistilo, že závislé aktivity se můžou dokončit po spuštění. Pomáhá také snížit pravděpodobnost neočekávaných výsledků.

Pokud chcete zobrazit vizuální způsob zobrazení plánu závislostí triggeru, vyberte zobrazení Ganttova diagramu.

Průhledná pole zobrazují okna závislostí pro jednotlivé triggery závislé na podřízenosti. Plná barevná pole zobrazená na předchozím obrázku zobrazují jednotlivá spuštění oken. Tady je několik tipů pro interpretaci zobrazení Ganttova diagramu:

• Průhledná pole se vykreslí modře, pokud jsou závislá okna ve stavu Čeká na vyřízení nebo Spuštěno .
• Po úspěšném dokončení všech oken pro závislý trigger se průhledné pole změní na zelenou.
• Průhledná pole se v případě selhání závislého okna vykreslují červeně. Vyhledejte plné červené pole pro identifikaci běhu okna selhání.

Pokud chcete znovu spustit okno v zobrazení Ganttova diagramu, vyberte pole plné barvy okna. Zobrazí se podokno akcí s informacemi a možnostmi opětovného spuštění.

Související obsah

• Vytvoření aktivační události pro přeskakující okno