

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 使用分布式 Map 处理来自 Amazon S3 的 CSV 文件
<a name="sample-dist-map-csv-process"></a>

本示例项目演示了如何使用[*分布式 Map 状态*](state-map-distributed.md)迭代使用 Lambda 函数生成的 CSV 文件的 1 万行。CSV 文件包含客户订单的配送信息，并存储在 Amazon S3 存储桶中。分布式 Map 对 CSV 文件中的 10 行进行批量迭代，以进行数据分析。

分布式 Map 包含一个 Lambda 函数，用于检测任何延迟订单。分布式 Map 还包含一个[内联 Map](state-map-inline.md)，用于处理批次中的延迟订单，并以数组形式返回这些延迟订单。对于每个延迟订单，内联 Map 都会向 Amazon SQS 队列发送一条消息。最后，本示例项目会将 [Map Run](concepts-examine-map-run.md) 结果存储到 AWS 账户中的另一个 Amazon S3 存储桶中。

使用分布式 Map，一次最多可运行 1 万个并行子工作流。在本示例项目中，分布式 Map 的最大并发量设置为 1000，即限制为 1000 个并行子工作流执行。

本示例项目将创建一台状态机、支持的 AWS 资源，并将配置相关 IAM 权限。探索此示例项目，了解如何使用分布式 Map 编排大规模并行工作负载，或将其作为您自己项目的起点。

## 第 1 步：创建状态机
<a name="sample-dist-map-csv-create"></a>

1. 打开 [Step Functions 控制台](https://console.aws.amazon.com/states/home?region=us-east-1#/)，然后选择**创建状态机**。

1. 选择**从模板创建**，然后找到相关的入门模板。选择**下一步**以继续。

1. 选择模板使用方式：

   1. **运行演示** — 创建只读状态机。审核后，您可以创建工作流和所有相关资源。

   1. **构建依据** — 提供可编辑的工作流定义，您可借助自有资源对其进行审核、定制并部署。（**不会**自动创建函数或队列等相关资源。）

1. 选择**使用模板**继续进行选择。
**注意**  
*部署到您的账户的服务将会收取标准费用。*

## 第 2 步：运行演示状态机
<a name="sample-dist-map-csv-run"></a>

如果您选择了**运行演示**选项，则所有相关资源都将部署并准备好运行。如果您选择了**构建依据**选项，则可能需要先设置占位符值并创建其他资源，然后才能运行自定义工作流。

1. 选择**部署并运行**。

1. 等待 CloudFormation 堆栈部署。这一过程耗时最多 10 分钟。

1. 出现**开始执行**选项后，查看**输入**并选择**开始执行**。

**恭喜您！**  
现在，您应该有了一个正在运行的状态机演示。您可以在**图表视图**中选择状态来查看输入、输出、变量、定义和事件。