{"id":13533,"date":"2022-07-06T13:37:00","date_gmt":"2022-07-06T20:37:00","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/?p=13533"},"modified":"2025-06-13T22:40:18","modified_gmt":"2025-06-14T05:40:18","slug":"eventing-data-consolidation-in-couchbase","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/es\/eventing-data-consolidation-in-couchbase\/","title":{"rendered":"Uso del servicio de eventos para consolidar datos de varias fuentes"},"content":{"rendered":"

Una de las muchas ventajas de utilizar una base de datos basada en documentos como Couchbase es la capacidad de utilizar un modelo de datos flexible para almacenar datos sin las restricciones de un esquema r\u00edgido y predeterminado. Muchos clientes eligen una base de datos NoSQL para soportar la ingesti\u00f3n de datos de m\u00faltiples fuentes. Pero, \u00bfqu\u00e9 ocurre si necesita que los datos se transformen para que coincidan con los existentes? Tal vez los necesite en un formato uniforme para la elaboraci\u00f3n de informes. Sea cual sea la raz\u00f3n, este es un uso perfecto para la base de datos Servicio de concursos<\/a> en Couchbase.<\/span><\/p>\n

Servicio de eventos Couchbase<\/h2>\n

El servicio de eventos es una caracter\u00edstica integrada de Couchbase Enterprise Edition que permite la aplicaci\u00f3n de funciones JavaScript, <\/span>o lambdas<\/em><\/span>que responden a los eventos de mutaci\u00f3n. Cada vez que se crea, modifica o elimina un documento, se puede realizar una acci\u00f3n <\/span>por ejecutar l\u00f3gica de negocio pura en JavaScript<\/em><\/span>. Hay una serie de acciones que pueden llevarse a cabo, como el enriquecimiento de datos, la llamada a flujos de trabajo externos (mediante llamadas a API RESTful) y eventos basados en temporizadores (reanudaci\u00f3n de la ejecuci\u00f3n en el futuro). Piense en los eventos como una base de datos heredada <\/span>post<\/span>gatillo con esteroides.<\/span><\/p>\n

Consolidaci\u00f3n de datos<\/h2>\n

En este ejemplo simplificado, imagine que acaba de adquirir dos nuevas fuentes de datos de clientes. Estos datos pueden proceder de una fuente normalizada, de un archivo plano o de ambos, y desea que coincidan con los datos de clientes existentes almacenados en un formato desnormalizado.<\/span><\/p>\n

La primera fuente de datos es una base de datos normalizada (<\/span>limpio y preciso) <\/span>que contiene clientes de Canad\u00e1. Cada registro de cliente apunta a una direcci\u00f3n de facturaci\u00f3n y otra de env\u00edo, y cada direcci\u00f3n est\u00e1 normalizada para eliminar la redundancia de datos de ciudad y provincia:<\/span><\/p>\n

\"Normalized
\nLa segunda fuente de datos es un archivo plano que tambi\u00e9n contiene clientes canadienses, pero que no registra por separado las direcciones de facturaci\u00f3n y de env\u00edo. Como puede ver, <\/span>un \u00fanico elemento de datos de direcci\u00f3n<\/span> se almacena en el registro del cliente:<\/span><\/p>\n

\"Customer<\/p>\n

Tenemos que transformar estos datos a medida que llegan para que coincidan con nuestra base de datos de clientes existente, que est\u00e1 desnormalizada de forma que las direcciones de facturaci\u00f3n y env\u00edo se adjuntan a los datos del cliente (<\/span>de la segunda fuente<\/span>) como subdocumentos:<\/span><\/p>\n

\"Creating<\/p>\n

Empecemos por <\/span>un f\u00e1cil<\/span> soluci\u00f3n en primer lugar, la importaci\u00f3n de ficheros planos. El proceso de transformaci\u00f3n de estos datos consiste en copiar los datos del cliente (nombre, correo electr\u00f3nico, tel\u00e9fono, nombre de la empresa) en un nuevo documento. A continuaci\u00f3n, los datos de la direcci\u00f3n deben copiarse en subdocumentos para las direcciones de facturaci\u00f3n y postal. Como s\u00f3lo tenemos una direcci\u00f3n por cliente, copiaremos esta direcci\u00f3n tanto en el subdocumento de facturaci\u00f3n como en el de direcci\u00f3n postal:<\/span><\/p>\n

\"Importing
\nC\u00f3digo JavaScript para consolidar las tablas<\/span><\/h2>\n

El c\u00f3digo Eventing para lograr esto es bastante simple:<\/span><\/p>\n

 \u00a01 function OnUpdate(doc, meta) {\r\n  2 const nuevo_doc = {}; \/\/ Nuevo documento de cliente\r\n  3 const direcci\u00f3n = {}; \/\/ Nuevo documento de direcci\u00f3n\r\n  4\r\n  5 nuevo_doc['nombre'] = doc.nombre;\r\n  6 nuevo_doc['apellido'] = doc.apellido;\r\n  7 new_doc['email'] = doc.email;\r\n  8 nuevo_doc['tel\u00e9fono'] = doc.tel\u00e9fono;\r\n  9 nuevo_doc['nombre_empresa'] = doc.nombre_empresa;\r\n 10\r\n 11 direcci\u00f3n['direcci\u00f3n_calle_1'] = doc.direcci\u00f3n_calle_1;\r\n 12 direcci\u00f3n['direcci\u00f3n_calle_2'] = doc.direcci\u00f3n_calle_2;\r\n 13 direcci\u00f3n['ciudad'] = doc.ciudad;\r\n 14 direcci\u00f3n['provincia'] = doc.provincia;\r\n 15 direcci\u00f3n['c\u00f3digo_postal'] = doc.c\u00f3digo_postal;\r\n 16\r\n 17 \/\/ A\u00f1ade el documento de direcci\u00f3n al documento de cliente como subdocumentos\r\n 18 nuevo_doc['direcci\u00f3n_facturaci\u00f3n'] = direcci\u00f3n;\r\n 19 new_doc['mailing_address'] = direcci\u00f3n;\r\n 20\r\n 21 \/\/ Esto crea el nuevo documento en el bucket de destino\r\n 22 dest_bkt[doc.email] = nuevo_doc;\r\n 23\r\n 24 \/\/ Borra el documento original - descomenta abajo\r\n 25 \/\/ borrar sch2[meta.id];\r\n 26\r\n 27 log(\"Documento creado\/actualizado\", meta.id);\r\n 28 }<\/pre>\n
El c\u00f3digo anterior deber\u00eda ser lo suficientemente f\u00e1cil de entender, incluso para los codificadores no JavaScript, pero voy a romper esto por secci\u00f3n s\u00f3lo para estar seguro.<\/span><\/p>\n