内容提要
Atlas Stream Processing是一种原生于MongoDB的处理流数据的方法,现已正式推出。它允许开发人员创建响应式、事件驱动的应用程序。新功能包括对时间序列集合的支持、开发和生产层、对Kafka的改进支持、以及以最低权限访问和流处理器警报。Atlas Stream Processing将MongoDB的文档模型和查询API的强大灵活性引入了流处理中。开发人员对其给予了积极的反馈。MongoDB计划推出新功能,如高级网络支持、对云区域和提供商的扩展支持,以及使用HashiCorp Terraform进行部署的灵活性。
延伸解读
从预览到生产:GA 意味着什么
Atlas Stream Processing 正式 GA,标志着它已准备好支持生产工作负载。这意味着开发团队可以将其用于对可靠性、可扩展性有要求的关键业务场景,而不再只是实验性项目。GA 版本还引入了开发和生产层(SP10 和 SP30),让用户可以根据流量和预算灵活选择,降低了入门门槛。
时间序列集合支持:流处理与存储的衔接
新版本允许将流处理器的输出直接写入时间序列集合。时间序列集合是 MongoDB Atlas 中专门为高效存储和查询时间序列数据而设计的集合类型。这一支持让开发者可以在数据流经处理器时进行连续预处理,并将结果存储起来供后续历史分析,简化了从流处理到持久化存储的链路。
Kafka 集成与安全增强
对 Kafka 的改进支持包括处理 Kafka 头信息,使应用程序能在事件数据之外传递额外元数据,便于消息路由、条件处理等场景。同时,最低权限访问允许数据库用户仅向需要的人授予流处理实例的访问权,而流处理器警报则能通过邮件、短信或 Datadog 等平台监控处理器状态,提升运维安全性。
未来路线图:网络、云区域与 Terraform
MongoDB 计划在未来几个月推出多项增强功能,包括对 Kafka 集群的 VPC 对等连接、扩展对云区域和云提供商(如 Microsoft Azure)的支持、更多数据源和数据接收器,以及更丰富的指标和可观测性。此外,还将支持使用 HashiCorp Terraform 管理 Atlas Stream Processing 实例和连接,以实现基础设施即代码和 CI/CD 流水线。
Q&A
Atlas Stream Processing是什么?
Atlas Stream Processing是MongoDB原生的流数据处理方法,允许开发人员创建响应式、事件驱动的应用程序。
Atlas Stream Processing有哪些新功能?
新功能包括对时间序列集合的支持、开发和生产层、对Kafka的改进支持、最低权限访问和流处理器警报。
Atlas Stream Processing如何提高开发者的生产力?
开发者反馈显示,Atlas Stream Processing提高了生产力和开发体验,降低了基础设施成本。
Atlas Stream Processing支持哪些数据处理功能?
它支持时间序列集合的高效存储和查询,能够处理复杂和快速变化的数据结构。
未来Atlas Stream Processing将推出哪些新特性?
未来将推出扩展的网络支持、对云区域和云提供商的支持,以及更多数据源和数据接收器的支持。
Atlas Stream Processing如何确保数据安全?
它提供最低权限访问,确保只有需要的用户才能访问流处理实例。