使用Python的Azure数据工厂-Java 学习之路

有人能告诉我如何使用Python（如策略变量（超时，重试等））在Azure数据工厂中设置Azure管道的一般功能吗？

1 回答

请在你的python代码中添加 policy 参数：

# Create a copy activity
act_name = 'copyBlobtoBlob'
blob_source = BlobSource()
blob_sink = BlobSink()

policy = {"timeout": "1.00:00:00",
          "concurrency": 1,
          "executionPriorityOrder": "NewestFirst",
          "style": "StartOfInterval",
          "retry": 3,
          "longRetry": 0,
          "longRetryInterval": "00:00:00"}

copy_activity = CopyActivity(act_name, source=blob_source, sink=blob_sink,
                             policy=policy)

# Create a pipeline with the copy activity
p_name = 'copyPipeline'
params_for_pipeline = {}
p_obj = PipelineResource(activities=[copy_activity], parameters=params_for_pipeline)
p = adf_client.pipelines.create_or_update(rg_name, df_name, p_name, p_obj)

测试：

enter image description here

希望它能帮到你 .

回复于 2024-05-01T12:28:15+08:00

使用Python的Azure数据工厂

1 回答

相关问题