Criar uma dependência de acionamento de janela em cascataCreate a tumbling window trigger dependency

APLICA-SE A: Azure Data Factory Azure Synapse Analytics

Este artigo fornece passos para criar uma dependência de um gatilho de janela caindo.This article provides steps to create a dependency on a tumbling window trigger. Para obter informações gerais sobre os gatilhos da Janela Tumbling, consulte Como criar o gatilho da janela .For general information about Tumbling Window triggers, see How to create tumbling window trigger.

Para construir uma cadeia de dependência e certificar-se de que um gatilho é executado apenas após a execução bem sucedida de outro gatilho na fábrica de dados, utilize esta funcionalidade avançada para criar uma dependência de janelas caindo.In order to build a dependency chain and make sure that a trigger is executed only after the successful execution of another trigger in the data factory, use this advanced feature to create a tumbling window dependency.

Para uma demonstração de como criar oleodutos dependentes na sua Fábrica de Dados Azure utilizando o gatilho da janela caindo, veja o seguinte vídeo:For a demonstration on how to create dependent pipelines in your Azure Data Factory using tumbling window trigger, watch the following video:

Criar uma dependência na UI da Fábrica de DadosCreate a dependency in the Data Factory UI

Para criar dependência de um gatilho, selecione Trigger > Advanced > New, e, em seguida, escolha o gatilho para depender do offset e do tamanho apropriados.To create dependency on a trigger, select Trigger > Advanced > New, and then choose the trigger to depend on with the appropriate offset and size. Selecione Terminar e publicar as alterações na fábrica de dados para que as dependências entrem em vigor.Select Finish and publish the data factory changes for the dependencies to take effect.

Criação de DependênciaDependency Creation

Propriedades de dependência de janelas caindoTumbling window dependency properties

Um gatilho de janela caindo com uma dependência tem as seguintes propriedades:A tumbling window trigger with a dependency has the following properties:

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

A tabela seguinte fornece a lista de atributos necessários para definir uma dependência da Janela Tumbling.The following table provides the list of attributes needed to define a Tumbling Window dependency.

Nome da PropriedadeProperty Name DescriçãoDescription TipoType ObrigatórioRequired
tipotype Todos os gatilhos da janela de caindo existentes são apresentados nesta queda.All the existing tumbling window triggers are displayed in this drop down. Escolha o gatilho para assumir a dependência.Choose the trigger to take dependency on. TumblingWindowTriggerDependencyReference ou SelfDependencyTumblingWindowTriggerReferenceTumblingWindowTriggerDependencyReference or SelfDependencyTumblingWindowTriggerReference YesYes
offsetoffset Compensação do gatilho da dependência.Offset of the dependency trigger. Fornecer um valor no formato de tempo e tanto compensações negativas como positivas são permitidas.Provide a value in time span format and both negative and positive offsets are allowed. Esta propriedade é obrigatória se o gatilho depender de si mesmo e em todos os outros casos é opcional.This property is mandatory if the trigger is depending on itself and in all other cases it is optional. A auto-dependência deve ser sempre uma compensação negativa.Self-dependency should always be a negative offset. Se nenhum valor especificado, a janela é a mesma que o gatilho em si.If no value specified, the window is the same as the trigger itself. TimespanTimespan
(hh:mm:ss)(hh:mm:ss)
Auto-dependência: SimSelf-Dependency: Yes
Outros: NãoOther: No
sizesize Tamanho da janela de caindo de dependência.Size of the dependency tumbling window. Fornecer um valor de tempos positivo.Provide a positive timespan value. Esta propriedade é opcional.This property is optional. TimespanTimespan
(hh:mm:ss)(hh:mm:ss)
NoNo

Nota

Um gatilho da janela caindo pode depender de um máximo de cinco outros gatilhos.A tumbling window trigger can depend on a maximum of five other triggers.

Propriedades de auto-dependência da janela caindoTumbling window self-dependency properties

Em cenários em que o gatilho não deve seguir para a janela seguinte até que a janela anterior esteja concluída com sucesso, construa uma auto-dependência.In scenarios where the trigger shouldn't proceed to the next window until the preceding window is successfully completed, build a self-dependency. Um gatilho de auto-dependência que depende do sucesso de execuções anteriores de si mesmo dentro da hora anterior terá as propriedades indicadas no seguinte código.A self-dependency trigger that's dependent on the success of earlier runs of itself within the preceding hour will have the properties indicated in the following code.

Nota

