Si est\u00e1 familiarizado tanto con Couchbase como con Eventing, no dude en omitir la breve descripci\u00f3n general y pasar a la parte siguiente. ejemplos.<\/a><\/em><\/p>\n En primer lugar, veamos lo b\u00e1sico Ciclo de vida de los eventos<\/a>.<\/p>\n Los siguientes pasos muestran lo f\u00e1cil que es escribir y utilizar una funci\u00f3n de eventos<\/p>\n Eso es todo, ahora tiene una funci\u00f3n distribuida que responde a las mutaciones en su conjunto de datos en tiempo real en todo su cl\u00faster.<\/p>\n El servicio de Eventing proporciona una plataforma sin infraestructura que puede escalar sus funciones de Eventing a medida que su negocio experimenta un crecimiento, ya sea un pico de una sola vez o un aumento mensual en los almacenes de datos o clientes atendidos sin preocuparse por el hecho de que sus funciones de Eventing basadas en JavaScript se est\u00e1n ejecutando de una manera robusta, fiable y distribuida en paralelo. Para obtener m\u00e1s informaci\u00f3n sobre Couchbase Eventing, consulte la p\u00e1gina Concurso completo<\/a> en nuestra documentaci\u00f3n.<\/p>\n Los ejemplos de este art\u00edculo muestran que en algunos casos Eventing puede actuar como una gota de aceite para \"liberar\" las partes m\u00f3viles de sus aplicaciones.<\/p>\n Me gusta pensar en un cl\u00faster de Couchbase como un conjunto de \"microservicios\" escalables e interoperables. Estos servicios pueden conectarse entre s\u00ed y dimensionarse para satisfacer un conjunto espec\u00edfico de necesidades operativas y empresariales.<\/p>\n Couchbase proporciona escalado multidimensional, o MDS, a trav\u00e9s de seis servicios clave con una interferencia m\u00ednima de recursos entre ellos. Adem\u00e1s, cada servicio de Couchbase es escalable de forma independiente, simplemente a\u00f1adiendo m\u00e1s nodos. Esto permite a los clientes crear el cl\u00faster multinodo ideal con el menor coste total de propiedad posible para la tarea o tareas en cuesti\u00f3n.<\/p>\n Como todas las l\u00edneas de productos, los nuevos servicios de Couchbase Query, Search, Eventing y Analytics tienen algunos defectos, pero en conjunto, la cesta completa proporciona una suite unificada, o una ventanilla \u00fanica para resolver un sinf\u00edn de problemas. En serio, si no te importa un producto unificado y todo lo que vas a hacer es usar FTS, podr\u00edas considerar usar Elasticsearch, pero una vez que necesites integrar tus resultados de FTS con N1QL (SQL para JSON), podr\u00edas haber empezado mucho mejor con Couchbase.<\/p>\n Hoy vamos a utilizar s\u00f3lo dos servicios 1) el servicio primario de KV proporcionado por los nodos de datos 2) el servicio de eventos. Voy a destacar a trav\u00e9s de unas peque\u00f1as funciones de JavaScript c\u00f3mo se puede superar algunos problemas dif\u00edciles a escala aprovechando el servicio de eventos.<\/p>\n En este art\u00edculo vamos a utilizar la \u00faltima versi\u00f3n de GA, es decir, Couchbase versi\u00f3n 6.5.1<\/p>\n Sin embargo, si usted no est\u00e1 familiarizado con Couchbase o el servicio Eventing por favor camine a trav\u00e9s de GET STARTED y un ejemplo Eventing espec\u00edficamente se refieren a los siguientes:<\/p>\n Un sistema de producci\u00f3n en vivo ha almacenado miles de millones de documentos. Ha surgido una nueva necesidad empresarial que exige enriquecer los datos existentes. Esta necesidad de datos adicionales afecta a todo el conjunto de documentos. El impacto operativo abarca tanto los datos antiguos o hist\u00f3ricos como los nuevos o mutantes. La empresa necesita mantener el sistema de producci\u00f3n en funcionamiento ininterrumpido y responder continuamente a los nuevos datos en tiempo real.<\/p>\n Consideremos un ejemplo de aplicaci\u00f3n un tanto artificioso: un servicio de b\u00fasqueda GeoIP. Esta utilidad necesita un conjunto de datos que permita buscar pa\u00edses por rangos de direcciones IPV4. La implementaci\u00f3n inicial almacenaba los registros de la siguiente manera:<\/p>\n Meses o m\u00e1s tarde cambian los nuevos requisitos empresariales. Ingenier\u00eda necesitaba enriquecer los documentos JSON con nuevos campos. El requisito era incluir las representaciones num\u00e9ricas de las dos direcciones IPV4 existentes.<\/p>\n Una simple funci\u00f3n de eventos de catorce (14) l\u00edneas JavaScript (2 de las cuales son comentarios) puede escribirse e implementarse para resolver el problema con recursos m\u00ednimos.<\/p>\n Al desplegar la funci\u00f3n anterior con un \"l\u00edmite de alimentaci\u00f3n\" establecido en \"Todo\", todos los documentos de tipo \"ip_country_map\" son procesados y enriquecidos.<\/p>\n La funci\u00f3n de eventos se deja \"desplegada\" reaccionando a todas las nuevas inserciones o actualizaciones (o mutaciones) en tiempo real enriqueciendo los nuevos elementos y tambi\u00e9n actualizando los elementos existentes en los cambios de \"ip_start_num\" o \"ip_end_num\" a las representaciones \"num\u00e9ricas\" adecuadas.<\/p>\n Como los documentos est\u00e1n enriquecidos (los campos antiguos siguen presentes), las aplicaciones de producci\u00f3n existentes seguir\u00e1n funcionando. Todos los datos nuevos o modificados se actualizan en tiempo real al nuevo esquema. Los componentes de la aplicaci\u00f3n GeoIP se desacoplan a trav\u00e9s de esta sencilla funci\u00f3n de eventos, de modo que pueden actualizarse de uno en uno.<\/p>\n Cuando todos los componentes de producci\u00f3n han sido actualizados, la funci\u00f3n de eventos puede ser desinstalada y dada de baja.<\/p>\n Un sistema de producci\u00f3n en vivo ha almacenado m\u00e1s de 7.000 millones de documentos. Todos los documentos tienen una caducidad autom\u00e1tica (o TTL<\/a> para el tiempo de vida). El entorno de producci\u00f3n recibe constantemente datos nuevos y expira constantemente datos antiguos.<\/p>\n Se cometi\u00f3 un error operativo que provoc\u00f3 la creaci\u00f3n de 2.000 millones de documentos sin fecha de caducidad.<\/p>\n El cliente no ten\u00eda los recursos (ni deseaba pagar por los recursos) para crear un gran \u00edndice para utilizar N1QL para identificar seleccionar y purgar los datos que carec\u00edan de un TTL activo (distinto de cero) cuando ya no eran \u00fatiles.<\/p>\n Una simple funci\u00f3n de eventos de seis (6) l\u00edneas JavaScript (2 de las cuales son comentarios) se implement\u00f3 y resolvi\u00f3 el problema con recursos m\u00ednimos.<\/p>\n Al desplegar la funci\u00f3n anterior con un \"L\u00edmite de alimentaci\u00f3n\" establecido en \"Todo\", se escane\u00f3 todo el conjunto de documentos del bucket de origen. Todos los documentos con un TTL distinto de cero (lo que significa que no ten\u00edan caducidad) fueron ignorados. S\u00f3lo se eliminan los documentos coincidentes con un TTL superior a cero.<\/p>\n Una vez limpiado el bucket de origen, se desinstal\u00f3 la funci\u00f3n de eventos, ya que se utilizaba como herramienta administrativa.<\/p>\n Tenga en cuenta que podr\u00edamos reemplazar la prueba de expiraci\u00f3n !== 0 en nuestro JavaScript para filtrar los datos para cualquier prop\u00f3sito necesario.<\/p>\n Es bastante f\u00e1cil adivinar lo que estamos haciendo a continuaci\u00f3n:<\/p>\n De hecho, podr\u00edamos actualizar f\u00e1cilmente lo anterior para realizar un archivo en cascada y eliminar no s\u00f3lo del cliente sino de cualquier otra informaci\u00f3n relacionada como pedidos, devoluciones y direcciones de env\u00edo. Consulte el ejemplo Cascada Suprimir<\/a> en la documentaci\u00f3n de Eventing.<\/p>\n Una empresa que ejecuta Couchbase on-premises en producci\u00f3n necesitaba compartir informaci\u00f3n de perfiles de clientes (150M y creciendo). Su socio comercial tambi\u00e9n ejecuta Couchbase, pero en un proveedor en la nube, AWS.<\/p>\n Dado un registro de perfil t\u00edpico como el siguiente:<\/p>\n No pod\u00edan compartir todo el perfil, ya que conten\u00eda datos sensibles sobre las preferencias de los usuarios y los m\u00e9todos de pago. Solo necesitaban compartir un subconjunto limitado como el siguiente:<\/p>\n<\/div>\n El cliente quer\u00eda sustituir la soluci\u00f3n SPARK de desgaste intermedio, que requer\u00eda horas en caso de fallo para inicializarse y s\u00f3lo ofrec\u00eda un lento proceso por lotes (horas para reflejar las actualizaciones) y sincronizar la informaci\u00f3n del perfil en tiempo real.<\/p>\n Una simple funci\u00f3n de eventos de nueve (9) l\u00edneas JavaScript (3 de las cuales son comentarios) fue desplegada y resolvi\u00f3 el problema con recursos m\u00ednimos.<\/p>\n Al desplegar la Funci\u00f3n anterior con un \"L\u00edmite de alimentaci\u00f3n\" establecido en \"Todo\", se escane\u00f3 todo el conjunto de documentos del bucket de origen y se procesaron todos los documentos de tipo: \"master_profile\" y s\u00f3lo se copi\u00f3 en el bucket de destino compartido un subdocumento de cada perfil sin la informaci\u00f3n sensible.<\/p>\n La funci\u00f3n de eventos siempre se deja desplegada reaccionando a todos los cambios (o mutaciones) de perfil de usuario en tiempo real y reenviando todas y cada una de las mutaciones al bucket de destino de AWS.<\/p>\n En este caso de uso se realiza una sincronizaci\u00f3n final de cubo a cubo a trav\u00e9s de Couchbase XCDR<\/a> Los datos confidenciales no salen en ning\u00fan momento del cl\u00faster local y nunca se transmiten a 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":"\nVisi\u00f3n general:<\/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
Couchbase una base de datos que se construye por encargo:<\/h2>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2017\/07\/MDS-container-1-1024x405.png\")
<\/p>\n\n
Requisitos previos \/ Aprendizaje del concurso completo:<\/h2>\n
\n
Enriquecimiento de datos mediante eventos:<\/h2>\n
Un problema t\u00edpico de un 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 al rescate<\/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>\nPurga de datos obsoletos mediante eventos:<\/h2>\n
Un problema t\u00edpico de un cliente<\/h4>\n
Eventing al rescate<\/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>\nEliminaci\u00f3n de datos sensibles mediante Eventing:<\/h2>\n
Un problema t\u00edpico de un 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 al rescate<\/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
Referencias<\/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":"