{"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\/pt\/eventing-data-consolidation-in-couchbase\/","title":{"rendered":"Usando o Eventing Service para consolidar dados de v\u00e1rias fontes"},"content":{"rendered":"

Uma das muitas vantagens de usar um banco de dados baseado em documentos, como o Couchbase, \u00e9 a capacidade de usar um modelo de dados flex\u00edvel para armazenar dados sem as restri\u00e7\u00f5es de um esquema r\u00edgido e predeterminado. Muitos clientes escolhem um banco de dados NoSQL para suportar a ingest\u00e3o de dados de v\u00e1rias fontes. Mas e se voc\u00ea precisar que seus dados sejam transformados para que correspondam aos dados existentes? Talvez voc\u00ea precise de todos eles em um formato uniforme para fins de relat\u00f3rio. Seja qual for o motivo, esse \u00e9 um uso perfeito para o Servi\u00e7o de eventos<\/a> no Couchbase.<\/span><\/p>\n

Servi\u00e7o de eventos do Couchbase<\/h2>\n

O servi\u00e7o de eventos \u00e9 um recurso interno do Couchbase Enterprise Edition que permite a aplica\u00e7\u00e3o de fun\u00e7\u00f5es JavaScript, <\/span>ou lambdas<\/em><\/span>que respondem a eventos de muta\u00e7\u00e3o. Sempre que um documento \u00e9 criado, modificado ou exclu\u00eddo, uma a\u00e7\u00e3o pode ser executada <\/span>por execu\u00e7\u00e3o de l\u00f3gica comercial pura em seu JavaScript<\/em><\/span>. H\u00e1 v\u00e1rias a\u00e7\u00f5es que podem ser executadas, como enriquecimento de dados, chamada de fluxos de trabalho externos (por meio de chamadas \u00e0 API RESTful) e eventos baseados em cron\u00f4metro (retomada da execu\u00e7\u00e3o no futuro). Pense nos eventos como um banco de dados legado <\/span>p\u00f3s<\/span>gatilho com esteroides.<\/span><\/p>\n

Consolida\u00e7\u00e3o de dados<\/h2>\n

Neste exemplo simplificado, imagine que voc\u00ea acabou de adquirir duas novas fontes de dados de clientes. Esses dados podem ser provenientes de uma fonte normalizada, de um arquivo simples ou de ambos, e voc\u00ea deseja que esses dados correspondam aos dados de clientes existentes armazenados em um formato desnormalizado.<\/span><\/p>\n

A primeira fonte de dados \u00e9 um banco de dados normalizado (<\/span>limpo e preciso) <\/span>contendo clientes no Canad\u00e1. Cada registro de cliente aponta para um endere\u00e7o de cobran\u00e7a e um endere\u00e7o de entrega, e cada endere\u00e7o \u00e9 normalizado para eliminar a redund\u00e2ncia de dados de cidade e prov\u00edncia:<\/span><\/p>\n

\"Normalized
\nA segunda fonte de dados \u00e9 um arquivo simples que tamb\u00e9m cont\u00e9m clientes canadenses, mas que n\u00e3o rastreia endere\u00e7os de cobran\u00e7a e de envio separados. Como voc\u00ea pode ver, <\/span>apenas um \u00fanico elemento de dados de endere\u00e7o<\/span> \u00e9 armazenado no registro do cliente:<\/span><\/p>\n

\"Customer<\/p>\n

Precisamos transformar esses dados \u00e0 medida que eles chegam para que correspondam ao nosso banco de dados de clientes existente, que \u00e9 desnormalizado, de modo que os endere\u00e7os de cobran\u00e7a e envio sejam anexados aos dados do cliente (<\/span>da segunda fonte<\/span>) como subdocumentos:<\/span><\/p>\n

\"Creating<\/p>\n

Vamos come\u00e7ar com <\/span>f\u00e1cil<\/span> A primeira solu\u00e7\u00e3o \u00e9 a importa\u00e7\u00e3o de arquivos simples. O processo de transforma\u00e7\u00e3o desses dados envolve a c\u00f3pia dos dados do cliente (nome, e-mail, telefone, nome da empresa) em um novo documento. Em seguida, os dados de endere\u00e7o precisam ser copiados em subdocumentos para os endere\u00e7os de faturamento e de correspond\u00eancia. Como temos apenas um endere\u00e7o por cliente, copiaremos esse endere\u00e7o para o subdocumento de endere\u00e7o de faturamento e de correspond\u00eancia:<\/span><\/p>\n

\"Importing
\nC\u00f3digo JavaScript para consolidar as tabelas<\/span><\/h2>\n

O c\u00f3digo do Eventing para realizar isso \u00e9 bastante simples:<\/span><\/p>\n

 \u00a01 function OnUpdate(doc, meta) {\r\n\u00a0\u00a02 \u00a0 \u00a0 const new_doc = {}; \/\/ New customer document\r\n\u00a0\u00a03 \u00a0 \u00a0 const address = {}; \/\/ New address document\r\n\u00a0\u00a04\r\n\u00a0\u00a05 \u00a0 \u00a0 new_doc['first_name'] = doc.first_name;\r\n\u00a0\u00a06 \u00a0 \u00a0 new_doc['last_name'] = doc.last_name;\r\n\u00a0\u00a07 \u00a0 \u00a0 new_doc['email'] = doc.email;\r\n\u00a0\u00a08 \u00a0 \u00a0 new_doc['phone'] = doc.phone;\r\n\u00a0\u00a09 \u00a0 \u00a0 new_doc['company_name'] = doc.company_name;\r\n\u00a010\r\n\u00a011 \u00a0 \u00a0 address['street_address_1'] = doc.street_address_1;\r\n\u00a012 \u00a0 \u00a0 address['street_address_2'] = doc.street_address_2;\r\n\u00a013 \u00a0 \u00a0 address['city'] = doc.city;\r\n\u00a014 \u00a0 \u00a0 address['state'] = doc.province;\r\n\u00a015 \u00a0 \u00a0 address['zip_code'] = doc.postal_code;\r\n\u00a016\r\n\u00a017 \u00a0 \u00a0 \/\/ Add address document to customer document as subdocuments\r\n\u00a018 \u00a0 \u00a0 new_doc['billing_address'] = address;\r\n\u00a019 \u00a0 \u00a0 new_doc['mailing_address'] = address;\r\n\u00a020\r\n\u00a021 \u00a0 \u00a0 \/\/ This creates the new document in the destination bucket\r\n\u00a022 \u00a0 \u00a0 dest_bkt[doc.email] = new_doc;\r\n\u00a023\r\n\u00a024 \u00a0 \u00a0 \/\/ Delete original document - uncomment below\r\n\u00a025 \u00a0 \u00a0 \/\/ delete sch2[meta.id];\r\n\u00a026\r\n\u00a027 \u00a0 \u00a0 log(\"Doc created\/updated\", meta.id);\r\n\u00a028 }<\/pre>\n
O c\u00f3digo acima deve ser f\u00e1cil de entender, mesmo para programadores que n\u00e3o trabalham com JavaScript, mas vou dividi-lo por se\u00e7\u00e3o para ter certeza.<\/span><\/p>\n