使用批处理活动从 CSV 上传数据

教程概述

批处理活动接受实体记录的 List<T> 作为输入并将其作为输出返回，以创建、更新或删除多个项目。

这些活动在单个调用中最多可接受 1,000 个记录，并且每个活动调用都将计为服务使用配额的一次调用。

要了解如何在Data Fabric中使用批处理活动，请下载下面的示例并按照本教程中的步骤操作。该示例通过 2 个批处理活动调用为一个实体创建 50 个记录。

下载示例

要运行下载的示例，请执行以下操作：

• 连接到 UiPath 组织。
• 确保在租户中启用了Data Fabric 。
• 创建该示例中的实体。
• 将相应的 Orchestrator 租户连接到 UiPath^TM 机器人。

包含批处理活动的工作流通常包括一个“遍历循环”，用于循环访问记录列表并填充 List<T> 列表变量。然后，该变量将作为输入传递到批处理活动。

收集数据

States.csv文件包含批处理活动添加到Data Fabric实体的记录。

要运行批处理活动，请创建一个与您的数据具有相同字段的实体。

创建实体

1. 转到租户的Data Fabric实例。
2. 创建名为“美国州”并包含以下字段的新实体：
   
   

   

   
   

设计工作流

1. 打开 Studio，然后启动一个新流程。
   注意：确保启用Data Fabric的租户已连接到 UiPath ^TM机器人。
2. 安装 UiPath.DataService.Activities 包。
3. 在 Studio 的工作流中导入之前创建的“美国的州”实体。
4. 要将 States.CSV 文件中的数据读取到数据表中，请拖放“读取 CSV”活动。
   • 在“读取文件”字段中，输入 CSV 文件的名称。
   • 在“输出位置”字段中，设置数据表的名称。
5. 设置一个用于存储批处理大小（即要在一个调用中更改的记录数量）的变量。使用分配活动。
   注意：批处理大小限制为 1,000 个记录。要更改超过 1,000 个条目，请将批量大小设置为 1,000。
6. 设置一个变量以存储记录列表（例如 listUSStates）。使用“分配”活动，并将列表类型初始化为 New <List(Of USStates)>。这将创建一个空列表，随时可用 CSV 文件中的数据填充。
   
   

   

   
   
7. 要循环访问先前创建的数据表（步骤 4）中的每一行，请使用“遍历数据表中的行”活动。
8. 为数据表中的每一行创建一个新变量（即 currState = New USStates），并设置“美国州”实体字段（即 State、DateofAdmission 和 Population）的值。使用“多重分配”活动。
9. 要将当前状态添加到listUSStates列表中，请使用“将项目附加到集合”活动。
   
   

   

   
   
10. 每次添加后，检查列表大小是否等于您在步骤 5 中设置的批处理大小。将“If 条件”活动与条件 listUSStates.Count = batchSize 结合使用。在满足 IF 条件之前，工作流将继续添加记录。
11. 当列表大小与批处理大小相等时，使用“创建多条实体记录”活动创建记录。在我们的示例中，这将在单个调用中创建 25 个记录。
12. 在每批记录后清除集合，以使下一批的计数从零开始。
    
    

    

    
    
13. 在“遍历循环”外部，检查集合中是否有任何剩余的记录并创建它们。

    在记录计数不是批处理大小的倍数的情况下，此最后一步非常重要。例如，如果集合包含 80 个记录，则满足 25、50 和 75 个记录（25 的倍数，示例批处理大小）的 IF 条件（在步骤 10 中设置）。剩余的 5 个记录由遍历循环外部的最后一个 IF 条件解析。