Azure Synapse: Как использовать веб-активность для запроса данных конвейера REST API?

Question 1

Как я могу использовать веб-активность Synapse для запроса выполнения конвейера? В частности, я хочу извлечь сообщение об ошибке в случае сбоя.

Первоначальная настройка выглядит следующим образом, следуя запросу GET, опубликованному в документации: https://docs.microsoft.com/en-us/rest/api/synapse/data-plane/pipeline-run/get-pipeline-run#clouderror

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

Чтобы получить идентификатор запуска конвейера, я просто использую этот код: activity('Execute Pipeline1').output.pipelineRunId

Когда я проверяю, что было отправлено в запросе GET ниже, я вижу, что он действительно извлек идентификатор конвейера, но не тот, который указан на панели отладки ниже.

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

Я подозреваю, что в этом проблема, но как я могу получить идентификатор запуска конвейера для точного запуска, который был выполнен и показан ниже?

Редактировать

Добавление идентификаторов запуска конвейера, которые я могу запросить; но я не могу запросить только что запущенный конвейер.

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

Question 2

Я считаю, что существует путаница между RunID конвейера и RunID активности.

Для того чтобы получить идентификатор запуска дочернего конвейера, вам придется использовать это динамическое выражение - @activity('ExecutePipelineParent').output.pipelineRunId

Согласно скриншотам, которыми вы поделились, похоже, что вы передаете правильный идентификатор запуска дочернего конвейера в веб-действие.

Я не вижу никаких проблем с извлечением RunID конвейера. В случае сбоя вашей веб-активности вам придется просмотреть конкретное сообщение об ошибке, связанное с настройкой веб-активности, чтобы выяснить основную причину.

Question 3

Ваши фотографии показывают, что ваш конвейер не был опубликован. Возможно, это чтение идентификатора конвейера из последней опубликованной версии? Также не было бы лучше использовать системную переменную @{pipeline().RunID}?

KranthiPakala-MSFT · Answer 1 · 2021-11-30T22:17:04

Я считаю, что существует путаница между RunID конвейера и RunID активности.

Для того чтобы получить идентификатор запуска дочернего конвейера, вам придется использовать это динамическое выражение - @activity('ExecutePipelineParent').output.pipelineRunId

Согласно скриншотам, которыми вы поделились, похоже, что вы передаете правильный идентификатор запуска дочернего конвейера в веб-действие.

Я не вижу никаких проблем с извлечением RunID конвейера. В случае сбоя вашей веб-активности вам придется просмотреть конкретное сообщение об ошибке, связанное с настройкой веб-активности, чтобы выяснить основную причину.

Спасибо, что прояснили это. Я могу успешно выполнить конвейер запросов с помощью этой веб-активности, если я использую Run ID (колонка) из Monitor > Pipeline runs секция в Синапсе. Похоже, что независимо от того, использую ли я @activity('ExecutePipelineParent').output.pipelineRunId или @{pipeline().RunId} -- оба не вернут никаких результатов, ошибка 404.

Le Poissons · Answer 2 · 2021-11-30T22:38:41

Ваши фотографии показывают, что ваш конвейер не был опубликован. Возможно, это чтение идентификатора конвейера из последней опубликованной версии? Также не было бы лучше использовать системную переменную @{pipeline().RunID}?

Azure Synapse: Как использовать веб-активность для запроса данных конвейера REST API?

Вопрос

Редактировать

На других языках

Эта страница на других языках

Популярное в этой категории

Популярные вопросы в этой категории