book

Construir microservicios basados en eventos

by Adam Bellemare

September 2024

Intermediate to advanced

324 pages

10h 26m

Spanish

O'Reilly Media, Inc.

Book available

Read now

Unlock full access

Convenciones utilizadas en este libroAprendizaje en línea O'ReillyCómo contactar con nosotrosAgradecimientos
¿Qué son los microservicios dirigidos por eventos?Introducción al Diseño Orientado al Dominio y a los Contextos DelimitadosAprovechar los modelos de dominio y los contextos limitadosAlinear los contextos limitados con los requisitos empresarialesEstructuras de comunicaciónEstructuras de comunicación empresarialAplicación Estructuras de comunicaciónEstructuras de comunicación de datosLey de Conway y estructuras de comunicaciónEstructuras de comunicación en la informática tradicionalOpción 1: Crear un nuevo servicioOpción 2: Añádelo al servicio existentePros y contras de cada opciónEl escenario del equipo, continuaciónPresiones contradictoriasEstructuras de comunicación basadas en sucesosLos acontecimientos son la base de la comunicaciónLos flujos de eventos proporcionan la única fuente de verdadLos consumidores realizan sus propios modelos y consultasSe mejora la comunicación de datos en toda la organizaciónLos datos accesibles apoyan los cambios en la comunicación empresarialMicroservicios asíncronos basados en eventosEjemplo de equipo que utiliza microservicios dirigidos por eventosMicroservicios SíncronosInconvenientes de los microservicios síncronosVentajas de los microservicios síncronosResumen
Topologías de edificiosTopología de microserviciosTopología empresarialEl contenido de un acontecimientoLa estructura de un acontecimientoEvento sin claveEvento de entidadEvento con llaveMaterializar el estado a partir de los eventos de la entidadDefiniciones y esquemas de datos de sucesosMicroservicio Principio de escritor únicoPotenciando Microservicios con el Event BrokerAlmacenamiento y servicio de eventosFactores adicionales a tener en cuentaIntermediarios de eventos frente a intermediarios de mensajesConsumir del registro inmutableProporcionar una única fuente de la verdadGestión de microservicios a escalaPoner microservicios en contenedoresPoner microservicios en máquinas virtualesGestionar contenedores y máquinas virtualesPagar el Impuesto de MicroserviciosResumen
Contratos de datos basados en sucesosUtilizar esquemas explícitos como contratosComentarios sobre la definición del esquemaEvolución completa del esquemaSoporte para el generador de códigoCambios en el esquemaSeleccionar un formato de eventoDiseño de eventosDi la verdad, toda la verdad y nada más que la verdadUtilizar una Definición de Suceso Singular por FlujoUtiliza los tipos de datos más estrechosMantén los eventos con un único objetivoMinimizar el tamaño de los eventosImplica a los posibles consumidores en el diseño del actoEvitar Eventos como Semáforos o SeñalesResumen
¿Qué es la liberación de datos?Compromisos para la liberación de datosConvertir datos liberados en eventosPatrones de Liberación de DatosMarcos de Liberación de DatosLiberar datos mediante consultasCarga a granelCarga incremental de marcas de tiempoCarga de identificadores autoincrementablesConsulta personalizadaActualización incrementalVentajas de la actualización basada en consultasInconvenientes de la actualización basada en consultasLiberación de Datos mediante Registros de Captura de Datos de CambiosVentajas de utilizar registros de almacén de datosInconvenientes del uso de registros de bases de datosLiberar datos mediante tablas de la bandeja de salidaConsideraciones sobre el rendimientoAislar los modelos de datos internosGarantizar la compatibilidad de esquemasCaptura de datos de cambios mediante activadoresHacer cambios en la definición de los conjuntos de datos en capturaGestión de los cambios en la definición de datos a posteriori para los patrones de consulta y registro CDCManejar los cambios en la definición de datos para los patrones de captura de tablas de datos modificadosTransferir datos de sucesos a almacenes de datosLas repercusiones del hundimiento y la deslocalización en una empresaResumen
Composición de topologías sin estadoTransformacionesBifurcar y fusionar flujosRepartición de flujos de eventosEjemplo: Repartición de un flujo de eventosCopartición de flujos de eventosEjemplo: Coparticionar un flujo de eventosAsignar particiones a una instancia de consumidorAsignar Particiones con el Asignador de ParticionesAsignar particiones coparticionadasEstrategias de asignación de particionesRecuperación de fallos de instancias de proceso sin estadoResumen
Determinismo con flujos de trabajo dirigidos por eventosMarcas de tiempoSincronizar marcas de tiempo distribuidasProcesamiento con Eventos con Marca de TiempoProgramación de eventos y procesamiento deterministaProgramadores de eventos personalizadosProcesamiento basado en el tiempo del suceso, el tiempo de procesamiento y el tiempo de ingestiónExtracción de la marca de tiempo por el consumidorLlamadas de solicitud-respuesta a sistemas externosMarcas de aguaMarcas de agua en el procesamiento paraleloTiempo de flujoTiempo de flujo en el procesamiento paraleloEventos fuera de servicio y que llegan tardeEventos tardíos con marcas de agua y tiempo de flujoCausas e impactos de los sucesos fuera de lugarFunciones sensibles al tiempo y ventanasManejo de eventos tardíosReprocesamiento Versus Procesamiento en Tiempo Casi RealFallos intermitentes y eventos tardíosProblemas de conectividad productor/corredor de eventosResumen y lecturas complementarias
Almacenes de Estado y Materialización del Estado a partir de un Flujo de EventosGrabar el estado en un flujo de eventos del registro de cambiosMaterializar el Estado en un Almacén de Estado InternoMaterializar el Estado GlobalVentajas de utilizar el Estado InternoDesventajas de utilizar el Estado InternoEscalado y recuperación del estado internoMaterializar el Estado en un Almacén de Estado ExternoVentajas del Estado ExteriorInconvenientes del Estado ExteriorEscalado y recuperación con almacenes de estado externosReconstruir frente a migrar las tiendas estatalesReconstruyendoMigrando aTransacciones y Efectivamente una vez procesadasEjemplo: Servicio de contabilidad de existenciasProcesar eficazmente una vez con transacciones cliente-agenteEfectivamente Una vez procesado sin transacciones cliente-agenteResumen
El patrón coreográficoUn ejemplo sencillo de coreografía basada en eventosCrear y modificar un flujo de trabajo coreografiadoMonitoreo de un flujo de trabajo coreografiadoEl patrón de orquestaciónUn ejemplo sencillo de orquestación basada en eventosUn ejemplo sencillo de orquestación de llamadas directasComparación de la llamada directa y la orquestación basada en eventosCrear y modificar un flujo de trabajo de orquestaciónMonitoreo del flujo de trabajo de orquestaciónTransacciones distribuidasTransacciones coreografiadas: La Saga PatrónTransacciones orquestadasFlujos de trabajo de compensaciónResumen
Diseñar soluciones basadas en funciones como microserviciosGarantizar la pertenencia estricta a un contexto delimitadoCompromete los desvíos sólo después de finalizar el procesamientoMenos es másElegir un proveedor de FaaSConstruir microservicios a partir de funcionesArranques en frío y en calienteIniciar funciones con disparadoresActivación basada en nuevos eventos: La escucha del flujo de eventosActivación basada en el retraso del grupo de consumidoresActivación en un horarioActivación mediante WebhooksActivación por eventos de recursosRealizar trabajo empresarial con funcionesMantener el EstadoFunciones que llaman a otras funcionesPatrón de comunicación basado en eventosPatrón de llamada directaTerminación y cierreAfinar tus funcionesAsignación de recursos suficientesParámetros de procesamiento de eventos por lotesEscalar tus soluciones FaaSResumen

