in SamplesV1/ParameterizedPipelinesForAzureML/DeployDataFactory/DeployDataFactory/ScoringPipeline.cs [44:119]
private static void CreatePipelines(
string resourceGroupName,
string dataFactoryName,
DataFactoryManagementClient client,
string inputDataset,
IList<string> outputDatasets,
string[] parameters)
{
int i = 0;
foreach (string parameter in parameters)
{
string[] parameterList = parameter.Split(',');
string region = parameterList[0];
// create a pipeline
DateTime PipelineActivePeriodStartTime = DateTime.Parse(DataFactoryConfig.PipelineStartTime);
DateTime PipelineActivePeriodEndTime = PipelineActivePeriodStartTime.AddMinutes(DataFactoryConfig.MinutesToAddToStartTimeForEndTime);
string PipelineName = String.Format("ScoringPipeline_{0}", region);
Console.WriteLine("Creating a pipeline {0}", PipelineName);
client.Pipelines.CreateOrUpdate(resourceGroupName, dataFactoryName,
new PipelineCreateOrUpdateParameters()
{
Pipeline = new Pipeline()
{
Name = PipelineName,
Properties = new PipelineProperties()
{
Description = "Pipeline for scoring",
// Initial value for pipeline's active period.
Start = PipelineActivePeriodStartTime,
End = PipelineActivePeriodEndTime,
Activities = new List<Activity>()
{
new Activity()
{
Name = "AzureMLBatchScoring",
Inputs = new List<ActivityInput>()
{
new ActivityInput() {
Name = inputDataset
}
},
Outputs = new List<ActivityOutput>()
{
new ActivityOutput()
{
Name = outputDatasets[i]
}
},
// Note: The linked service names referenced here are generated previously by the retraining pipeline code.
LinkedServiceName = Utilities.GetScoringLinkedServiceName(DataFactoryConfig.ScoringLinkedServiceNamePrefix, region),
TypeProperties = new AzureMLBatchExecutionActivity()
{
WebServiceInput = inputDataset,
WebServiceOutputs = new Dictionary<string, string>
{
{"output1", outputDatasets[i]}
},
GlobalParameters = new Dictionary<string, string>
{
{"starttime", "$$Text.Format('\\'{0:yyyy-MM-dd HH:mm:ss}\\'', WindowStart)"},
{"endtime", "$$Text.Format('\\'{0:yyyy-MM-dd HH:mm:ss}\\'', WindowEnd)"},
{"cpf", region}
}
}
}
},
}
}
});
i++;
}
}