首页 > 解决方案 > Azure 数据工厂检查复制记录的行数

问题描述

我正在设计一个 ADF 管道,它将行从 SQL 表复制到 Azure Data Lake 中的文件夹。之后应该删除 SQL 中的行。但是对于发生此删除操作,我想知道复制的行数是否与我在管道开始时选择的行数相同。有没有办法获取复制操作的行数并将其用于另一个操作(如查找)

编辑后续问题:博晓的回答还可以。但是我有一个后续问题。在复制活动之后,我使用以下表达式放置了一个 If 条件:

@activity('LookUpActivity').output.firstRow.RecordsRead ==      @{activity('copyActivity').output.rowsCopied

但后来我得到了错误:@activity('LookUpActivity').output.firstRow.RecordsRead == @{activity('copyActivity').output.rowsCopied

是否可以比较两个活动的输出参数以查看是否为真?

额外编辑:我刚刚在这段代码中发现了一个错误。我忘记了代码开头的“{”。但是代码仍然是错误的。要比较早期活动的两个输出,代码必须是:

@equals(activity('LookUpActivity').output.firstRow.RecordsRead,activity('copyActivity').output.rowsCopied)

标签: azure-data-factory

解决方案


您可以在活动输出中找到复制的行

您可以像这样使用输出值:

@activity('copyActivity').output.rowsCopied

推荐阅读