레플리케이션

-- MySQL 레플리케이션 상태 확인 (Replica에서)
SHOW REPLICA STATUS\G

-- 복제 지연 확인
SHOW REPLICA STATUS\G
-- Seconds_Behind_Source: 0 이면 동기화 완료

-- PostgreSQL 스트리밍 레플리케이션 설정 (Primary)
-- postgresql.conf
wal_level = replica
max_wal_senders = 3
synchronous_standby_names = 'replica1'

-- Python에서 읽기/쓰기 분리
class DatabaseRouter:
    def __init__(self):
        self.primary = create_engine('mysql://primary/db')
        self.replicas = [
            create_engine('mysql://replica1/db'),
            create_engine('mysql://replica2/db'),
        ]
        self._replica_idx = 0

    def get_write_connection(self):
        return self.primary.connect()

    def get_read_connection(self):
        # 라운드 로빈으로 Replica 선택
        conn = self.replicas[self._replica_idx].connect()
        self._replica_idx = (self._replica_idx + 1) % len(self.replicas)
        return conn

# 사용
router = DatabaseRouter()
with router.get_write_connection() as conn:
    conn.execute("INSERT INTO users (name) VALUES (%s)", ('Alice',))

with router.get_read_connection() as conn:
    result = conn.execute("SELECT * FROM users")