\uc88b\uc2b5\ub2c8\ub2e4. \uc774\uc81c \ubb38\uc11c \u2192 \uc2e4\uc81c \ub3d9\uc791\ud558\ub294 \uc2dc\uc2a4\ud15c\uc73c\ub85c \ub118\uc5b4\uac11\ub2c8\ub2e4.<\/p>\n
\uc544\ub798\ub294 \ubcf5\ubd99\ud574\uc11c \ubc14\ub85c \uc2e4\ud589 \uac00\ub2a5\ud55c AOP \ucd5c\uc18c \ub808\ud37c\ub7f0\uc2a4 (FastAPI + Event Store + Replay)\uc785\ub2c8\ub2e4.<\/p>\n<\/p>\n
\ud83d\ude80 AOP Minimal Reference Implementation<\/p>\n
\ubaa9\ud45c<\/p>\n<\/p>\n
event \uae30\ub85d<\/p>\n<\/p>\n
projection \uc0dd\uc131<\/p>\n<\/p>\n
\uc2e4\ud328 \ubc1c\uc0dd<\/p>\n<\/p>\n
replay\ub85c \ubcf5\uad6c<\/p>\n<\/p>\n
1. \uc544\ud0a4\ud14d\ucc98 (\ucd5c\uc18c \uad6c\uc131)<\/p>\n
FastAPI (API)<\/p>\n
\u2193<\/p>\n
Command Handler<\/p>\n
\u2193<\/p>\n
Event Store (SQLite)<\/p>\n
\u2193<\/p>\n
Projection (in-memory)<\/p>\n
\u2193<\/p>\n
Replay Engine<\/p>\n
2. \ud504\ub85c\uc81d\ud2b8 \uad6c\uc870<\/p>\n
Bash<\/p>\n
aop_minimal\/<\/p>\n
\u251c\u2500\u2500 main.py<\/p>\n
\u251c\u2500\u2500 event_store.py<\/p>\n
\u251c\u2500\u2500 projection.py<\/p>\n
\u251c\u2500\u2500 handlers.py<\/p>\n
\u251c\u2500\u2500 replay.py<\/p>\n
\u2514\u2500\u2500 models.py<\/p>\n
3. \ucf54\ub4dc<\/p>\n
3.1 models.py<\/p>\n
Python<\/p>\n
\uc2e4\ud589\ub428<\/p>\n
from pydantic import BaseModel<\/p>\n
from typing import Optional<\/p>\n
import uuid<\/p>\n<\/p>\n
class Command(BaseModel):<\/p>\n
type: str<\/p>\n
payload: dict<\/p>\n
trace_id: str = str(uuid.uuid4())<\/p>\n<\/p>\n
class Event(BaseModel):<\/p>\n
id: str<\/p>\n
type: str<\/p>\n
payload: dict<\/p>\n
trace_id: str<\/p>\n
seq: int<\/p>\n
3.2 event_store.py<\/p>\n
Python<\/p>\n
\uc2e4\ud589\ub428<\/p>\n
import sqlite3<\/p>\n
from models import Event<\/p>\n<\/p>\n
conn = sqlite3.connect(“events.db”, check_same_thread=False)<\/p>\n
cursor = conn.cursor()<\/p>\n<\/p>\n
cursor.execute(“””<\/p>\n
CREATE TABLE IF NOT EXISTS events (<\/p>\n
id TEXT,<\/p>\n
type TEXT,<\/p>\n
payload TEXT,<\/p>\n
trace_id TEXT,<\/p>\n
seq INTEGER<\/p>\n
)<\/p>\n
“””)<\/p>\n
conn.commit()<\/p>\n<\/p>\n
def append_event(event: Event):<\/p>\n
cursor.execute(<\/p>\n
“INSERT INTO events VALUES (?, ?, ?, ?, ?)”,<\/p>\n
(event.id, event.type, str(event.payload), event.trace_id, event.seq)<\/p>\n
)<\/p>\n
conn.commit()<\/p>\n<\/p>\n
def get_events(trace_id: str):<\/p>\n
cursor.execute(<\/p>\n
“SELECT id, type, payload, trace_id, seq FROM events WHERE trace_id=? ORDER BY seq”,<\/p>\n
(trace_id,)<\/p>\n
)<\/p>\n
rows = cursor.fetchall()<\/p>\n
return rows<\/p>\n
3.3 projection.py<\/p>\n
Python<\/p>\n
\uc2e4\ud589\ub428<\/p>\n
projections = {}<\/p>\n<\/p>\n
def apply_event(event):<\/p>\n
trace_id = event.trace_id<\/p>\n<\/p>\n
if trace_id not in projections:<\/p>\n
projections[trace_id] = {“status”: “INIT”}<\/p>\n<\/p>\n
if event.type == “OrderCreated”:<\/p>\n
projections[trace_id][“status”] = “CREATED”<\/p>\n<\/p>\n
elif event.type == “PaymentRequested”:<\/p>\n
projections[trace_id][“status”] = “PAYMENT_PENDING”<\/p>\n<\/p>\n
elif event.type == “PaymentCompleted”:<\/p>\n
\n
\n