为了使您的管道在大量记录或创建批处理以导入数据时正常工作，您可以使用以下方法。

• 如果有大量的记录，并且您希望将它们批量处理为1000行，则首先使用查找活动，然后获取所有记录的计数，并将其存储在设置变量中，其中包含以下动态表达式，或者如果您知道数量，则直接将其添加到设置变量活动中。

#to get ftom lookup
@string(activity('Lookup1').output.count)

#to add manually
@string(5000)

• 我使用了另一个变量来设置作为start处理的记录的开始。

@string(1)

• 我使用了另一个变量来设置作为end处理的记录的结尾。

@string(1000)

• 现在使用until活动进行处理，直到end值大于left。

@greater(variables('end'),variables('left'))

*现在，使用execute pipeline活动并将变量值传递给该管道参数，在此参数的帮助下，您可以查询数据并批量导入。

• 现在，我们必须更新start和end的值，其中start的值递增，并且end的值也递增。
• 因为我们不能自引用变量，所以我们必须取一个临时引用变量，然后更新它。
• 为了更新start的值，我将changestart变量取为以下值。

@string(add(int(variables('start')),1000))

• 将上述changestart值赋给start变量。

• 对于end也是如此。下面是当有5000条记录时的调试输出。