【发布时间】:2021-05-08 06:36:20
【问题描述】:
通过下面的链接,我了解到使用 Python SDK,我们可以创建 Pipeline 并运行它。
https://docs.microsoft.com/en-us/azure/data-factory/quickstart-create-data-factory-python
但我尝试在 create_run 函数中的 parameters={} 中传递数据流参数,但它不起作用。 (看起来它正在使用管道参数而不是数据流参数)
任何示例/细节都会有所帮助!!
【问题讨论】:
-
你能告诉我们你的代码吗?
-
credentials = UserPassCredentials('userid','pwd') adf_client = DataFactoryManagementClient(credentials, subscription_id) df = adf_client.factories.get(rg_name, df_name) p_name='DATA_STAGE' run_response = adf_client.pipelines .create_run(rg_name, df_name, p_name, parameters={"Table_name":"FILE_INFO","Target_Query":"select * from schema1.FILE_INFO where cast(adf_create_date as date) in ('2020-12-17','2020 -12-16') ","Application_name":"ACAL"}) run_response.run_id pipeline_run = adf_client.pipeline_runs.get(rg_name, df_name, run_response.run_id) print(pipeline_run.status)
标签: python azure azure-data-factory azure-data-factory-2 azure-sdk-python