Как проверить текущий статус последнего запуска конвейера фабрики данных с именем конвейера? - PullRequest
0 голосов
/ 28 мая 2020

Можно ли проверить текущее состояние последнего запуска конвейера фабрики данных с именем конвейера с помощью. NET SDK? Вот что я пробовал сейчас:

             using (var client = new DataFactoryManagementClient(cred) {SubscriptionId = subscriptionId})
            {
                RunQueryFilter pipeline = new RunQueryFilter("PipelineName", "Equals", new List<string> { "Pipeline" });                

                var before = DateTime.UtcNow;
                var after = before.AddHours(-24);
                var param = new RunFilterParameters(after, before, null, new List<RunQueryFilter> { pipeline }, null);
                PipelineRunsQueryResponse pipelineResponse = client.PipelineRuns.QueryByFactory(
                                                                        resourceGroup,
                                                                        dataFactoryName, param
                                                                    );



            }

How do I get latest run id?

1 Ответ

0 голосов
/ 28 мая 2020

разобрался -

using (var client = new DataFactoryManagementClient(cred) {SubscriptionId = subscriptionId})
            {
                RunQueryFilter pipeline = new RunQueryFilter("PipelineName", "Equals", new List<string> { "Pipeline" });                
                var pipelineRuns = new RunQueryOrderBy("RunEnd", "DESC");
                var before = DateTime.UtcNow;
                var after = before.AddHours(-24);
                var param = new RunFilterParameters(after, before, null, new List<RunQueryFilter> { pipeline }, new List<RunQueryOrderBy> { pipelineRuns });
                PipelineRunsQueryResponse pipelineResponse = client.PipelineRuns.QueryByFactory(
                                                                        resourceGroup,
                                                                        dataFactoryName, param
                                                                    );

                var runId = pipelineResponse?.Value?[0]?.RunId;

            }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...