{"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\/pt\/eventing-service-improvements-in-couchbase-server-6-5\/","title":{"rendered":"Aprimoramentos do servi\u00e7o de eventos no Couchbase Server 6.5"},"content":{"rendered":"

Servi\u00e7o de eventos do Couchbase<\/a> fornece uma estrutura para escrever suas pr\u00f3prias fun\u00e7\u00f5es para processar eventos de altera\u00e7\u00e3o de dados (cria\u00e7\u00e3o, atualiza\u00e7\u00e3o, exclus\u00e3o\/expira\u00e7\u00e3o). O Couchbase Server 6.5 apresenta um conjunto de aprimoramentos importantes no Eventing Service que permitem muitos casos de uso novos e simplificam a manuten\u00e7\u00e3o do Evening Functions.<\/p>\n

Muta\u00e7\u00f5es do Bucket de Origem<\/h2>\n

Uma fun\u00e7\u00e3o Eventing \u00e9 definida para ouvir as altera\u00e7\u00f5es de um bucket, conhecido como o bucket de origem da fun\u00e7\u00e3o. As vers\u00f5es anteriores do Couchbase n\u00e3o permitiam que uma fun\u00e7\u00e3o alterasse os documentos em seu bucket de origem, porque se essas muta\u00e7\u00f5es estiverem sendo alimentadas de volta para a fun\u00e7\u00e3o, isso poder\u00e1 criar uma recurs\u00e3o infinita. Essa limita\u00e7\u00e3o foi removida no Couchbase 6.5: uma fun\u00e7\u00e3o Eventing agora pode alterar os documentos no bucket de origem, at\u00e9 mesmo o documento do evento de altera\u00e7\u00e3o. O Couchbase torna essas altera\u00e7\u00f5es seguras, suprimindo a propaga\u00e7\u00e3o recursiva para a mesma fun\u00e7\u00e3o Eventing.<\/p>\n

A possibilidade de alterar documentos no bucket de origem abre muitos casos de uso interessantes: enriquecer os documentos alterados com novos atributos, realizar atualiza\u00e7\u00f5es em cascata ou exclus\u00f5es de documentos dependentes, gerar novos documentos no mesmo bucket.<\/p>\n

O exemplo abaixo usa Eventing para gerar automaticamente atributos de documento que cont\u00eam a hora de cria\u00e7\u00e3o do documento e a hora de sua \u00faltima atualiza\u00e7\u00e3o. Vamos ouvir as altera\u00e7\u00f5es no atributo amostra de viagem<\/strong> e geram ou atualizam os atributos de tempo sempre que um documento \u00e9 alterado. As fun\u00e7\u00f5es de eventos acessam os compartimentos por meio dos chamados bucket bindings. Criamos uma vincula\u00e7\u00e3o de bucket de leitura e grava\u00e7\u00e3o no amostra de viagem<\/strong> ou seja, o bucket de origem, e dar a ele um alias balde<\/strong>:<\/p>\n

\"\"<\/p>\n

Na pr\u00f3xima etapa, forne\u00e7a o c\u00f3digo da fun\u00e7\u00e3o:<\/p>\n

fun\u00e7\u00e3o OnUpdate(doc, meta) {\r\n    log('docId', meta.id);\r\n    var time = Date.now();\r\n    doc[\"updated\"] = time;\r\n    se (!(\"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
No Sobre a atualiza\u00e7\u00e3o<\/strong> que \u00e9 chamado em cada evento de inser\u00e7\u00e3o e atualiza\u00e7\u00e3o, gravamos a hora atual no atualizado<\/strong> (criando ou substituindo-o). Se o documento ainda n\u00e3o contiver criado<\/strong> presumimos que essa \u00e9 a primeira altera\u00e7\u00e3o no documento, portanto, adicionamos criado<\/strong> contendo tamb\u00e9m a hora atual. Depois de estendermos o documento com os novos atributos, n\u00f3s o gravamos de volta no bucket de origem com o mesmo ID de documento.<\/p>\n
Ao mudar atualizado<\/strong> e criado<\/strong> geramos novas altera\u00e7\u00f5es no documento. A estrutura Eventing suprime a recurs\u00e3o ao n\u00e3o propagar essas altera\u00e7\u00f5es para nossa fun\u00e7\u00e3o. Caso contr\u00e1rio, essas altera\u00e7\u00f5es s\u00e3o tratadas de maneira normal: elas s\u00e3o replicadas, indexadas e at\u00e9 propagadas para outras fun\u00e7\u00f5es de Eventing.<\/p>\n
Invoca\u00e7\u00e3o de fun\u00e7\u00f5es externas com o cURL<\/h2>\n
As fun\u00e7\u00f5es de eventos podem interagir com sistemas externos usando enrolar<\/b> para chamar sua API REST. A possibilidade de interagir com sistemas externos abre uma s\u00e9rie de novos casos de uso, como a propaga\u00e7\u00e3o de altera\u00e7\u00f5es de dados para outros sistemas, notificando o aplicativo sobre eventos interessantes, enriquecendo documentos com dados de sistemas externos e assim por diante. Uma pr\u00e9via da fun\u00e7\u00e3o curl j\u00e1 estava dispon\u00edvel em vers\u00f5es anteriores do Couchbase, mas com a vers\u00e3o 6.5 o recurso foi reprojetado para torn\u00e1-lo confi\u00e1vel e seguro: as chamadas cURL s\u00e3o limitadas a um conjunto predefinido de liga\u00e7\u00f5es de URL, para cada liga\u00e7\u00e3o podemos especificar autentica\u00e7\u00e3o, criptografia e valida\u00e7\u00e3o de certificado, conforme necess\u00e1rio.<\/p>\n
No exemplo a seguir, definiremos um aplicativo que escuta as altera\u00e7\u00f5es no bucket de amostra de viagem. Salve o c\u00f3digo do aplicativo abaixo no arquivo 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(\"Companhia a\u00e9rea \" + id + \" alterada\");\r\n    response.send(\"OK\");\r\n});\r\n \r\nvar server = app.listen(3000, () => {\r\n    console.log(\"Listening...\");\r\n});<\/pre>\n
O aplicativo define um ponto de extremidade \/api\/companhia a\u00e9rea<\/strong> para receber notifica\u00e7\u00f5es sobre altera\u00e7\u00f5es nos dados da companhia a\u00e9rea como solicita\u00e7\u00f5es POST com o corpo contendo o ID da companhia a\u00e9rea. O aplicativo est\u00e1 configurado com autentica\u00e7\u00e3o b\u00e1sica, esperando que o usu\u00e1rio couchbase<\/strong> com a senha senha<\/strong>.<\/p>\n
Execute os seguintes comandos para instalar os pacotes node.js necess\u00e1rios e executar o aplicativo:<\/p>\n
npm init -y\r\nnpm install express body-parser express-basic-auth --save\r\nnode app.js\r\n<\/pre>\n
Agora vamos criar uma Eventing Function que notifica nosso aplicativo sobre as altera\u00e7\u00f5es nos documentos da companhia a\u00e9rea. Todas as APIs externas que podem ser chamadas pela fun\u00e7\u00e3o devem ser declaradas como liga\u00e7\u00f5es de URL. Supondo que 192.168.61.1 seja o IP da m\u00e1quina em que iniciamos o aplicativo, declaramos uma associa\u00e7\u00e3o de URL para o URL https:\/\/192.168.61.1:3000\/api<\/strong> e nome\u00e1-lo notifyApi<\/b>.<\/p>\n
\"\"<\/p>\n
Uma liga\u00e7\u00e3o de URL pode usar o protocolo http ou https. Tamb\u00e9m podemos especificar diferentes tipos de autentica\u00e7\u00e3o e ativar cookies para evitar a repeti\u00e7\u00e3o da autentica\u00e7\u00e3o. No nosso caso, selecionamos a autentica\u00e7\u00e3o b\u00e1sica com o usu\u00e1rio couchbase<\/strong> e senha senha<\/strong>.<\/p>\n
Na pr\u00f3xima etapa, forne\u00e7a o c\u00f3digo da fun\u00e7\u00e3o, que escuta as altera\u00e7\u00f5es dos documentos do tipo companhia a\u00e9rea<\/strong> e encaminha essas altera\u00e7\u00f5es para o aplicativo usando enrolar<\/b> chamadas:<\/p>\n
fun\u00e7\u00e3o OnUpdate(doc, meta) {\r\n    se (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        se (response.status ! = 200) {\r\n            log('request failed', response);\r\n        }\r\n    }\r\n}<\/pre>\n
O enrolar<\/b> recebe tr\u00eas par\u00e2metros: o m\u00e9todo da solicita\u00e7\u00e3o HTTP, a vincula\u00e7\u00e3o de URL e o objeto de solicita\u00e7\u00e3o que pode conter os seguintes atributos:<\/p>\n