{"id":12724,"date":"2022-01-28T08:00:34","date_gmt":"2022-01-28T16:00:34","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/?p=12724"},"modified":"2024-03-08T18:09:25","modified_gmt":"2024-03-09T02:09:25","slug":"event-driven-architecture-with-solace-event-broker-couchbase","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/es\/event-driven-architecture-with-solace-event-broker-couchbase\/","title":{"rendered":"Arquitectura basada en eventos con Solace Event Broker y Couchbase"},"content":{"rendered":"

La arquitectura as\u00edncrona basada en eventos de Couchbase es el n\u00facleo de su dise\u00f1o. Las mutaciones de documentos fluyen continuamente hacia Couchbase Index, Analytics, Eventos<\/a> y servicios de b\u00fasqueda.<\/span><\/p>\n

Esta arquitectura garantiza que los servicios de Couchbase se actualizan en tiempo real y nos permite integrar Couchbase a la perfecci\u00f3n en su arquitectura basada en eventos.<\/span><\/p>\n

Esta entrada del blog demuestra c\u00f3mo se puede integrar Couchbase con un corredor de eventos. <\/span>En este post, utilizo el popular <\/span>Agente de mensajes Solace PubSub<\/span><\/a>pero la integraci\u00f3n con otros productos de mensajer\u00eda, como Kafka, es muy similar.<\/span><\/p>\n

Arquitectura general<\/span><\/h4>\n

Couchbase puede interactuar con otros sistemas usando los SDKs de Couchbase y varios Couchbase Connectors, como el que tenemos para Kafka. Para esta integraci\u00f3n, usamos un enfoque alternativo, Couchbase Eventing Service. El servicio de eventos te permite actuar r\u00e1pidamente sobre los cambios (mutaciones) de tus datos activando funciones JavaScript. El servicio de eventos soporta cURL de forma nativa y te permite llamar a servicios REST externos directamente desde el receptor JavaScript.<\/span><\/p>\n

Utilizamos esta capacidad para enviar datos a Solace PubSub+ utilizando su API de mensajer\u00eda REST. Los mensajes se env\u00edan a un Solace Topic que sus suscriptores pueden consumir.<\/span><\/p>\n

En esta integraci\u00f3n, aplicamos un <\/span>unidireccional<\/span><\/i> POST <\/span><\/i>a Solace, ilustrado en la siguiente figura. Aqu\u00ed, la funci\u00f3n Couchbase Eventing env\u00eda un <\/span>HTTP POST <\/span><\/i>con el documento en el cuerpo del mensaje al agente de eventos Solace PubSub+. El agente de eventos acusa recibo del mensaje con un <\/span>HTTP 200 OK <\/span><\/i>respuesta. El mensaje est\u00e1 ahora en manos del Solace Event Broker, donde los consumidores pueden suscribirse a los mensajes del Topic.<\/span><\/p>\n

\"Consumers<\/p>\n

Figura 1. Las mutaciones de documentos en Couchbase activan un receptor de eventos que env\u00eda el documento a un tema de Solace a trav\u00e9s de un HTTP POST. Los consumidores se suscriben al tema.<\/span><\/i><\/p>\n

Solace puede procesar el mensaje, o los suscriptores pueden suscribirse al tema a trav\u00e9s de JMS, MQTT y otros protocolos. En este post, utilizo un consumidor REST. Un microservicio puede consumir los mensajes proporcionando un punto final de devoluci\u00f3n de llamada HTTP mediante la creaci\u00f3n de un punto final de consumidor REST en Solace. El punto final de devoluci\u00f3n de llamada se llama cuando un nuevo mensaje se a\u00f1ade al tema.<\/span><\/p>\n

Ejemplo de solicitud<\/span><\/h4>\n

Para demostrarlo, hemos creado un escenario de ejemplo utilizando un conjunto de datos que viene de f\u00e1brica con Couchbase, el archivo <\/span>viaje-muestra <\/span><\/i>cubo.<\/span><\/p>\n

En nuestro escenario de prueba, queremos publicar cualquier cambio en el archivo <\/span>hotel<\/span><\/i> a Solace. Como se muestra en esta figura, un microservicio se suscribir\u00e1 y consumir\u00e1 los cambios.<\/span><\/p>\n

\"\"<\/p>\n

Las partes de la aplicaci\u00f3n de muestra son:<\/span><\/p>\n

    \n
  1. A <\/span>Funci\u00f3n de eventos de Couchbase <\/b>se activa por cada mutaci\u00f3n del <\/span>hotel<\/span><\/i> documentos. A continuaci\u00f3n, la funci\u00f3n de eventos enviar\u00e1 el <\/span>hotel<\/span><\/i> documento a un tema de Solace\u00a0<\/span><\/li>\n
  2. Corredor de eventos Solace <\/b>que contiene la cola y el tema, as\u00ed como la configuraci\u00f3n de entrega REST\u00a0<\/span><\/li>\n
  3. A <\/span>Consumidor REST <\/b>suscrito al tema Solace<\/span><\/li>\n<\/ol>\n

    Requisitos previos<\/span><\/h4>\n

    Estos tres requisitos previos son necesarios para seguir junto con la solicitud de muestra:<\/span><\/p>\n

    Couchbase 7 Enterprise Edition<\/b><\/p>\n

    Puedes ejecutar Couchbase como un cl\u00faster de un solo nodo <\/span>sobre Docker<\/span><\/a> en una m\u00e1quina local.<\/span><\/p>\n

    Creamos un cluster Couchbase de un solo nodo para prop\u00f3sitos de desarrollo (los clusters de un solo nodo no se recomiendan para uso en producci\u00f3n). Incluye los servicios Eventing y Data cuando configures Couchbase en tu cl\u00faster de un nodo.<\/span><\/p>\n

    Nube de intermediarios de eventos Solace PubSub<\/b><\/p>\n

    Inscr\u00edbete gratis <\/span>Prueba en la nube de Solace<\/span><\/a> y cree un Servicio\/VPN. Configuraremos la VPN m\u00e1s adelante en las instrucciones.<\/span><\/p>\n

    Consumidor REST<\/b><\/p>\n

    Necesitamos un punto final HTTP que acepte <\/span>HTTP POST <\/span><\/i>peticiones. Dado que utilizamos Solace PubSub+ Cloud, el consumidor REST debe ser accesible desde Internet.<\/span><\/p>\n

    En lugar de alojar su propio consumidor REST, puede utilizar un servicio gratuito (como Beeceptor) que le permita recibir <\/span>HTTP POST <\/span><\/i>solicita y reconoce un <\/span>HTTP 200 <\/span><\/i>respuesta. Eso es todo lo que necesitamos para verificar que la integraci\u00f3n funciona. Si planeas realizar pruebas m\u00e1s extensas, podr\u00edas escribir tu propio microservicio consumidor REST.<\/span><\/p>\n

    Para ello, vaya a <\/span>Beeceptor.com<\/span><\/a> y configure un nombre de endpoint. En este ejemplo, utilizo <\/span>cbtest<\/b> como punto final.<\/span><\/p>\n

    Captura la direcci\u00f3n del punto final: <\/span>https:\/\/cbtest.free.beeceptor.com<\/b><\/a>que se necesitar\u00e1 m\u00e1s adelante para configurar el punto final de recepci\u00f3n en Solace.<\/span><\/p>\n

    Configuraci\u00f3n<\/span><\/h4>\n

    Una vez establecidos los requisitos previos, es hora de configurar los distintos servicios de la aplicaci\u00f3n de ejemplo.<\/span><\/p>\n

    Configuraci\u00f3n de Solace<\/span><\/h5>\n

    En primer lugar, tenemos que configurar Solace para crear el tema, la cola y el punto final de entrega REST correspondientes. Despu\u00e9s de registrarse en la nube Solace, aseg\u00farese de haber creado un Servicio\/VPN.\u00a0<\/span><\/p>\n

    Cada uno de los siguientes pasos se ilustra con una captura de pantalla para mostrar c\u00f3mo deber\u00eda ser su configuraci\u00f3n a medida que avanza.<\/span><\/p>\n

    Configurar cola y tema<\/b><\/p>\n

    Vamos a configurar el Topic para que reciba los mensajes que enviamos desde el Servicio de Eventos de Couchbase.<\/span><\/p>\n

    En la interfaz administrativa de Solace, vaya a <\/span>Colas\/Puntos finales<\/b> y crear un nuevo <\/span>Punto final del tema<\/span><\/i> llamado<\/span> T\/rest\/pubsub<\/span><\/i> utilizando la configuraci\u00f3n predeterminada.<\/span><\/p>\n

    \"Edit<\/p>\n

    A continuaci\u00f3n, vaya a <\/span>Colas<\/b> y crear una cola llamada <\/span>Q\/bolsa\/entrada<\/span><\/i>. Mantenga los valores por defecto.<\/span><\/p>\n

    \"Edit<\/p>\n

    Ahora abra el <\/span>Q\/bolsa\/entrada<\/span><\/i> en modo de edici\u00f3n y seleccione la opci\u00f3n <\/span>Suscripciones<\/b> pesta\u00f1a. A\u00f1ada un <\/span>T\/rest\/pubsub<\/b> suscripci\u00f3n tem\u00e1tica al <\/span>Q\/bolsa\/entrada<\/span><\/i> cola.<\/span><\/p>\n

    \"Q\/couchbase\/input\"<\/p>\n

    Una vez creados la cola y el tema, el cliente REST puede suscribirse a ellos.<\/span><\/p>\n

    Ir a <\/span>\u00a0Conexiones de clientes<\/b> y cambiar a la <\/span>REST<\/b> pesta\u00f1a. Cree un nuevo <\/span>Punto final de entrega REST<\/b> con el nombre <\/span>RDPCouchbase<\/b>. Mantenga los valores por defecto y aseg\u00farese de habilitar el nuevo endpoint.<\/span><\/p>\n

    \"Edit<\/p>\n

    Navegue hasta el endpoint reci\u00e9n creado y vaya a la secci\u00f3n <\/span>Consumidores REST<\/b> ficha.<\/span><\/p>\n

    Crear un nuevo <\/span>Consumidor REST<\/b> con el nombre <\/span>demoConsumidor <\/b>y <\/span>active<\/b> al consumidor.<\/span><\/p>\n

    Proporcione la direcci\u00f3n del host remoto para el servicio REST consumidor. Como se describe en el requisito previo, proporcione su propio punto final o cree un punto final de prueba gratuito en Beeceptor.<\/span><\/p>\n

    Configure el puerto remoto; nosotros utilizamos Beeceptor con el puerto 80 y mantenemos el resto de valores por defecto.<\/span><\/p>\n

    \"\"<\/p>\n

    Navegue hasta el <\/span>Enlaces de consulta<\/b> en la pesta\u00f1a <\/span>RDPCouchbase <\/b>REST y a\u00f1ada el enlace para la cola Q\/couchbase\/input creada recientemente. A\u00f1ada el <\/span>Objetivo de la solicitud de puesto, <\/span><\/i>que corresponde a la ruta URL del receptor REST. Utilizo <\/span>\/callback<\/span><\/i>.<\/span><\/p>\n

    \"\"<\/p>\n

    Verificar la configuraci\u00f3n REST de Solace<\/span><\/h4>\n

    Para verificar que Solace est\u00e1 configurado correctamente y que los mensajes REST pueden ser consumidos por Solace as\u00ed como enviados al cliente REST, ejecute el siguiente comando cURL:<\/span><\/p>\n

    curl -v -X POST https:\/\/mrd3aaxn3oc4d.messaging.solace.cloud:9443\/T\/rest\/pubsub \\\r\n-d \"Hello World REST\" \\\r\n-H \"content-type: text\" \\\r\n-H \"Solace-delivery-mode: direct\" \\\r\n--user solace-cloud-client:g50ou1qos9ha0hauabrp0nn2ev<\/pre>\n
    Sustituye el nombre de host y las credenciales por la configuraci\u00f3n de tu entorno.<\/span><\/p>\n
    Esto concluye la configuraci\u00f3n de Solace. Ahora tenemos un tema que puede recibir mensajes y un suscriptor REST que proporciona una funci\u00f3n de devoluci\u00f3n de llamada.<\/span><\/p>\n
    Configuraci\u00f3n de Couchbase<\/span><\/h4>\n
    Con nuestro nodo Couchbase ejecutando los servicios Eventing y Data, podemos crear la funci\u00f3n eventing.<\/span><\/p>\n
    Instale el <\/span>viaje-muestra<\/span><\/i> cubo de muestras (<\/span>consulte la documentaci\u00f3n aqu\u00ed<\/span><\/a>).\u00a0<\/span><\/p>\n
    Crear un cubo llamado <\/span>rr100<\/i><\/b> (para la relaci\u00f3n residente 100%) y un \u00e1mbito denominado <\/span>concurso<\/i><\/b>. <\/span><\/i>En este \u00e1mbito, cree una colecci\u00f3n denominada <\/span>metadatos<\/i><\/b>.<\/span><\/i><\/p>\n
    rr100.eventing.metadata<\/span><\/i> ser\u00e1 utilizado por la funci\u00f3n de eventos para almacenar sus metadatos.\u00a0<\/span><\/p>\n
    En Couchbase, antes de la versi\u00f3n 7, ten\u00edas que crear un bucket dedicado para los metadatos. Con la versi\u00f3n 7 aprovechamos el soporte de \u00e1mbitos y colecciones para crear en su lugar una colecci\u00f3n dedicada para la informaci\u00f3n de metadatos de eventing.<\/span><\/p>\n
    Vaya al servicio de eventos y cree una nueva funci\u00f3n de eventos haciendo clic en <\/span>A\u00f1adir funci\u00f3n<\/span><\/i>.<\/span><\/p>\n
    \"\"<\/p>\n
    El receptor de eventos escucha el evento <\/span>hotel<\/span><\/i> colecci\u00f3n en el <\/span>inventario<\/span><\/i> \u00e1mbito dentro del <\/span>viaje-muestra<\/span><\/i> cubo. Esto activar\u00e1 nuestro receptor de eventos cada vez que se modifique un documento dentro del bucket <\/span>hotel<\/span><\/i> mientras que los cambios en documentos de otras colecciones o buckets no se recogen.<\/span><\/p>\n
    El rr100.eventing.<\/span>metadatos<\/span><\/i> bucket se utiliza para almacenar los metadatos de las funciones de eventing.<\/span><\/p>\n
    En <\/span>curlSolaceRestUrl<\/span><\/i> especifica el alias de URL para el punto final REST de Solace receptor. Proporcione la URL completa, incluida la ruta URL, que representa el tema que cre\u00f3 durante la configuraci\u00f3n de Solace. Por ejemplo <\/span>https:\/\/mrd3aaxn3oc4d.messaging.solace.cloud:9443\/T\/rest\/pubsub<\/span><\/p>\n
    El endpoint Solace requiere autenticaci\u00f3n. Configuramos <\/span>b\u00e1sico<\/span><\/i> autenticaci\u00f3n y proporcionar las credenciales.\u00a0<\/span><\/p>\n
    (<\/span>Nota: Hubo un error en Couchbase 7.0.X que puede perder la contrase\u00f1a de tus credenciales cURL. Los problemas se pueden evitar volviendo a escribir la contrase\u00f1a si editas la configuraci\u00f3n de tu Eventing Function y realizas un \"Guardar\".<\/span>)<\/span><\/p>\n
    Ahora podemos aplicar el <\/span>OnUpdate()<\/i><\/b> JavaScript con la configuraci\u00f3n de eventos. Couchbase activar\u00e1 esta funci\u00f3n para cualquier mutaci\u00f3n de documento en el archivo <\/span>hotel<\/span><\/i> colecci\u00f3n.\u00a0<\/span><\/p>\n
    En este sencillo ejemplo, enviamos todas las mutaciones de documentos a Solace utilizando el soporte cURL en el Servicio de Eventos. En un caso de uso real, normalmente aplicar\u00edamos un filtrado basado en algunos atributos del documento e implementar\u00edamos la funci\u00f3n <\/span>OnDelete<\/i><\/b> para gestionar la eliminaci\u00f3n de documentos.<\/span><\/p>\n
    function OnUpdate(doc, meta) {\r\n\/\/ We keep the eventing function as simple as possible with minimal error handling.\r\n\/\/ For every document mutation the document is passed on to Solace using an HTTP POST.\r\ntry {\r\n\/\/ build the request to the Solace REST endpoint.\r\nvar request = {\r\nbody: doc\r\n};\r\n\/\/ perform the cURL request using the URL alias 'curlSolaceRestUrl' from the settings\r\n\/\/ The URL alias 'curlSolaceRestUrl' from the settings contains the host including the path to the Topic in Solace\r\nvar response = curl('POST', curlSolaceRestUrl, request);\r\nif (response.status != 200) {\r\nlog(\"docId\", meta.id, \"cURL POST failed response.status:\",response.status);\r\n} else {\r\nlog(\"cURL POST success, sent\", meta.id);\r\n}\r\n} catch (e) {\r\nlog(\"ERROR cURL request had an exception:\",e)\r\n}\r\n}<\/pre>\n
    Probar la aplicaci\u00f3n de ejemplo<\/h4>\n
    Ahora es el momento de probar la aplicaci\u00f3n de ejemplo:<\/span><\/p>\n
      \n
    1. Inicie el <\/span>evt_sendto_solace <\/i><\/b>oyente de eventos<\/span><\/li>\n
    2. Vaya a <\/span>Documentos<\/span><\/i> en la consola de Couchbase<\/span><\/li>\n
    3. Seleccione <\/span>viajes-muestra.inventario.hotel<\/span><\/i> como se muestra aqu\u00ed:<\/span><\/li>\n
    4. \"\"<\/li>\n
    5. Abrir un <\/span>hotel<\/span><\/i> editar cualquier campo del documento y guardar los cambios. Este cambio en el documento desencadenar\u00e1 un evento de actualizaci\u00f3n que nuestro receptor de eventos recoger\u00e1.<\/span><\/li>\n
    6. El receptor de eventos enviar\u00e1 ahora el documento actualizado a Solace.<\/span><\/li>\n
    7. Ahora podemos verificar que nuestro consumidor REST Solace ha recibido el documento actualizado. Observe que Solace envi\u00f3 el documento al consumidor REST utilizando el m\u00e9todo <\/span>\/callback<\/i><\/b> especificado durante la vinculaci\u00f3n de la cola.<\/span><\/li>\n<\/ol>\n
      \"\"<\/p>\n
      Las mutaciones del documento a los documentos del hotel en el <\/span>hotel<\/span><\/i> colecci\u00f3n se publican ahora en Solace y luego se env\u00edan a los suscriptores de Solace.<\/span><\/p>\n
      Couchbase services rely on the internal Database Change Protocol (DCP) which supports the\u00a0 eventually consistent view of your data.\u00a0 DCP does not guarantee that you see all changes but it does guarantee you see the most recent.\u00a0 For example if a document in `travel-sample`.inventory.hotel mutates quite fast some of the intermediate mutations can be deduplicated as such the Eventing Service will not see all the changes.<\/span><\/p>\n
      Gracias por acompa\u00f1arme en esta demostraci\u00f3n.<\/span><\/p>\n
      Conclusi\u00f3n<\/b><\/p>\n
      Este art\u00edculo nos ense\u00f1\u00f3 a integrar Couchbase con el broker de eventos Solace usando el servicio Couchbase Eventing.<\/span><\/p>\n
      Vemos c\u00f3mo Couchbase puede integrarse perfectamente en tu arquitectura basada en eventos. Ahora puedes aprovechar al m\u00e1ximo los aspectos de calidad de servicio de la plataforma Solace con mensajer\u00eda garantizada y persistente.<\/span><\/p>\n
      La l\u00f3gica de la funci\u00f3n Eventing en nuestro ejemplo se limita a una petici\u00f3n POST cURL b\u00e1sica sin un manejo de errores adecuado. Usted querr\u00e1 implementar <\/span>l\u00f3gica de error y reintento<\/span><\/a> para una soluci\u00f3n lista para la producci\u00f3n.<\/span><\/p>\n