Azure 数据工厂 Python SDK 创建触发器
Azure Data Factory Python SDK Create Trigger
我正在使用 Azure 数据工厂 Python SDK 创建触发器 here。不幸的是,它不起作用,我收到了一条非常神秘的错误消息。
我正在使用以下代码(根据示例):
tr_name = 'mytrigger'
scheduler_recurrence = ScheduleTriggerRecurrence(frequency='Minute', interval='15',start_time='2017-12-12T04:00:00Z', end_time='2017-12-12T05:00:00Z', time_zone='UTC')
pipeline_parameters = {'inputPath':'adftutorial/input', 'outputPath':'adftutorial/output'}
pipelines_to_run = []
pipeline_reference = PipelineReference(reference_name='copyPipeline')
pipelines_to_run.append(TriggerPipelineReference(pipeline_reference=pipeline_reference, parameters=pipeline_parameters))
tr_properties = ScheduleTrigger(description='My scheduler trigger', pipelines = pipelines_to_run, recurrence=scheduler_recurrence)
adf_client.triggers.create_or_update(rg_name, df_name, tr_name, tr_properties)
我得到的错误是:
azure.core.exceptions.HttpResponseError: (InvalidPropertyValue) Invalid value for property 'Properties'
Code: InvalidPropertyValue
Message: Invalid value for property 'Properties'
Target: mytrigger
这根本没有告诉我太多信息:-(。有人以前见过这个吗?我正在努力弄清楚这个问题。我一直在寻找一个属性 Properties
,但没有好像没有。有没有好的调试方法?
要解决此 azure.core.exceptions.HttpResponseError: (InvalidPropertyValue) Invalid value for property 'Properties'
错误:
而不是:
tr_properties = ScheduleTrigger(description='My scheduler trigger', pipelines = pipelines_to_run, recurrence=scheduler_recurrence)
你可以试试这个:
tr_properties = TriggerResource(properties=ScheduleTrigger(description='My scheduler trigger',pipelines=pipelines_to_run,recurrence=scheduler_recurrence))
可以参考Bad body serialization creating a Schedule Trigger in Data Factory and Azure data factory trigger creation using python SDK
我正在使用 Azure 数据工厂 Python SDK 创建触发器 here。不幸的是,它不起作用,我收到了一条非常神秘的错误消息。
我正在使用以下代码(根据示例):
tr_name = 'mytrigger'
scheduler_recurrence = ScheduleTriggerRecurrence(frequency='Minute', interval='15',start_time='2017-12-12T04:00:00Z', end_time='2017-12-12T05:00:00Z', time_zone='UTC')
pipeline_parameters = {'inputPath':'adftutorial/input', 'outputPath':'adftutorial/output'}
pipelines_to_run = []
pipeline_reference = PipelineReference(reference_name='copyPipeline')
pipelines_to_run.append(TriggerPipelineReference(pipeline_reference=pipeline_reference, parameters=pipeline_parameters))
tr_properties = ScheduleTrigger(description='My scheduler trigger', pipelines = pipelines_to_run, recurrence=scheduler_recurrence)
adf_client.triggers.create_or_update(rg_name, df_name, tr_name, tr_properties)
我得到的错误是:
azure.core.exceptions.HttpResponseError: (InvalidPropertyValue) Invalid value for property 'Properties'
Code: InvalidPropertyValue
Message: Invalid value for property 'Properties'
Target: mytrigger
这根本没有告诉我太多信息:-(。有人以前见过这个吗?我正在努力弄清楚这个问题。我一直在寻找一个属性 Properties
,但没有好像没有。有没有好的调试方法?
要解决此 azure.core.exceptions.HttpResponseError: (InvalidPropertyValue) Invalid value for property 'Properties'
错误:
而不是:
tr_properties = ScheduleTrigger(description='My scheduler trigger', pipelines = pipelines_to_run, recurrence=scheduler_recurrence)
你可以试试这个:
tr_properties = TriggerResource(properties=ScheduleTrigger(description='My scheduler trigger',pipelines=pipelines_to_run,recurrence=scheduler_recurrence))
可以参考Bad body serialization creating a Schedule Trigger in Data Factory and Azure data factory trigger creation using python SDK