Atlas Stream Processing 现已公开预览
内容提要
Atlas Stream Processing现已公开预览，具有文档模型的灵活性和易用性。在私人预览期间，开发团队收集了有用的反馈。公开预览将增加高级团队要求的功能，并以促销价格收费。
延伸解读
从私人预览到公开预览：开发者反馈驱动产品演进
在私人预览期间，数千个开发团队申请访问，数百个团队提供了反馈。这些反馈来自航空、能源、SaaS等多个行业，涉及复杂聚合、实时监控、上下文告警等场景。公开预览中新增的VS Code集成、DLQ改进、$lookup阶段、change stream前后镜像、条件路由等功能，正是基于这些反馈中最高频的需求。这表明Atlas Stream Processing的迭代紧密围绕实际使用中的痛点，而非闭门造车。
公开预览的计费变化：促销价格与GA前的成本考量
公开预览开始，Atlas Stream Processing将不再免费，而是以促销价格收费，直至正式发布（GA）。这意味着开发者现在需要为流处理器的运行付费。虽然促销价格可能较低，但团队应提前评估使用成本，尤其是长期运行或高吞吐的场景。文章未透露具体价格，建议查阅官方文档了解计费细节，以便规划预算。
操作与安全增强：检查点、Terraform与Kafka消费者组
公开预览引入了检查点执行，使流处理器在故障后能从断点恢复，避免数据丢失或重复处理。Terraform支持允许以基础设施即代码的方式创建连接和流处理器实例，便于重复部署。项目级安全角色和最小权限配置提升了安全性。Kafka消费者组支持则让用户能轻松调整处理器在流中的位置并监控延迟。这些改进共同降低了生产环境中的运维复杂度。
扩展的流处理能力：$lookup、前后镜像与动态路由
公开预览新增了$lookup阶段，允许流处理器用远程Atlas集群的数据丰富文档，实现流数据与静态数据的连接。change stream的$source现在支持前后镜像，便于计算字段差异或访问已删除文档的完整内容。$merge和$emit阶段支持动态表达式，可根据文档字段值将消息路由到不同的集合或Kafka主题。此外，无进展水印的流可配置超时关闭，适应不稳定的数据源。这些功能让复杂事件处理更加灵活。
Q&A
Atlas Stream Processing 现在是什么状态？
Atlas Stream Processing 现已进入公开预览阶段，任何开发者都可以访问和使用。
在私人预览期间，开发者对 Atlas Stream Processing 的反馈如何？
在私人预览期间，数千个开发团队申请了访问权限，我们收集了数百个团队的反馈。开发者欣赏文档模型的灵活性和易用性，以及 API 查询功能，允许他们像处理代码一样处理数据。
公开预览版增加了哪些新功能？
公开预览版增加了以下新功能：VS Code 集成、增强的死信队列功能、$lookup 阶段、改进的 change stream 支持（包括前像和后像）、条件路由与动态表达式、空闲流超时、检查点执行、Terraform 支持、安全角色和 Kafka 消费者组支持。
Atlas Stream Processing 在公开预览期间如何收费？
在公开预览期间，Atlas Stream Processing 开始收费，但提供促销价格，直到正式发布（GA）。具体定价信息可查阅文档。
Atlas Stream Processing 有哪些典型使用案例？
典型使用案例包括：一家领先的航空公司使用复杂聚合快速处理维护和运营数据，确保每天数千客户的航班准时；一家大型能源设备制造商使用它持续监控大容量泵数据，以避免中断并优化收益；一家创新的企业级 SaaS 提供商利用其丰富的处理能力在产品内发送及时、情境化的警报，以提高用户参与度。
Atlas Stream Processing 如何改善开发者体验？
通过 VS Code 集成，开发者可以在熟悉的开发环境中创建和管理流处理器；增强的死信队列功能允许在运行管道时查看 DLQ 消息，无需设置专用集合，从而简化开发体验。
