我想将输出参数传递给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<字符串,对象>。