как передать параметры потока данных / набора данных в конвейер фабрики данных Azure из Python SDK

Из приведенной ниже ссылки я понимаю, что с помощью Python SDK мы можем создать конвейер и запустить его.

https://docs.microsoft.com/en-us/azure/data-factory/quickstart-create-data-factory-python.

Но я попытался передать параметры потока данных в parameters = {} функции create_run, и это не работает. (Похоже, он принимает параметры конвейера, а не параметры потока данных)

Любой пример / подробности помогут !!


azure python azure-data-factory-2 azure-data-factory azure-sdk-python
person narayana kandukuri    schedule 04.02.2021    source источник
comment
Вы можете показать нам свой код?   -  person Steve Zhao    schedule 09.02.2021
comment
credentials = UserPassCredentials ('userid', 'pwd') adf_client = DataFactoryManagementClient (учетные данные, ID_подписки) df = adf_client.factories.get (rg_name, df_name) p_name = 'DATA_STAGE' run_response = adf_clate.pipename , 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)   -  person narayana kandukuri    schedule 17.02.2021

Ответы (1)


arrow_upward
1
arrow_downward

Насколько я знаю, прямого способа сделать это нет. В качестве обходного пути вы можете создать параметры конвейера, а затем передать их в поток данных. Что-то вроде этого:

введите описание изображения здесь

person Steve Zhao    schedule 18.02.2021
comment
Спасибо, Стив. Да, это сработало. Я создал параметр конвейера и передал его в поток данных. - person narayana kandukuri; 24.02.2021