Фабрика данных Azure с использованием Python

Question

Может кто-нибудь сказать мне, как мы можем установить общие функции конвейера Azure в фабрике данных Azure, используя переменную политики, подобную Python (тайм-аут, повтор и т. Д.)?

Answer 1

Пожалуйста, добавьте параметр policy в коде Python:

# 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)

Тест:

Надеюсь, это поможет вам.