¿Dónde funcionan bien los BPC?Integración con sistemas existentes y heredadosLógica empresarial con estado que no depende del orden de los eventosCuando la capa de datos hace gran parte del trabajoEscalado independiente de la capa de procesamiento y datosAplicaciones BPC híbridas con procesamiento de flujo externoEjemplo: Utilizar un marco externo de procesamiento de flujos para unir flujos de eventosResumen
Breve historia de los frameworks pesadosEl funcionamiento interno de los Frameworks pesadosVentajas y limitacionesOpciones de configuración del clúster y modos de ejecuciónUtiliza un servicio alojadoConstruye tu propio clúster completoCrear clusters con integración CMSModos de presentación de solicitudesModo ConductorModo ClústerManejo del estado y uso de puntos de controlEscalado de aplicaciones y gestión de particiones de flujos de eventosEscalar una aplicación mientras se ejecutaEscalar una aplicación reiniciándolaAplicaciones de autoescaladoRecuperarse de los fracasosConsideraciones sobre el multiarrendamientoLenguas y sintaxisElegir un marcoEjemplo: Ventana de sesión de clics y vistasResumen
Ventajas y limitacionesProcesado ligeroManejo del estado y uso de los registros de cambiosEscalar aplicaciones y recuperarse de fallosBarajar eventosAsignación estatalReplicación de estados y réplicas en calienteElegir un marco ligeroApache Kafka StreamsApache Samza: Modo EmbebidoLenguas y sintaxisUnión Corriente-Tabla-Tabla: Patrón de enriquecimientoResumen
Manejo de Eventos ExternosEventos generados autónomamenteEventos generados reactivamenteManejo de Eventos Analíticos Generados AutónomamenteIntegración con API de solicitud-respuesta de tercerosProcesar y servir datos de estadoServir peticiones en tiempo real con almacenes de estado internosServir peticiones en tiempo real con almacenes de estado externosGestión de solicitudes dentro de un flujo de trabajo basado en eventosProcesamiento de eventos para interfaces de usuarioMicro-Frontends en Aplicaciones Petición-RespuestaLas ventajas de los microfrentesMicroservicios basados en la composiciónFácil alineación con los requisitos empresarialesInconvenientes de los MicrofrontalesElementos de interfaz de usuario y estilo potencialmente incoherentesVariar el rendimiento del MicrofrontendEjemplo: Solicitud de Búsqueda y Revisión de ExperienciasResumen
Sistema de asignación de microservicios a equiposCreación y modificación de flujos de eventosEtiquetado de metadatos de flujo de eventosCuotasRegistro de EsquemasNotificaciones de creación y modificación de esquemasGestión de compensacionesPermisos y listas de control de acceso para flujos de eventosGestión de estados y reinicio de aplicacionesMonitoreo del retraso en el desplazamiento del consumidorProceso simplificado de creación de microserviciosControles de gestión de contenedoresCreación y gestión de clústeresAumento programático de los intermediarios de eventosAumento programático de los recursos informáticosReplicación de Datos de Sucesos entre ClustersAumento programático del utillajeSeguimiento de la dependencia y visualización de la topologíaEjemplo de topologíaResumen
Principios generales de las pruebasPrueba unitaria de las funciones de topologíaFunciones sin estadoFunciones con estadoProbar la topologíaPruebas de evolución y compatibilidad de esquemasPruebas de integración de microservicios basados en eventosPruebas de integración localCrea un entorno temporal dentro del tiempo de ejecución de tu código de pruebaCrea un entorno temporal externo a tu código de pruebaIntegrar Servicios Alojados Utilizando Opciones de Simulación y SimuladorIntegrar servicios remotos que no tienen opciones localesPruebas de Integración Remota CompletaCrear mediante programación un entorno temporal de pruebas de integraciónPruebas utilizando un entorno compartidoPruebas con el entorno de producciónCómo elegir tu estrategia de pruebas de integración totalmente a distanciaResumen
Principios de Implementación de MicroserviciosComponentes arquitectónicos de la Implementación de MicroserviciosSistemas de Integración, Entrega e Implementación ContinuasSistemas de gestión de contenedores y hardware de productos básicosEl Patrón Básico de Implementación CompletaEl Patrón de Actualización RodanteEl patrón de cambio de esquema de rupturaMigración eventual a través de dos flujos de eventosMigración sincronizada al nuevo flujo de eventosEl patrón de Implementación Azul-VerdeResumen
Capas de comunicaciónDominios empresariales y contextos limitadosHerramientas e infraestructura compartiblesEventos esquematizadosLa liberación de los datos y la fuente única de la verdadMicroserviciosOpciones de implementación de microserviciosPruebaImplementacionesPalabras finales