Se o seu gasoduto acionado depender da saída de gasodutos em janelas previamente acionadas, recomendamos que utilize apenas a auto-dependência do gatilho da janela.If your triggered pipeline relies on the output of pipelines in previously triggered windows, we recommend using only tumbling window trigger self-dependency. Para limitar as execuções paralelas do gatilho, desloe o gatilho máximo.To limit parallel trigger runs, set the maximimum trigger concurrency.

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

Cenários e exemplos de utilizaçãoUsage scenarios and examples

Abaixo estão ilustrações de cenários e uso de propriedades de dependência de janelas caindo.Below are illustrations of scenarios and usage of tumbling window dependency properties.

Compensação de dependênciaDependency offset

Exemplo de offsetOffset Example

Tamanho da dependênciaDependency size

Exemplo de tamanhoSize example

Auto-dependênciaSelf-dependency

Auto-dependênciaSelf-dependency

Dependência de outro gatilho da janela caindoDependency on another tumbling window trigger

Um trabalho diário de processamento de telemetria dependendo de outro trabalho diário agregando a produção dos últimos sete dias e gera fluxos de janelas rolantes de sete dias:A daily telemetry processing job depending on another daily job aggregating the last seven days output and generates seven day rolling window streams:

Exemplo de dependênciaDependency example

Dependência de si mesmaDependency on itself

Um trabalho diário sem lacunas nos fluxos de saída do trabalho:A daily job with no gaps in the output streams of the job:

Exemplo de auto-dependênciaSelf-dependency example

Monitorizar dependênciasMonitor dependencies

Pode monitorizar a cadeia de dependência e as janelas correspondentes a partir da página de monitorização do gatilho.You can monitor the dependency chain and the corresponding windows from the trigger run monitoring page. Navegue para monitorizar > Trigger Runs.Navigate to Monitoring > Trigger Runs. Se um gatilho da janela de ingrção tiver dependências, o Nome do Gatilho terá uma hiperligação para a visão de monitorização da dependência.If a Tumbling Window trigger has dependencies, Trigger Name will bear a hyperlink to dependency monitoring view.

Monitorizar execuções acionadasMonitor trigger runs

Clique no nome do gatilho para ver as dependências do gatilho.Click through the trigger name to view trigger dependencies. O painel da direita mostra informações detalhadas sobre o gatilho, tais como RunID, tempo de janela, estado, e assim por diante.Right-hand panel shows detailed trigger run information, such as RunID, window time, status, and so on.

Vista da lista de dependências do monitorMonitor dependencies list view

Pode ver o estado das dependências e janelas para cada gatilho dependente.You can see the status of the dependencies, and windows for each dependent trigger. Se um dos gatilhos de dependência falhar, deve reenca encontrá-lo com sucesso para que o gatilho dependente possa funcionar.If one of the dependencies triggers fails, you must successfully rerun it in order for the dependent trigger to run.

Um gatilho da janela caindo vai esperar de dependências por sete dias antes de sair. Após sete dias, o gatilho falhará.A tumbling window trigger will wait on dependencies for seven days before timing out. After seven days, the trigger run will fail.

Para uma visualização mais visual do calendário de dependência do gatilho, selecione a vista Gantt.For a more visual to view the trigger dependency schedule, select the Gantt view.

Gráfico de gantt de dependências de monitorizaçãoMonitor dependencies gantt chart

As caixas transparentes mostram as janelas de dependência de cada gatilho dependente do fluxo, enquanto caixas coloridas sólidas acima mostram corridas individuais de janelas.Transparent boxes show the dependency windows for each down stream-dependent trigger, while solid colored boxes above show individual window runs. Aqui ficam algumas dicas para interpretar a vista do gráfico de Gantt:Here are some tips for interpreting the Gantt chart view:

  • Caixa transparente torna azul quando as janelas dependentes estão em estado pendente ou em funcionamentoTransparent box renders blue when dependent windows are in pending or running state
  • Depois de todas as janelas ter sucesso para um gatilho dependente, a caixa transparente vai ficar verdeAfter all windows succeeds for a dependent trigger, the transparent box will turn green
  • A caixa transparente torna-se vermelha quando alguma janela dependente falha.Transparent box renders red when some dependent window fails. Procure uma caixa vermelha sólida para identificar a janela de falhaLook for a solid red box to identify the failure window run

Para refazer uma janela na vista do gráfico de Gantt, selecione a caixa de cores sólida para a janela, e um painel de ação aparecerá com detalhes e opções de repetiçãoTo rerun a window in Gantt chart view, select the solid color box for the window, and an action panel will pop up with details and rerun options

Passos seguintesNext steps