Я хочу перезапустить активность конкретного конвейера на основе некоторых параметров 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
}