Atlas Stream Processing 现已推出公共预览版
内容提要
MongoDB发布Atlas Stream Processing公共预览版，提供灵活易用的流处理，增加VS Code集成和死信队列功能，添加远程Atlas集群数据查询和条件路由功能，进行运行和安全方面的改进。
延伸解读
从私有预览到公共预览：开发者反馈驱动产品演进
Atlas Stream Processing 在私有预览阶段收到了数千个开发团队的访问请求，并从数百个参与团队收集了反馈。这些反馈来自航空、能源、企业 SaaS 等多个行业，涉及复杂聚合、连续监控、上下文相关警报等场景。公共预览版的新功能正是基于这些反馈中提炼出的三大主题：优化开发者体验、扩展高级特性、改善运行与安全。这表明该产品并非闭门造车，而是紧密围绕实际使用需求迭代。
公共预览版的关键增强：开发者体验与高级功能
公共预览版新增了 VS Code 集成，允许开发者在熟悉的环境中创建和托管流处理器；改进了死信队列功能，使 DLQ 消息在 sp.process() 和 .sample() 时自动显示，无需额外设置目标集合。高级功能方面，支持使用远程 Atlas 集群数据进行 $lookup 丰富、change stream 的前映像和后映像、在 $merge 和 $emit 阶段使用动态表达式进行条件路由，以及可配置的空闲流超时。这些改进旨在降低操作复杂性，提升开发效率。
运行与安全改进：检查点、Terraform 与安全角色
公共预览版在运行和安全方面进行了多项投入。检查点机制使流处理器在遇到数据问题或基础设施故障后能够从停止位置恢复；Terraform 提供商支持将连接和流处理实例 (SPI) 作为代码进行可重复部署；新增的项目级安全角色允许流处理器在特定角色上下文中运行，支持最小权限原则。此外，Kafka 客户群组支持让用户能轻松调整处理器在操作流中的位置并监控延迟。这些改进提升了生产环境的可靠性和可管理性。
定价与正式发布前的过渡安排
在公共预览版期间，Atlas Stream Processing 将开始使用促销定价进行收费，直到正式发布。这意味着开发者可以以促销价格使用该服务，但需注意定价可能随正式发布而调整。文章未透露正式发布的具体时间或最终定价细节，建议关注官方文档以获取最新信息。对于计划长期使用的团队，应提前评估成本影响。
Q&A
Atlas Stream Processing 公共预览版是什么？
Atlas Stream Processing 公共预览版是 MongoDB 向所有 Atlas 开发者开放的流处理服务，旨在简化流处理，提供灵活的文档模型和查询 API，并新增了 VS Code 集成、死信队列改进等功能。
Atlas Stream Processing 公共预览版有哪些新功能？
新功能包括：VS Code 集成、改进的死信队列（DLQ）功能、使用远程 Atlas 集群数据查询的 $lookup、change stream 前映像和后映像、在合并和发送阶段使用动态表达式进行条件路由、空闲流超时配置、检查点、Terraform 提供商支持、安全角色以及 Kafka 客户群组支持。
Atlas Stream Processing 在私有预览阶段有哪些使用案例？
使用案例包括：一家全球领先的航空公司使用复杂聚合快速处理维护和运营数据以确保准点航班；一家大型能源设备制造商连续监控大容量泵数据以避免停机并优化产量；一家创新型企业 SaaS 提供商利用丰富的处理功能提供及时且上下文相关的产品内警报，提高产品参与度。
Atlas Stream Processing 如何改善开发者体验？
通过 VS Code 集成，开发者可以在熟悉的开发环境中创建和托管处理器；改进的死信队列功能使得在使用 sp.process() 执行管道和运行 .sample() 时，DLQ 消息自行显示，无需设置目标集合。
Atlas Stream Processing 在运行和安全方面有哪些改进？
改进包括：检查点（保存状态以便恢复）、Terraform 提供商支持（基础设施即代码）、安全角色（项目级角色，支持最小权限原则）以及 Kafka 客户群组支持（偏移跟踪和监控延迟）。
Atlas Stream Processing 公共预览版的定价如何？
在公共预览版期间，Atlas Stream Processing 将开始使用促销定价进行收费，直到正式发布。更多信息请参阅文档。
