如何从C#代码通过Azure函数以编程方式将参数传递到Azure数据工厂管道



我想将输出参数传递给Azure数据工厂管道。

例如。我有这样的参数

pipelineparameter:{"emp_id":1,"emp_name": "Havells","emp_dept":"IT"}

代码如下。。

{CreateRunResponse runResponse;PipelineRun pipelineRun;runResponse = client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroup, factoryName, pipelineName, parameters: (IDictionary<string, object>)parameters).Result.Body;

}

当我尝试以如下方式读取该参数时'pipelineRun.Parameters'然后它给我一个错误,如下所示:System.Collections.Generic.Dictionary`2[System.String,System.String]

这是我在Azure函数中使用的代码:

public async Task<string> RunPipelineAsync(string resourceGroupName,
string dataFactoryName,
string pipelineName,
Dictionary<string, object> parameters = null,
Dictionary<string, List<string>> customHeaders = null)
{
var runResponse = await Client.Pipelines.CreateRunWithHttpMessagesAsync(resourceGroupName, dataFactoryName, pipelineName, parameters: parameters , customHeaders: customHeaders);
return runResponse.Body.RunId;
}

在无法查看整个错误消息的情况下,我的假设是对象参数未能强制转换为IDictionary<字符串,对象>

相关内容

  • 没有找到相关文章

最新更新