Content preview from Construir microservicios basados en eventos

Capítulo 11. Marco pesado de microservicios

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: translation-feedback@oreilly.com

Este capítulo y el siguiente cubren los marcos de trabajo completos más utilizados en el procesamiento basado en eventos. Frecuentemente denominados marcos de streaming, proporcionan mecanismos y APIs para manejar flujos de datos y se utilizan a menudo para consumir y producir eventos para un corredor de eventos. Estos marcos pueden dividirse a grandes rasgos en marcos pesados, que se tratan en este capítulo, y marcos ligeros, que se tratan en el siguiente. Estos capítulos no pretenden comparar las tecnologías, sino ofrecer una visión generalizada del funcionamiento de estos marcos. Sin embargo, algunas secciones examinan características específicas de los marcos, especialmente en lo que se refiere a la implementación de aplicaciones en forma de microservicio. Con el fin de evaluar los marcos de peso, este capítulo cubre aspectos de Apache Spark, Apache Flink, Apache Storm, Apache Heron y el modelo Apache Beam como ejemplos de los tipos de tecnología y operaciones que se ofrecen habitualmente.

Una característica definitoria de un marco de streaming pesado es que requiere un clúster independiente de recursos de procesamiento para realizar sus operaciones. Este clúster suele estar constituido por varios nodos trabajadores compartibles, junto con algunos nodos maestros que programan y coordinan el trabajo. Además, las principales ...