Se voc\u00ea j\u00e1 conhece o Couchbase e o Eventing, fique \u00e0 vontade para pular a breve vis\u00e3o geral e passar para a se\u00e7\u00e3o exemplos.<\/a><\/em><\/p>\n Em primeiro lugar, vamos dar uma olhada no b\u00e1sico Ciclo de vida de eventos<\/a>.<\/p>\n As etapas abaixo mostram como \u00e9 f\u00e1cil escrever e usar uma Eventing Function<\/p>\n \u00c9 isso, agora voc\u00ea tem uma fun\u00e7\u00e3o distribu\u00edda que responde a muta\u00e7\u00f5es em seu conjunto de dados em tempo real em todo o cluster.<\/p>\n O servi\u00e7o Eventing oferece uma plataforma sem infraestrutura que pode escalonar suas Eventing Functions \u00e0 medida que sua empresa cresce, seja um pico \u00fanico ou um aumento mensal nos armazenamentos de dados ou nos clientes atendidos, sem se preocupar com o fato de que suas fun\u00e7\u00f5es Eventing baseadas em JavaScript est\u00e3o sendo executadas de forma distribu\u00edda paralela robusta e confi\u00e1vel. Para saber mais sobre o Couchbase Eventing, consulte a se\u00e7\u00e3o Vis\u00e3o geral de eventos<\/a> em nossa documenta\u00e7\u00e3o.<\/p>\n Os exemplos deste artigo mostram que, em alguns casos, o Eventing pode agir como uma gota de \u00f3leo para \"liberar\" as partes m\u00f3veis de seus aplicativos.<\/p>\n Gosto de pensar em um cluster do Couchbase como um conjunto de \"microsservi\u00e7os\" escalon\u00e1veis e interoper\u00e1veis. Esses servi\u00e7os podem ser conectados e dimensionados para atender a um conjunto espec\u00edfico de necessidades operacionais e comerciais.<\/p>\n O Couchbase oferece escalonamento multidimensional, ou MDS, em seis servi\u00e7os principais com interfer\u00eancia m\u00ednima de recursos entre eles. Al\u00e9m disso, cada servi\u00e7o do Couchbase pode ser dimensionado de forma independente, bastando adicionar mais n\u00f3s. Isso permite que os clientes criem o cluster ideal de v\u00e1rios n\u00f3s com o menor TCO poss\u00edvel para a(s) tarefa(s) em quest\u00e3o.<\/p>\n Como em todas as linhas de produtos, os servi\u00e7os mais recentes do Couchbase Query, Search, Eventing e Analytics t\u00eam alguns defeitos, mas, no conjunto, a cesta completa oferece um pacote unificado ou um balc\u00e3o \u00fanico para resolver uma infinidade de problemas. Falando s\u00e9rio, se voc\u00ea n\u00e3o se importa com um produto unificado e tudo o que vai fazer \u00e9 usar o FTS, talvez considere usar o Elasticsearch, mas quando precisar integrar os resultados do FTS com o N1QL (SQL para JSON), talvez tenha sido muito melhor come\u00e7ar com o Couchbase.<\/p>\n Hoje, utilizaremos apenas dois servi\u00e7os: 1) o servi\u00e7o KV principal fornecido pelos n\u00f3s de dados; 2) o Eventing Service. Destacarei, por meio de algumas pequenas fun\u00e7\u00f5es JavaScript, como voc\u00ea pode superar alguns problemas dif\u00edceis de escala aproveitando o Eventing Service.<\/p>\n Neste artigo, usaremos a vers\u00e3o mais recente do GA, ou seja, a vers\u00e3o 6.5.1 do Couchbase<\/p>\n No entanto, se voc\u00ea n\u00e3o estiver familiarizado com o Couchbase ou com o servi\u00e7o Eventing, consulte o GET STARTED e um exemplo de Eventing, especificamente o seguinte:<\/p>\n Um sistema de produ\u00e7\u00e3o ativo armazenou bilh\u00f5es de documentos. Surgiu uma nova necessidade comercial em que os dados existentes precisam ser enriquecidos. Essa necessidade de dados adicionais afeta o conjunto completo de documentos. O impacto operacional abrange dados antigos ou hist\u00f3ricos e tamb\u00e9m dados novos ou mutantes. A empresa precisa manter o sistema de produ\u00e7\u00e3o em funcionamento ininterrupto e responder continuamente a novos dados em tempo real.<\/p>\n Considere um aplicativo de exemplo um tanto for\u00e7ado, um servi\u00e7o de pesquisa GeoIP. Esse utilit\u00e1rio precisa de um conjunto de dados para permitir a pesquisa de pa\u00edses por intervalos de endere\u00e7os IPV4. A implementa\u00e7\u00e3o inicial armazenava registros da seguinte forma:<\/p>\n Meses ou mais tarde, novos requisitos comerciais mudam. A engenharia precisava que os documentos JSON fossem enriquecidos com novos campos. O requisito era incluir as representa\u00e7\u00f5es num\u00e9ricas dos dois endere\u00e7os IPV4 existentes.<\/p>\n Uma simples fun\u00e7\u00e3o de evento de 14 linhas JavaScript (2 das quais s\u00e3o coment\u00e1rios) pode ser escrita e implementada para resolver o problema com o m\u00ednimo de recursos.<\/p>\n Ao implantar a fun\u00e7\u00e3o acima com um \"Limite de feed\" definido como \"Tudo\", todos os documentos do tipo: \"ip_country_map\" s\u00e3o processados e enriquecidos.<\/p>\n A Eventing Function \u00e9 deixada \"implantada\", reagindo a todas as novas inser\u00e7\u00f5es ou atualiza\u00e7\u00f5es (ou muta\u00e7\u00f5es) em tempo real, enriquecendo novos itens e tamb\u00e9m atualizando itens existentes em altera\u00e7\u00f5es de \"ip_start_num\" ou \"ip_end_num\" para as representa\u00e7\u00f5es \"num\u00e9ricas\" adequadas.<\/p>\n Como os documentos s\u00e3o enriquecidos (os campos antigos ainda est\u00e3o presentes), os aplicativos de produ\u00e7\u00e3o existentes continuar\u00e3o funcionando. Todos os dados novos ou alterados s\u00e3o atualizados em tempo real para o novo esquema. Os componentes do aplicativo GeoIP s\u00e3o desacoplados por meio dessa fun\u00e7\u00e3o de evento simples, de modo que podem ser atualizados um de cada vez.<\/p>\n Quando todos os componentes de produ\u00e7\u00e3o tiverem sido atualizados, a Eventing Function poder\u00e1 ser desimplantada e desativada.<\/p>\n Um sistema de produ\u00e7\u00e3o ativo armazenou mais de 7 bilh\u00f5es de documentos. Todos os documentos t\u00eam uma expira\u00e7\u00e3o autom\u00e1tica (ou TTL<\/a> para tempo de vida). O ambiente de produ\u00e7\u00e3o recebe constantemente novos dados e expira constantemente os dados antigos.<\/p>\n Foi cometido um erro operacional que resultou na cria\u00e7\u00e3o de 2 bilh\u00f5es de documentos sem validade.<\/p>\n O cliente n\u00e3o tinha os recursos (nem desejava pagar pelos recursos) para criar um \u00edndice grande para utilizar o N1QL para identificar, selecionar e eliminar os dados que n\u00e3o tinham um TTL ativo (diferente de zero) quando n\u00e3o fossem mais \u00fateis.<\/p>\n Uma simples fun\u00e7\u00e3o de evento JavaScript de seis (6) linhas (2 das quais s\u00e3o coment\u00e1rios) foi implementada e resolveu o problema com o m\u00ednimo de recursos.<\/p>\n Ao implementar a fun\u00e7\u00e3o acima com um \"Limite de alimenta\u00e7\u00e3o\" definido como \"Tudo\", todo o conjunto de documentos no bucket de origem foi digitalizado. Todos os documentos com um TTL diferente de zero (o que significa que eles n\u00e3o tinham expira\u00e7\u00e3o) foram ignorados. Somente os documentos correspondentes com um TTL maior que zero s\u00e3o exclu\u00eddos.<\/p>\n Depois que o bucket de origem foi limpo, a Eventing Function n\u00e3o foi implantada, pois era usada como uma ferramenta administrativa.<\/p>\n Observe que poder\u00edamos substituir o teste de expira\u00e7\u00e3o !== 0 em nosso JavaScript para filtrar os dados para qualquer finalidade necess\u00e1ria.<\/p>\n \u00c9 muito f\u00e1cil adivinhar o que estamos fazendo abaixo:<\/p>\n Na verdade, poder\u00edamos facilmente atualizar o que foi dito acima para executar um arquivamento em cascata e excluir n\u00e3o apenas o cliente, mas qualquer outra informa\u00e7\u00e3o relacionada, como pedidos, devolu\u00e7\u00f5es e endere\u00e7os de entrega. Consulte o exemplo Cascade Delete<\/a> na documenta\u00e7\u00e3o de Eventing.<\/p>\n Uma empresa que executa o Couchbase no local em produ\u00e7\u00e3o precisava compartilhar informa\u00e7\u00f5es de perfil de clientes (150 milh\u00f5es e em crescimento). Seu parceiro de neg\u00f3cios tamb\u00e9m est\u00e1 executando o Couchbase, mas em um provedor de nuvem, o AWS.<\/p>\n Dado um registro de perfil t\u00edpico como o seguinte:<\/p>\n Eles n\u00e3o podiam simplesmente compartilhar todo o perfil, pois ele continha dados confidenciais sobre as prefer\u00eancias do usu\u00e1rio e os m\u00e9todos de pagamento. Eles s\u00f3 precisavam compartilhar um subconjunto limitado, como o seguinte:<\/p>\n<\/div>\n O cliente queria substituir a solu\u00e7\u00e3o SPARK de uso intermedi\u00e1rio, que exigia horas de falha para inicializar e fornecia apenas um processo em lote lento (horas para refletir as atualiza\u00e7\u00f5es) e sincronizar as informa\u00e7\u00f5es do perfil em tempo real.<\/p>\n Uma simples fun\u00e7\u00e3o de eventos de nove (9) linhas JavaScript (3 das quais s\u00e3o coment\u00e1rios) foi implementada e resolveu o problema com recursos m\u00ednimos.<\/p>\n Ao implementar a fun\u00e7\u00e3o acima com um \"Limite de alimenta\u00e7\u00e3o\" definido como \"Tudo\", todo o conjunto de documentos no bucket de origem foi digitalizado e todos os documentos do tipo: \"master_profile\" foram processados e apenas um subdocumento de cada perfil sem as informa\u00e7\u00f5es confidenciais foi copiado para o bucket de destino compartilhado.<\/p>\n A Eventing Function \u00e9 sempre implantada, reagindo a todas as altera\u00e7\u00f5es (ou muta\u00e7\u00f5es) de perfil de usu\u00e1rio em tempo real e encaminhando cada muta\u00e7\u00e3o para o bucket de destino do AWS.<\/p>\n Nesse caso de uso, uma sincroniza\u00e7\u00e3o final de balde para balde \u00e9 realizada por meio do Couchbase XCDR<\/a> em nenhum momento os dados confidenciais deixam o cluster local e nunca s\u00e3o transmitidos para o AWS.<\/p>\n Eventing Simple Yet Powerful: Eventing allows small scripts to overcome hard to solve problems. If you are familiar with both Couchbase and Eventing please feel free to skip the brief overview and skip\u00a0ahead to the examples. Overview: First off, let’s […]<\/p>","protected":false},"author":42711,"featured_media":8745,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"inline_featured_image":false,"footnotes":""},"categories":[1814,1815,1821,1816,2273,9411],"tags":[1445,9271,2046],"ppma_author":[9113],"class_list":["post-8743","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-application-design","category-best-practices-and-tutorials","category-couchbase-architecture","category-couchbase-server","category-eventing","category-multi-dimensional-scaling","tag-mds","tag-multi-dimensional-scaling","tag-mutation"],"acf":[],"yoast_head":"\nVis\u00e3o geral:<\/h2>\n
![\"Eventing](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2020\/05\/cron_implementation_1_image_0_lifecycle_overview_notitle_b-1024x398.png\")
<\/p>\n\n
O Couchbase \u00e9 um banco de dados que voc\u00ea constr\u00f3i sob encomenda:<\/h2>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2017\/07\/MDS-container-1-1024x405.png\")
<\/p>\n\n
Pr\u00e9-requisitos \/ Aprendendo sobre Eventing:<\/h2>\n
\n
Enriquecimento de dados por meio de eventos:<\/h2>\n
Um problema t\u00edpico do cliente<\/h4>\n
{\r\n \"type\": \"ip_country_map\",\r\n \"country\": \"RU\",\r\n \"ip_start\": \"7.12.60.1\",\r\n \"ip_end\": \"7.62.60.9\"\r\n}<\/pre>\n{\r\n \"type\": \"ip_country_map\",\r\n \"country\": \"RU\",\r\n \"ip_end\": \"7.62.60.9\",\r\n \"ip_start\": \"7.12.60.1\",\r\n \"ip_num_start\": 118242305,\r\n \"ip_num_end\": 121519113\r\n}<\/pre>\n<\/div>\nEventing para o resgate<\/h4>\n
function OnUpdate(doc, meta) {\r\n if (doc.type !== \"ip_country_map\" ) return;\r\n doc[\"ip_num_start\"] = get_numip_first_3_octets(doc[\"ip_start\"]);\r\n doc[\"ip_num_end\"] = get_numip_first_3_octets(doc[\"ip_end\"]);\r\n \/\/ src is a bucket alias to the source bucket in settings, write back to it\r\n src[meta.id]=doc;\r\n}\r\nfunction get_numip_first_3_octets(ip) {\r\n if (!ip) return 0;\r\n var parts = ip.split('.');\r\n \/\/ IP Number = A x (256*256*256) + B x (256*256) + C x 256 + D\r\n return = (parts[0]*(256*256*256)) + (parts[1]*(256*256)) +\r\n (parts[2]*256) + parseInt(parts[3]);\r\n}<\/pre>\n<\/div>\nElimina\u00e7\u00e3o de dados obsoletos por meio de eventos:<\/h2>\n
Um problema t\u00edpico do cliente<\/h4>\n
Eventing para o resgate<\/h4>\n
function OnUpdate(doc, meta) {\r\n if (meta.expiration !== 0) return;\r\n \/\/ delete all items that have TTL or expiration of 0\r\n \/\/ src is a bucket alias to the source bucket in settings, delete from it.\r\n delete src[meta.id];\r\n}<\/pre>\n<\/div>\nfunction OnUpdate(doc, meta) {\r\n if (!(doc.type === \"customer\"&& doc.active === false)) return \r\n \/\/ archive the customer to the bucket aias arc and remove from the bucket alias src\r\n arc[meta.id] = doc;\r\n delete src[meta.id];\r\n}<\/pre>\nRemo\u00e7\u00e3o de dados confidenciais via Eventing:<\/h2>\n
Um problema t\u00edpico do cliente<\/h4>\n
{\r\n \"type\": \"master_profile\",\r\n \"first_name\": \"Peter\",\r\n \"last_name\": \"Chang\",\r\n \"id\": 80927079070,\r\n \"basic_profile\": {\r\n \"partner_id\": 80980221,\r\n \"services\": [\r\n {\r\n \"music\": true\r\n },\r\n {\r\n \"radio\": true\r\n },\r\n {\r\n \"video\": false\r\n }\r\n ]\r\n },\r\n \"sensitive_profile\": {\r\n \"ssn\": \"111-11-1111\",\r\n \"credit_card\": {\r\n \"number\": \"3333-333-3333-3333\",\r\n \"expires\": \"01\/09\",\r\n \"ccv\": \"111\"\r\n }\r\n },\r\n \"address\": {\r\n \"home\": {\r\n \"street\": \"4032 Kenwood Drive\",\r\n \"city\": \"Boston\",\r\n \"zip\": \"02102\"\r\n },\r\n \"billing\": {\r\n \"street\": \"541 Bronx Street\",\r\n \"city\": \"Boston\",\r\n \"zip\": \"02102\"\r\n }\r\n },\r\n \"phone\": {\r\n \"home\": \"800-555-9201\",\r\n \"work\": \"877-123-8811\",\r\n \"cell\": \"878-234-8171\"\r\n },\r\n \"locale\": \"en_US\",\r\n \"timezone\": -7,\r\n \"gender\": \"M\"\r\n}<\/pre>\n{\r\n \"type\": \"shared_profile\",\r\n \"first_name\": \"Peter\",\r\n \"id\": 80927079070,\r\n \"basic_profile\": {\r\n \"partner_id\": 80980221,\r\n \"services\": [\r\n {\r\n \"music\": true\r\n },\r\n {\r\n \"radio\": true\r\n },\r\n {\r\n \"video\": false\r\n }\r\n ]\r\n },\r\n \"timezone\": -7\r\n}<\/pre>\n<\/div>\nEventing para o resgate<\/h4>\n
function OnUpdate(doc, meta) {\r\n \/\/ only process our profile documents\r\n if (doc.type !== \"master_profile\") return;\r\n \/\/ aws_bkt is a bucket alias to the target bucket to replicate to AWS via \r\n \/\/ XCDR. Write the minimal (non-sensitive) profile doc to the bucket for AWS.\r\n aws_bkt[\"shared_profile::\"+doc.id] = \r\n { \"type\": \"shared_profile\", \"first_name\": doc.first_name, \"id\": doc.id, \r\n \"basic_profile\": doc.basic_profile, \"timezone\": doc.timezone };\r\n}<\/pre>\n<\/div>\nRecursos<\/h3>\n
\n
Refer\u00eancias<\/h3>\n
\n
\nhttps:\/\/docs.couchbase.com\/server\/current\/eventing\/eventing-overview.html<\/a><\/li>\n
\nhttps:\/\/docs.couchbase.com\/server\/6.5\/introduction\/whats-new.html<\/a><\/li>\n
\nhttps:\/\/www.couchbase.com\/blog\/tag\/eventing\/<\/a><\/li>\n<\/ul>","protected":false},"excerpt":{"rendered":"