ATLAS

Atlas流处理

简化将MongoDB与Apache Kafka集成，以构建事件驱动应用程序。

立即开始

Illustration of vectors going into and coming out of a pipe.

为流式数据构建的数据模型

在处理流式数据时，模式管理对于数据正确性和开发者生产力至关重要。文档模型为开发者提供了一个灵活、自然的数据模型，用于构建实时数据应用程序。

统一的开发者体验

开发者可以使用一个平台——涵盖API、查询语言和数据模型——来持续处理来自Apache Kafka的流式数据，同时处理存储在其数据库中的关键应用程序数据。

在Atlas中完全托管

通过几行代码，开发者可以快速将Apache Kafka的流式数据与数据库集成，构建响应式、灵敏的应用程序——所有这些均由Atlas完全托管。

MongoDB Atlas中的原生流处理

查看文档

使用Atlas流处理轻松处理和验证复杂事件数据，将其合并到您需要使用的地方。

查看文档

与Apache Kafka数据流集成

Atlas流处理使查询Apache Kafka中的数据与查询MongoDB数据库一样简单。流处理器由源阶段、任意数量的处理阶段和汇阶段组成。

阅读文档

使用窗口函数执行连续分析

Atlas流处理中的窗口操作符允许您在连续数据流中分析和处理特定、固定大小的数据窗口，这使得在接近实时的情况下发现模式和趋势变得容易。

阅读文档

在复杂事件上验证模式

在Atlas流处理中，开发者可以进行连续验证。检测潜在的报文损坏和迟到数据，确保在处理之前事件是正确形成的。

阅读文档

与Apache Kafka数据流集成

Atlas流处理使查询Apache Kafka中的数据与查询MongoDB数据库一样简单。流处理器由源阶段、任意数量的处理阶段和汇阶段组成。

阅读文档

MongoDB查询API

代码片段

阅读文档

使用窗口函数执行连续分析

Atlas流处理中的窗口操作符允许您在连续数据流中分析和处理特定、固定大小的数据窗口，这使得在接近实时的情况下发现模式和趋势变得容易。

阅读文档

MongoDB查询API

代码片段

阅读文档

在复杂事件上验证模式

在Atlas流处理中，开发者可以进行连续验证。检测潜在的报文损坏和迟到数据，确保在处理之前事件是正确形成的。

阅读文档

MongoDB查询API

代码片段

{ $validate: {
        validator:  {
            $and: [
                    {$expr: {
                        $ne: [
                        '$device_id',
                        'device_8'
                        ]
                    }},
                    {$jsonSchema: {
                    required: [ 'device_id', 'timestamp', 'obs', 'event_type' ],
                    not : {required : ['event_details']},
                    properties: {
                        device_id: {
                            bsonType: 'string',
                            pattern: '^device_\\d+',
                            description: "'device_id' is required and must be like device_#"
                        },
                        obs: {
                            bsonType: 'object',
                            required: [ 'watts', 'temp' ],
                            properties:{
                                watts : {
                                    bsonType : 'int',
                                    minimum: 0,
                                    maximum: 250,
                                    description: "'obs.watts' is required and cannot be less then 0 or more then 250"
                                },
                                temp : {
                                        bsonType: 'int',
                                        description: "'obs.temp' must be an integer"
                                },
                                }
                            },
                            event_type : {
                                    bsonType: 'int',
                                    minimum: 0,
                                    maximum: 1,
                            },
                        timestamp: {
                            bsonType: 'string',
                            description: "'timestamp' must be a string "
                        }
                        }
                    }
                    }
            ]
                    },    validationAction : 'dlq'}
}

MongoDB查询API

代码片段

阅读文档