在 Azure 数据工厂中映射数据流时使用数组作为参数

问题描述 投票:0回答:0

我正在使用变更数据捕获 (CDC) 功能来映射 ADF 中的数据流。该功能会按预期拾取源表中的所有新行、已删除行或已修改行。 然而,它没有提供返回行到底发生了什么的指示:它是否被删除、是新的还是被修改。为了了解特定行发生了什么,我希望使用下面的“if - then”逻辑:

  1. 如果 CDC 返回的行不再存在于源数据集中 - 它是已删除的行。
  2. 如果源数据集中存在该行 - 它是新行或更新的行。

我在执行数据流之前使用“查找”活动来收集表中的所有主键 (PK)。 此活动返回所有 PK 的列表,我将它们解析为我的 df_parameter 的数组。

此参数也在数据流中定义为整数数组(我的 PK 是整数)。

在数据流内部,我使用具有以下表达式的“派生列”活动: 不幸的是,这不起作用并返回数据流活动错误: “作业因以下原因失败:com.microsoft.dataflow.broker.InvalidParameterTypeException:参数类型无效:df_parameter” 任何帮助将不胜感激

azure-data-factory oracle-adf change-data-capture azure-mapping-data-flow
© www.soinside.com 2019 - 2024. All rights reserved.