Cómo crear una canalización de agregación en MongoDB

Contenidos

Introducción

MongoDB es una base de datos de documentos sin SQL de código abierto y gratuita. Es muy utilizado en el desarrollo de aplicaciones web y también en las implementaciones de soluciones Big Data. Según el informe de motores de base de datos, tiene una clasificación alta en comparación con otras bases de datos de documentos como CouchDB, Realm, etc. Es una base de datos sin esquema y permite documentos incrustados que representan relaciones complejas en un solo registro. una declaración de problema como se muestra a continuación

«Tengo una gran cantidad de datos jerárquicos que quiero agregar».

MongoDB proporciona un marco de agregación que se puede utilizar para agregar una gran cantidad de datos jerárquicos. Admite muchas funciones incorporadas y también diferentes tipos de indexación que mejoran el rendimiento de las consultas. En este tutorial, aprenderá a realizar una canalización de agregación en MongoDB. Una canalización de agregación es uno de los marcos de agregación básicos proporcionados por MongoDB. Aggregation Pipeline procesa los documentos de entrada en varias etapas en un orden en serie. Cada resultado producido en una etapa se pasa a la siguiente etapa donde se puede realizar un procesamiento adicional en este subconjunto de documentos para lograr el resultado agregado final. Todos los ejemplos se implementan utilizando MongoDB Versión 4.4.5.

Vamos a sumergirnos.

Prerrequisitos

Para realizar este tutorial, MongoDB debe estar instalado en el sistema.

Configurar la conexión

Primero, necesitamos abrir una conexión a la base de datos usando el comando ‘mongoCuando vea ‘>’ en el indicador, estará listo para ejecutar comandos relacionados con las operaciones de la base de datos utilizadas en esta publicación.

34017mongo7-5933464

Creando base de datos

Creemos una base de datos ‘testdb’ primero usando el «usar» mando.

33004mongo1-3781108

Como puede ver arriba, si la base de datos existe, el comando anterior usará esa base de datos; de lo contrario, creará una nueva base de datos.

Ahora creemos una colección llamada ‘productos’ dentro de esta base de datos usando el comando ‘crear colección’

91113mongo2-8553891

Ahora inserte documentos de prueba dentro de la colección con la ayuda del comando ‘Insertar muchos

24591mongo3-9667993

Los documentos se insertaron correctamente. También puede consultar los documentos de la colección con el comando «encontrar».

36560mongo4-4040118

Creación de canalización de agregación

En la colección anterior, digamos que necesitamos averiguar la cantidad total de ventas que ocurrieron para cada una de las marcas.
Apple y Samsung para el teléfono disponible. Entonces, primero tenemos que filtrar los documentos según el valor disponible = «Verdadero». Esto se hace usando el comando «Fósforo» y también la primera etapa del Aggregation Pipeline. Luego, debemos encontrar la suma de «precio», que es la segunda etapa, como se muestra a continuación.. En la segunda etapa, la agrupación se realiza en función de la marca y luego se calcula la suma total del precio mediante el comando «Grupo»

59092mongo5-6442045

Agreguemos una etapa más a esta salida llamada clasificación para mostrar la suma basada en un precio más alto a un precio más bajo como se muestra a continuación. El comando que usamos aquí es «Clasificar».Aquí en el ordenamiento, 1 significa orden ascendente y -1 significa orden descendente.

24191mongo6-4514357

Conclusión

En este artículo, hemos visto cómo construir una canalización de agregación usando MongoDB. Espero que esto sea útil y si tiene algún comentario, no dude en comentar en la siguiente sección.

Los medios que se muestran en este artículo no son propiedad de DataPeaker y se utilizan a discreción del autor.

Sobre el Autor

Soy Deepti Jakka, me gusta escribir blogs sobre temas técnicos. Conóceme en https://learnfundas.com/sobre/

Suscribite a nuestro Newsletter

No te enviaremos correo SPAM. Lo odiamos tanto como tú.