Azure Datalake Перезапустите действие, используя windostart и windowEnd. - PullRequest
0 голосов
/ 18 января 2019

Я хочу перезапустить активность конкретного конвейера на основе некоторых параметров windowStart и windowEnd. Как я могу перезапустить эту конкретную операцию?

   public static void Activityrerun(DataFactoryManagementClient client1, string resourceGroupName, string dataFactoryName)
    {
        var pipe = client1.Pipelines.List(resourceGroupName, dataFactoryName);
        foreach (var p in pipe.Pipelines)
        {
            Console.WriteLine(p.Name);
            var parameters = new ActivityWindowsByDataFactoryListParameters(resourceGroupName, dataFactoryName);
            //parameters.WindowState = "Failed";
            DateTime d = new DateTime(2019, 1, 17, 08, 30, 0,DateTimeKind.Utc);
            parameters.WindowStart = d;
            parameters.WindowEnd = d.AddDays(1);
            var response = client1.ActivityWindows.List(parameters);
            do
            {
                foreach (var activityWindow in response.ActivityWindowListResponseValue.ActivityWindows)
                {
                    var row = string.Join(
                        "\t",
                        activityWindow.WindowStart.ToString(),
                        activityWindow.WindowEnd.ToString(),
                        activityWindow.RunStart.ToString(),
                        activityWindow.RunEnd.ToString(),
                        activityWindow.DataFactoryName,
                        activityWindow.PipelineName,
                        activityWindow.ActivityName,
                        string.Join(",", activityWindow.OutputDatasets));
                        Console.WriteLine(row);
                    //rerun code here



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