Azure Sinapse: Como utilizar a Atividade da Web para Consulta API REST do Pipeline de Dados?

0

Pergunta

Como posso usar Sinapse atividades na Web para consulta de um pipeline de execução? Em particular, pretende extrair a mensagem de erro em caso de falha.

A configuração inicial é o seguinte, seguinte a solicitação GET postado por documentação: https://docs.microsoft.com/en-us/rest/api/synapse/data-plane/pipeline-run/get-pipeline-run#clouderror

https://i.stack.imgur.com/Ud14y.png

Para obter o RunId do pipeline, eu simplesmente use este código: activity('Execute Pipeline1').output.pipelineRunId

Quando eu inspecionar o que foi enviado na solicitação GET, abaixo, eu vejo que ele tem, de fato, extraído de um pipelineRunId, mas não com o que está listado no painel de depuração abaixo.

https://i.stack.imgur.com/HaSHM.png

Eu suspeito que este é o problema, mas como posso obter o pipeline de Execução de Identificação para a exata execução que foi executado e o que é mostrado abaixo?

Editar

A adição de no pipeline de Execução Identificações que eu posso consultar; mas eu não posso consultar o pipeline que foi apenas correu.

https://i.stack.imgur.com/UcyO4.png

azure azure-synapse
2021-11-23 19:45:24
2
0

Eu acredito que há uma confusão entre o pipeline runID e atividade runID.

enter image description here

Inorder para obter o pipeline filho runID você terá que usar esta expressão dinâmica - @activity('ExecutePipelineParent').output.pipelineRunId

Conforme as imagens compartilhadas por você, parece que você está passando o correto pipeline filho runID para a atividade de web.

Eu não vejo qualquer problema com a extração do pipeline runID. Encerra se a sua atividade na web está falhando, você terá que passar a mensagem de erro específico relacionado com a atividade da Web de configuração para descobrir a causa raiz.

2021-11-30 22:17:04

Obrigado por esclarecer isso. Eu posso pipeline de consulta é executada com êxito com que a Atividade da Web, desde que eu uso um Run ID (coluna) de a Monitor > Pipeline runs seção Sinapse. Parece que não importa se eu usar @activity('ExecutePipelineParent').output.pipelineRunId ou @{pipeline().RunId} -- ambos irão retornar nenhum resultado, um erro 404.
John Stud
0

As fotos mostram que o duto não foi publicado. Possível, é a leitura do pipelineId desde a última versão publicada? Também não seria melhor usar a variável de Sistema @{pipeline().RunId}?

2021-11-30 22:38:41

Em outros idiomas

Esta página está em outros idiomas

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................