AWS IoT Greengrass Version 1 2023 年 6 月 30 日进入延长寿命阶段。有关更多信息，请参阅 AWS IoT Greengrass V1 维护策略。在此日期之后，将 AWS IoT Greengrass V1 不会发布提供功能、增强功能、错误修复或安全补丁的更新。在上面运行的设备 AWS IoT Greengrass V1 不会中断，将继续运行并连接到云端。我们强烈建议您迁移到 AWS IoT Greengrass Version 2，这样可以添加重要的新功能并支持其他平台。

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

在 AWS IoT Greengrass 核心上管理数据流

AWS IoT Greengrass 流管理器可以更轻松、更可靠地将大容量 IoT 数据传输到 AWS Cloud。流管理器在本地处理数据流并自动将其导出到 AWS Cloud。此功能与常见的边缘方案（如机器学习 (ML) 推理）集成，在将数据导出到 AWS Cloud 或本地存储目标之前，将对数据进行本地处理和分析。

流管理器简化了应用程序开发。IoT 应用程序可以使用标准化机制来处理大容量流和管理本地数据保留策略，而不是构建自定义流管理功能。IoT 应用程序可以读取和写入流。它们可以在每个流的基础之上定义存储类型、大小和数据的保留策略，以控制流管理器处理和导出流的方式。

流管理器设计为在间歇性或有限连接的环境中工作。您可以定义带宽使用、超时行为以及当核心连接或断开连接时如何处理流数据。对于关键数据，您可以设置优先级以控制流导出到 AWS Cloud 的顺序。

您可以配置自动导出到 AWS Cloud 以便存储和进行进一步处理和分析。流管理器支持导出到以下 AWS Cloud 目标。

流管理工作流

您的 IoT 应用程序通过 AWS IoT Greengrass 核心开发工具包与流管理器交互。在简单工作流中，在 Greengrass 核心上运行的用户定义的 Lambda 函数会消耗 IoT 数据，如时间序列温度和压力指标。Lambda 函数可能会过滤或压缩数据，然后调用 AWS IoT Greengrass 核心开发工具包以将数据写入流管理器中的流。流管理器可以根据为流定义的策略自动将流导出到 AWS Cloud。用户定义的 Lambda 函数还可以将数据直接发送到本地数据库或存储库。

您的 IoT 应用程序可以包含多个用户定义的 Lambda 函数用于读取或写入流。这些本地 Lambda 函数可以读取和写入流，以便在本地过滤、聚合和分析数据。这样可以在数据从核心传输到云或本地目的地之前快速响应本地事件并提取有价值的信息。

下图显示了工作流程示例。

要使用流管理器，请首先配置流管理器参数来定义组级别的运行时设置，以应用到 Greengrass 核心上的所有流中。这些可自定义设置允许您根据业务需求和环境约束控制流管理器存储、处理和导出流的方式。有关更多信息，请参阅配置 AWS IoT Greengrass 流管理器。

配置流管理器后，您可以创建和部署 IoT 应用程序。这些通常是用户定义的 Lambda 函数，它们使用 AWS IoT Greengrass Core 软件包开发工具包中的 StreamManagerClient 来创建流并与之交互。在创建流期间，Lambda 函数会定义每个流的策略，例如导出目标、优先级和持久性。有关更多信息（包括 StreamManagerClient 操作的代码片段），请参阅使用 StreamManagerClient 处理流。

有关配置简单工作流程的教程，请参阅将数据流导出到 AWS Cloud（控制台）或将数据流导出到 AWS Cloud (CLI)。

要求

以下要求适用于使用流管理器：

数据安全性

使用流管理器时，请注意以下安全注意事项。

本地数据安全性

AWS IoT Greengrass 不会在核心设备上的组件之间进行静态或本地传输的流数据加密。

有关更多信息，请参阅数据加密。

客户端身份验证

流管理器客户端使用 AWS IoT Greengrass 核心开发工具包与流管理器进行通信。启用客户端身份验证后，只有 Greengrass 组中的 Lambda 函数才能与流管理器中的流交互。禁用客户端身份验证时，Greengrass 核心上运行的任何进程（如 Docker 容器）都可以与流管理器中的流进行交互。只有在您的业务案例需要时才应禁用身份验证。

您可以使用 STREAM_MANAGER_AUTHENTICATE_CLIENT 参数来设置客户端身份验证模式。您可以从控制台或 AWS IoT Greengrass API 配置此参数。更改在部署组后生效。

另请参阅