如何使用 .NET SDK 将参数传递给 ADF 管道
How to pass parameters to ADF pipeline using .NET SDK
我正在尝试从我的函数中传递管道参数,但它似乎仍然只使用默认值。我很好奇我在这里遗漏了什么。
我有我的 ADF-2 管道。我定义了一个名为 schema 的管道参数。我在查询中的 Copy Data activity 中使用此管道参数,例如:
...
FROM @{pipeline().parameters.schema}.CUSTOMERS t2
...
调试管道时一切正常(当我填写正确的值时)。但是如果我通过这段代码调用管道
var parameters = new Dictionary<string, object>()
{
{"schema", "fi" }
};
var runResponse = await client.Pipelines.CreateRunWithHttpMessagesAsync(
remoteControlConfigurations.InitPipeConfigurations.ResourceGroup,
remoteControlConfigurations.InitPipeConfigurations.DataFactoryName,
remoteControlConfigurations.InitPipeConfigurations.PipelineName,
parameters: parameters);
失败,因为 schema 参数为空:
... 'Invalid object name '.CUSTOMERS' ...
我在这里缺少什么?
好了,谜团已经解开了。我错误地没有 运行 提供的代码,而是没有参数的旧版本。部署正确的版本后,一切正常。
我正在尝试从我的函数中传递管道参数,但它似乎仍然只使用默认值。我很好奇我在这里遗漏了什么。
我有我的 ADF-2 管道。我定义了一个名为 schema 的管道参数。我在查询中的 Copy Data activity 中使用此管道参数,例如:
...
FROM @{pipeline().parameters.schema}.CUSTOMERS t2
...
调试管道时一切正常(当我填写正确的值时)。但是如果我通过这段代码调用管道
var parameters = new Dictionary<string, object>()
{
{"schema", "fi" }
};
var runResponse = await client.Pipelines.CreateRunWithHttpMessagesAsync(
remoteControlConfigurations.InitPipeConfigurations.ResourceGroup,
remoteControlConfigurations.InitPipeConfigurations.DataFactoryName,
remoteControlConfigurations.InitPipeConfigurations.PipelineName,
parameters: parameters);
失败,因为 schema 参数为空:
... 'Invalid object name '.CUSTOMERS' ...
我在这里缺少什么?
好了,谜团已经解开了。我错误地没有 运行 提供的代码,而是没有参数的旧版本。部署正确的版本后,一切正常。