【问题标题】:Azure Data Factory check rowcount of copied recordsAzure 数据工厂检查复制记录的行数
【发布时间】:2022-05-11 01:55:24
【问题描述】:

我正在设计一个 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


    【解决方案1】:

    您可以在活动输出中找到复制的行,如下图所示。

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

    @activity('copyActivity').output.rowsCopied
    

    【讨论】:

      猜你喜欢
      • 2019-11-19
      • 2020-08-21
      • 1970-01-01
      • 2020-11-25
      • 1970-01-01
      • 1970-01-01
      • 2022-01-04
      • 1970-01-01
      • 2020-09-15
      相关资源
      最近更新 更多