创建从Python的ADF V2的存储过程活动



获取以下代码的错误,该代码为ADF V2创建存储过程活动。

无法构建模型:无法应对响应数据。数据:{dateToImportfor:{value:2017-01-04,type:str}},{storedProcedureParameter},attributeError:'str'对象没有属性'项目',deserializationerror:无法应对响应数据。数据:{dateToImportfor:{value:2017-01-04,type:str}},{storedProcedureParameter},attributeError:'str''对象没有属性'项目'

我的代码:

spActivity_Name="AzureSQLDWStoredProcedureActivity"
storedproc_name ="DailyImport"
linkedService = LinkedServiceReference(lsdw)
p="{%s :{value:%s,type:str}}" % ('DateToImportFor','2017-01-04')

lsp_activity = SqlServerStoredProcedureActivity(name=spActivity_Name,
                                       stored_procedure_name=storedproc_name,
                                       stored_procedure_parameters=p,
                                       linked_service_name=linkedService)

由于我是Python的新手,我不确定如何构造参数对象。

#stored_procedure_parameter is expecting in the following format
  :param stored_procedure_parameters: Value and type setting for stored
     procedure parameters. Example: "{Parameter1: {value: "1", type: "int"}}".
    :type stored_procedure_parameters: dict[str,
     ~azure.mgmt.datafactory.models.StoredProcedureParameter]
    """

p_name =  'StoredProcPipeLine'
params_for_pipeline = {}
p_obj = PipelineResource(activities=[lsp_activity], parameters=params_for_pipeline)
p = adf_client.pipelines.create_or_update(rg_name, df_name, p_name, p_obj)

文档上的示例有点不准确,因为它将 stored_procedure_parameters的示例称为字符串。

尝试将p设置为词典:

from azure.mgmt.datafactory.models import StoredProcedureParameter
p = {'DateToImportFor': StoredProcedureParameter('2017-01-04', type='String')}

最新更新