你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

映射数据流中的“更改行”转换

适用于： Azure 数据工厂 Azure Synapse Analytics

提示

试用 Microsoft Fabric 中的数据工厂，这是一种适用于企业的一站式分析解决方案。 Microsoft Fabric 涵盖从数据移动到数据科学、实时分析、商业智能和报告的所有内容。 了解如何免费开始新的试用！

数据流在 Azure 数据工厂和 Azure Synapse 管道中均可用。 本文适用于映射数据流。 如果不熟悉转换，请参阅介绍性文章使用映射数据流转换数据。

使用“更改行”转换来设置针对行的插入、删除、更新和更新插入策略。 可以将一对多条件添加为表达式。 应按优先级顺序指定这些条件，因为每一行都将用与第一个匹配的表达式对应的策略进行标记。 其中的每个条件都可能会导致对行执行插入、更新、删除或更新插入操作。 “更改行”可能会产生对数据库的 DDL 和 DML 操作。

“更改行”转换仅对你的数据流中的数据库、REST 或 Azure Cosmos DB 接收器进行操作。 在调试会话期间，分配给行的操作（插入、更新、删除、更新插入）不会发生。 若要对数据库表执行“更改行”策略，请在管道中运行“执行数据流”活动。

注意

使用本机 CDC 源（如 SQL Server 或 SAP）的变更数据捕获数据流不需要更改行转换。 在这些情况下，ADF 将自动检测行标记，因此不需要更改行策略。

指定一个默认行策略

创建一个“更改行”转换，并指定一个条件为 true() 的行策略。 与前面定义的任何表达式都不匹配的每个行都将标记为执行指定的行策略。 默认情况下，与任何条件表达式都不匹配的每个行都将标记为执行 Insert。

注意

若要为所有行标记一个策略，可以为该策略创建一个条件，并将条件指定为 true()。

在数据预览中查看策略

使用调试模式在数据预览窗格中查看“更改行”策略的结果。 “更改行”转换的数据预览不会针对目标产生 DDL 或 DML 操作。

每个“更改行”策略的图标指示会发生插入、更新、更新插入还是删除操作。 在预览中，顶部标题会显示每个策略所影响的行数。

在接收器中允许“更改行”策略

要使“更改行”策略有效，数据流必须写入到数据库或 Azure Cosmos DB 接收器。 在接收器的“设置”选项卡中，启用允许该接收器使用的“更改行”策略。

默认行为是仅允许插入。 若要允许更新、更新插入或删除，请选中接收器中与该条件对应的框。 如果启用更新、更新插入或删除操作，则必须指定接收器中与之匹配的键列。

注意

如果插入、更新或更新插入操作修改了接收器中目标表的架构，则数据流会失败。 若要修改数据库中的目标架构，请选择“重新创建表”作为表操作。 这将删除表并使用新的架构定义重新创建表。

接收器转换需要单个键或一系列键才能在目标数据库中对行进行独一无二的标识。 对于 SQL 接收器，请在接收器“设置”选项卡中设置键。对于 Azure Cosmos DB，请在“设置”中设置分区键，并且还要在接收器映射中设置 Azure Cosmos DB 系统字段“ID”。 对于 Azure Cosmos DB，必须包含针对更新、更新插入和删除操作的系统列“ID”。

对 Azure SQL 数据库和 Azure Synapse 的合并与更新插入

数据流支持使用更新插入选项对 Azure SQL 数据库和 Azure Synapse 数据库池（数据仓库）执行合并操作。

但是，你可能会遇到目标数据库架构使用了键列的标识属性的情况。 此服务要求你标识用来为更新和更新插入操作匹配行值的键。 但是，如果目标列设置了标识属性，而你使用的是更新插入策略，则目标数据库不允许写入到列。 尝试对分布式表的分布列进行更新插入时，也可能会遇到错误。

下面是解决该问题的方法：

1. 转到“接收器转换设置”并设置“跳过写入键列”。 这将指示此服务不要写入你选择用作映射键值的列。

2. 如果该键列不是导致标识列问题的列，则可使用此接收器转换预处理 SQL 选项：SET IDENTITY_INSERT tbl_content ON。 然后，通过以下后处理 SQL 属性将其关闭：SET IDENTITY_INSERT tbl_content OFF。

3. 对于标识案例和分布列案例，可以使用“条件拆分”转换将逻辑从更新插入切换为使用单独的更新条件和单独的插入条件。 这样即可将更新路径上的映射设置为忽略键列映射。

数据流脚本

语法

<incomingStream>
    alterRow(
           insertIf(<condition>?),
           updateIf(<condition>?),
           deleteIf(<condition>?),
           upsertIf(<condition>?),
        ) ~> <alterRowTransformationName>

示例

下面的示例是一个名为 CleanData 的“更改行”转换，它接受传入的流 SpecifyUpsertConditions 并创建三个“更改行”条件。 在上一转换中计算了名为 alterRowCondition 的列，目的是确定是否在数据库中插入、更新或删除行。 如果列的值包含与“更改行”规则匹配的字符串值，则会为其分配该策略。

在 UI 中，此转换如下图所示：

此转换的数据流脚本位于下面的代码片段中：

SpecifyUpsertConditions alterRow(insertIf(alterRowCondition == 'insert'),
	updateIf(alterRowCondition == 'update'),
	deleteIf(alterRowCondition == 'delete')) ~> AlterRow

相关内容

完成“更改行”转换后，即可将数据接收到目标数据存储中。