文件名称：automi：Go（alpha）的流处理API
文件大小：1.79MB
文件格式：ZIP
更新时间：2024-02-24 08:13:39
go golang data-stream stream-processing streaming-api
Go（Alpha）的数据流处理API Automi是用于使用惯用的Go处理数据流的API。 使用Automi，程序可以通过组合应用于流的每个元素的操作阶段来处理数据块的流。 概念 Automi API用四个原语表达流，包括： 发射器：可以发射流元素的内存，网络或文件资源 流：代表流式传输数据元素的管道 流操作：可以附加到流上以处理流元素的代码 收集器：可以收集流式数据的内存，网络或文件资源。 Automi流在内部使用Go通道来路由数据。 这意味着Automi流将自动支持诸如缓冲，自动背压排队和并发安全性之类的功能。 使用Automi 现在，让我们探索一些示例，看看使用Automi传输和处理数据有多么容易。 请参阅目录中的所有示例。 示例：从切片流式传输到标准输出 第一个示例显示了使用Automi编写和表达流操作是多么容易。 在此示例中，符文值从切片中发出，并进行单独流式传输。 应用流运算符方法Filter过滤掉不需要的符文值，而Sort运算符方法对其余项进行排序。 最后，一个collector用于收集结果成io.Writer和通过管道输送到stdout 。 func ma