4 Repos
Transformations of event logs into materialized read views for efficient querying.
Distinguishing note: None of the candidates cover the transformation of event streams into alternative datastores for CQRS read models.
Explore 4 awesome GitHub repositories matching data & databases · Read Model Projections. Refine with filters or upvote what's useful.
Akka.NET is an actor model framework used for building concurrent and distributed applications. It functions as a distributed computing platform and state manager that enables isolated actors to communicate via asynchronous message passing, ensuring thread-safe state management without manual locks. The project is distinguished by its decentralized coordination capabilities, including a distributed state manager that uses sharding and dynamic rebalancing to maintain high availability. It incorporates an event sourcing engine that persists state as a sequence of events in an append-only log an
Transforms persisted events into alternative datastores using reactive streams to create materialized read views.
Dieses Projekt ist eine Referenzimplementierung von Domain-Driven-Design-Mustern und ein Beispiel für Command Query Responsibility Segregation (CQRS). Es bietet eine Sammlung ereignisgesteuerter Microservices, die die praktische Anwendung architektonischer Prinzipien zur Strukturierung komplexer Softwaresysteme demonstrieren. Die Implementierung trennt Lese- und Schreibmodelle durch ein Event-Journal und organisiert Services in Bounded Contexts, um klare funktionale Grenzen zu wahren. Sie koordiniert Geschäftslogik durch das Versenden und Konsumieren von Domain-Events, um verschiedene Module zu synchronisieren. Das Projekt deckt eine Reihe architektonischer Fähigkeiten ab, einschließlich Event-Sourced State Persistence, materialisierter Leseprojektionen und Domain-Driven-Layering. Es enthält zudem eine REST-API-Implementierung, um die Kern-Geschäftslogik für externe Systeme bereitzustellen.
Pre-calculates read-only data views by subscribing to and processing domain event streams.
Dieses Projekt ist ein Framework zur Implementierung von Event Sourcing und Command Query Responsibility Segregation (CQRS) innerhalb containerisierter Microservices. Es bietet einen strukturierten Ansatz zur Verwaltung des Geschäftsstatus als Sequenz unveränderlicher Ereignisse, was einen zuverlässigen Audit-Trail und die Möglichkeit zur Wiederherstellung des Systemzustands zu jedem beliebigen Zeitpunkt gewährleistet. Das Framework zeichnet sich durch die Durchsetzung einer klaren Trennung zwischen Datenänderungs- und Datenabrufpfaden aus. Durch die Nutzung ereignisgesteuerter Datensynchronisation ermöglicht es die asynchrone Aktualisierung von materialisierten Views und Read-Modellen, wodurch sichergestellt wird, dass abfrageoptimierte Daten aktuell bleiben, ohne die Leistung primärer Schreiboperationen zu beeinträchtigen. Die Architektur unterstützt die Bereitstellung von Komponenten entweder als unabhängige Microservices oder als einheitlicher Monolith, mit integrierter Unterstützung für Container-Orchestrierung, um die Konsistenz über Entwicklungs- und Produktionsumgebungen hinweg zu wahren. Es erleichtert die Verwaltung verteilter Daten durch denormalisierte Views und bietet effizienten Zugriff auf aggregierte Informationen über Servicegrenzen hinweg.
Refreshes read models asynchronously to keep queryable data current without blocking writes.
Rails Event Store ist eine Bibliothek für die Implementierung von Event-Sourcing- und Command-Query-Responsibility-Segregation-Mustern (CQRS) innerhalb von Ruby-Anwendungen. Sie fungiert als Framework zur Erfassung aller Anwendungszustandsänderungen als unveränderliche Sequenz von Ereignissen und bietet eine dauerhafte und verifizierbare Historie von Systemoperationen. Die Bibliothek bietet eine Messaging-Infrastruktur, die Geschäftslogik durch das Senden von Domänenereignissen über einen zentralen Bus entkoppelt. Diese Architektur ermöglicht die Ausführung von Handlern entweder sofort oder asynchron, was sicherstellt, dass rechenintensive Aufgaben den primären Anwendungsfluss nicht blockieren. Über die Kern-Event-Verwaltung hinaus unterstützt das Projekt die Transformation von Roh-Event-Streams in optimierte Read-Modelle. Diese Projektionen ermöglichen effiziente Abfragen und Berichterstattung durch die Trennung der Datenabfrage von den zugrunde liegenden Schreiboperationen. Das System führt zudem chronologische Audit-Logs, um Sicherheits- und Compliance-Anforderungen zu erfüllen, und nutzt schema-agnostische Serialisierung, um eine konsistente Datenspeicherung über Zeit hinweg sicherzustellen.
Builds optimized read models from event streams to enable fast data retrieval for user interfaces.