event-sourcing-migrator
npx machina-cli add skill a5c-ai/babysitter/event-sourcing-migrator --openclawFiles (1)
SKILL.md
2.2 KB
Event Sourcing Migrator Skill
Migrates applications to event-sourcing architecture, handling event extraction from existing data, event store setup, and CQRS implementation.
Purpose
Enable event sourcing migration for:
- Event extraction from existing data
- Event store setup
- Projection generation
- CQRS implementation
- Snapshot management
Capabilities
1. Event Extraction from Existing Data
- Analyze current state
- Derive historical events
- Generate event streams
- Handle data gaps
2. Event Store Setup
- Configure event store
- Set up partitioning
- Define retention
- Implement subscriptions
3. Projection Generation
- Create read models
- Build projections
- Handle updates
- Manage consistency
4. CQRS Implementation
- Separate read/write
- Implement commands
- Handle queries
- Manage eventual consistency
5. Snapshot Management
- Define snapshot strategy
- Generate snapshots
- Handle restoration
- Optimize performance
6. Event Replay
- Replay events
- Rebuild projections
- Handle migrations
- Test consistency
Tool Integrations
| Tool | Purpose | Integration Method |
|---|---|---|
| EventStore | Event database | CLI/API |
| Axon Framework | Java event sourcing | Library |
| Marten | .NET event store | Library |
| EventStoreDB | Event store | CLI |
| Custom stores | PostgreSQL/Kafka | Library |
Output Schema
{
"migrationId": "string",
"timestamp": "ISO8601",
"eventStore": {
"type": "string",
"streams": "number",
"events": "number"
},
"projections": [
{
"name": "string",
"status": "string",
"lastPosition": "number"
}
],
"snapshots": {
"enabled": "boolean",
"count": "number"
}
}
Integration with Migration Processes
- monolith-to-microservices: Event-driven architecture
- database-schema-migration: Data transformation
Related Skills
domain-model-extractor: Event discovery
Related Agents
data-architect-agent: Event architecture
Source
git clone https://github.com/a5c-ai/babysitter/blob/main/plugins/babysitter/skills/babysit/process/specializations/code-migration-modernization/skills/event-sourcing-migrator/SKILL.mdView on GitHub Overview
Event Sourcing Migrator helps move applications to an event-sourced architecture by extracting events from existing data, setting up an event store, generating projections, and implementing CQRS. It also covers snapshot management and event replay to ensure consistency during migration.
How This Skill Works
The tool analyzes the current state, derives historical events, and generates event streams. It then configures the event store (partitioning, retention, subscriptions), creates read models via projections, and implements CQRS with commands and queries. It also defines a snapshot strategy and supports event replay to rebuild projections and validate consistency.
When to Use It
- Migrating a monolith to an event-driven microservices architecture.
- Starting a new project with event sourcing and CQRS.
- Reconstructing historical events from legacy data and filling data gaps.
- Building read models and projections to support complex queries.
- Planning snapshot strategies and disaster recovery with event replay.
Quick Start
- Step 1: Analyze the current data and extract domain events to form event streams.
- Step 2: Set up the event store, configure partitioning/retention, and establish subscriptions.
- Step 3: Implement projections and CQRS (commands/queries), add snapshots, and run event replay tests.
Best Practices
- Map domain events first and define stable event boundaries to guide migration.
- Design idempotent event handlers and avoid side effects in projections and commands.
- Define a clear snapshot strategy and regularly test replay end-to-end.
- Choose an appropriate event store, and configure partitioning and retention to match load and aging data.
- Validate projections against source data and run replay tests to ensure consistency.
Example Use Cases
- Migrating an e-commerce order system to an event-sourced model with CQRS and projections.
- Repairing a banking ledger by extracting events and rebuilding read models for audits.
- Ingesting IoT telemetry into event streams and generating device-level projections.
- Auditing user activity in a SaaS app with event-sourced history and read models.
- Managing inventory with event streams, projections, and snapshot-driven restores.
Frequently Asked Questions
Add this skill to your agents
