{"id":7045,"date":"2019-08-09T10:00:40","date_gmt":"2019-08-09T17:00:40","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/?p=7045"},"modified":"2025-06-13T22:40:26","modified_gmt":"2025-06-14T05:40:26","slug":"eventing-service-improvements-in-couchbase-server-6-5","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/es\/eventing-service-improvements-in-couchbase-server-6-5\/","title":{"rendered":"Mejoras en el servicio de eventos de Couchbase Server 6.5"},"content":{"rendered":"

Servicio de eventos Couchbase<\/a> proporciona un marco para escribir tus propias funciones para procesar eventos de cambio de datos (creaci\u00f3n, actualizaci\u00f3n, borrado\/expiraci\u00f3n). Couchbase Server 6.5 introduce un conjunto de importantes mejoras en el Servicio de Eventos que permiten un mont\u00f3n de nuevos casos de uso y simplifican el mantenimiento de las Funciones Vespertinas.<\/p>\n

Mutaciones del cubo de origen<\/h2>\n

Una funci\u00f3n Eventing est\u00e1 definida para escuchar los cambios de un bucket, conocido como el bucket fuente de la funci\u00f3n. Las versiones anteriores de Couchbase no permit\u00edan a una funci\u00f3n mutar documentos en su bucket fuente, porque si estas mutaciones se retroalimentaban a la funci\u00f3n pod\u00eda potencialmente crear una recursi\u00f3n infinita. Esta limitaci\u00f3n ha sido eliminada en Couchbase 6.5: una funci\u00f3n Eventing puede ahora cambiar los documentos en el bucket fuente, incluso el documento del evento de cambio. Couchbase hace tales cambios seguros suprimiendo su propagaci\u00f3n recursiva a la misma funci\u00f3n Eventing.<\/p>\n

La posibilidad de modificar documentos en el bucket de origen abre muchos casos de uso interesantes: enriquecer los documentos modificados con nuevos atributos, realizar actualizaciones o eliminaciones en cascada de documentos dependientes, generar nuevos documentos en el mismo bucket.<\/p>\n

El siguiente ejemplo utiliza Eventing para generar autom\u00e1ticamente atributos de documento que contienen la hora de creaci\u00f3n del documento y la hora de su \u00faltima actualizaci\u00f3n. Vamos a escuchar a los cambios en el viaje-muestra<\/strong> y generan o actualizan los atributos de tiempo cada vez que se modifica un documento. Las funciones de eventos acceden a los buckets a trav\u00e9s de los llamados bucket bindings. Creamos un bucket de lectura-escritura en el archivo viaje-muestra<\/strong> es decir, el cubo de origen, y asignarle un alias cubo<\/strong>:<\/p>\n

\"\"<\/p>\n

En el siguiente paso proporcione el c\u00f3digo de la funci\u00f3n:<\/p>\n

function OnUpdate(doc, meta) {\r\n    log('docId', meta.id);\r\n    var time = Date.now();\r\n    doc[\"updated\"] = time;\r\n    if (!(\"created\" in doc)) {\r\n        doc[\"created\"] = time;\r\n    }\r\n    log('newDoc', meta, doc);\r\n    bucket[meta.id] = doc;\r\n}\r\n<\/pre>\n
En el OnUpdate<\/strong> que se llama en cada evento de inserci\u00f3n y actualizaci\u00f3n, escribimos la hora actual en el campo actualizado<\/strong> (cre\u00e1ndolo o sustituy\u00e9ndolo). Si el documento a\u00fan no contiene creado<\/strong> asumimos que es el primer cambio en el documento, por lo que a\u00f1adimos creado<\/strong> que contiene tambi\u00e9n la hora actual. Despu\u00e9s de ampliar el documento con los nuevos atributos, lo escribimos de nuevo en el bucket de origen para el mismo ID de documento.<\/p>\n
Cambiando actualizado<\/strong> y creado<\/strong> generamos nuevos cambios en el documento. El marco de Eventing suprime la recursi\u00f3n al no propagar estos cambios a nuestra funci\u00f3n. De lo contrario, estos cambios se gestionan de forma normal: se replican, indexan e incluso se propagan a otras funciones de Eventing.<\/p>\n
Invocaci\u00f3n de funciones externas con cURL<\/h2>\n
Las funciones de eventos pueden interactuar con sistemas externos utilizando rizo<\/b> para llamar a su API REST. La posibilidad de interactuar con sistemas externos abre un mont\u00f3n de nuevos casos de uso, como la propagaci\u00f3n de cambios de datos a otros sistemas, la notificaci\u00f3n a la aplicaci\u00f3n de eventos interesantes, el enriquecimiento de documentos con datos de sistemas externos, etc. Una vista previa de la funci\u00f3n curl ya estaba disponible en versiones anteriores de Couchbase, pero con 6.5 la funci\u00f3n se ha redise\u00f1ado para hacerla fiable y segura: las llamadas cURL se limitan a un conjunto predefinido de enlaces URL, para cada enlace podemos especificar autenticaci\u00f3n, cifrado y validaci\u00f3n de certificados seg\u00fan sea necesario.<\/p>\n
En el siguiente ejemplo definiremos una aplicaci\u00f3n a la escucha de los cambios en el bucket viaje-muestra. Guarde el c\u00f3digo de la aplicaci\u00f3n en el archivo app.js<\/strong>:<\/p>\n
const Express = require(\"express\");\r\nconst BasicAuth = require(\"express-basic-auth\");\r\nconst BodyParser = require(\"body-parser\");\r\n \r\nvar app = Express();\r\napp.use(BodyParser.json());\r\napp.use(BodyParser.urlencoded({ extended: true }));\r\napp.use(BasicAuth({ users: { 'couchbase': 'password' } }))\r\n \r\napp.post(\"\/api\/airline\", (request, response) => {\r\n    var id = request.body.id;\r\n    console.log(\"Airline \" + id + \" changed\");\r\n    response.send(\"OK\");\r\n});\r\n \r\nvar server = app.listen(3000, () => {\r\n    console.log(\"Listening...\");\r\n});<\/pre>\n
La aplicaci\u00f3n define un punto final \/api\/aerol\u00ednea<\/strong> para recibir notificaciones sobre cambios en los datos de la aerol\u00ednea como peticiones POST con el cuerpo conteniendo el ID de la aerol\u00ednea. La aplicaci\u00f3n est\u00e1 configurada con autenticaci\u00f3n b\u00e1sica esperando que el usuario couchbase<\/strong> con la contrase\u00f1a contrase\u00f1a<\/strong>.<\/p>\n
Ejecuta los siguientes comandos para instalar los paquetes node.js necesarios y ejecutar la aplicaci\u00f3n:<\/p>\n
npm init -y\r\nnpm install express body-parser express-basic-auth --save\r\nnode app.js\r\n<\/pre>\n
Ahora vamos a crear una Funci\u00f3n Eventing que notifique a nuestra aplicaci\u00f3n sobre los cambios de los documentos de las aerol\u00edneas. Todas las APIs externas que pueden ser llamadas por la funci\u00f3n deben ser declaradas como URL bindings. Asumiendo que 192.168.61.1 es la IP de la m\u00e1quina donde iniciamos la aplicaci\u00f3n, declaramos un URL binding para la URL https:\/\/192.168.61.1:3000\/api<\/strong> y ponerle un nombre notifyApi<\/b>.<\/p>\n
\"\"<\/p>\n
Un enlace URL puede utilizar el protocolo http o https. Tambi\u00e9n podemos especificar diferentes tipos de autenticaci\u00f3n y habilitar cookies para evitar la autenticaci\u00f3n repetida. En nuestro caso, seleccionamos la autenticaci\u00f3n b\u00e1sica con el usuario couchbase<\/strong> y contrase\u00f1a contrase\u00f1a<\/strong>.<\/p>\n
En el siguiente paso proporcionar el c\u00f3digo de la funci\u00f3n, que escucha a los cambios de los documentos de tipo aerol\u00ednea<\/strong> y reenv\u00eda estos cambios a la aplicaci\u00f3n mediante rizo<\/b> llamadas:<\/p>\n
function OnUpdate(doc, meta) {\r\n    if (doc.type == 'airline') {\r\n        var request = {\r\n            path: '\/airline',\r\n            body: { id : meta.id,\r\n                    value : doc \r\n            }\r\n        };\r\n        log('request', request);\r\n        var response = curl('POST', notifyApi, request);\r\n        if (response.status != 200) {\r\n            log('request failed', response);\r\n        }\r\n    }\r\n}<\/pre>\n
En rizo<\/b> toma tres par\u00e1metros: el m\u00e9todo de la petici\u00f3n HTTP, el enlace URL y el objeto de la petici\u00f3n que puede contener los siguientes atributos:<\/p>\n