当前位置: 代码迷 >> 综合 >> Azure Data Factory 详解
  详细解决方案

Azure Data Factory 详解

热度:9   发布时间:2023-12-09 22:52:29.0

output的dataset会depend on 其时间跨度内的input dataset的ready

只有其时间跨度内 input的dataset的slice都完成了, 它才执行


client.Pipelines.CreateOrUpdate(resourceGroupName, dataFactoryName,new PipelineCreateOrUpdateParameters(){Pipeline = new Pipeline(){Name = pip.Pipeline.Name,Properties = new PipelineProperties(){//Description = "Description",// Initial value for pipeline's active period. With this, you won't need to set slice status//Start = PipelineActivePeriodStartTime,//End = PipelineActivePeriodEndTime,Activities = new List(){new Activity(){Name = "PatientPayerODSAct",Inputs = new List(){new ActivityInput() {Name = "PatientOnPrem"},new ActivityInput() {Name = "PatientPayerOnPrem"}},Outputs = new List(){new ActivityOutput(){Name = "PatientPayerODS"}},TypeProperties = new CopyActivity(){Source = s,Sink = new SqlSink(){WriteBatchSize = 0,WriteBatchTimeout = TimeSpan.FromMinutes(0)}}}}}}}
);


  相关解决方案