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

教程概述

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

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

To understand how to use batch activities in Data Fabric, download the example below and follow the steps in this tutorial. The example creates 50 records for an entity via 2 batch activity calls.

下载示例

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

• 连接到 UiPath 组织。
• Make sure Data Fabric is enabled in your tenant.
• 创建该示例中的实体。
• 将相应的 Orchestrator 租户连接到 UiPath^TM 机器人。

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

收集数据

The States.csv file contains the records that the batch activity adds to your Data Fabric entity.

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

创建实体

1. Go to the Data Fabric instance of your tenant.
2. 创建名为“美国州”并包含以下字段的新实体：
   
   

   

   
   

设计工作流

1. 打开 Studio，然后启动一个新流程。
   Note: Make sure the Data Fabric enabled tenant is connected to the UiPath^® Robot.
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 条件解析。