데이터 수집 → 분석 → 리포트 파이프라인

[E] Extract (추출) - 데이터 소스에서 데이터 가져오기 ├── API 호출 (Google Analytics, Stripe, SNS) ├── 웹 스크래핑 (경쟁사 가격, 뉴스) ├── DB 쿼리 (자체 서비스 데이터) └── 파일 읽기 (CSV, Excel) [T] Transform (변환) - 데이터 정제 및 가공 ├── 중복 제거, 결측값 처리 ├── 형식 통일 (날짜, 통화 등) ├── 지표 계산 (전환율, 성장률) └── AI 분석 (트렌드, 이상 탐지) [L] Load (적재) - 결과 저장 및 전달 ├── DB 저장 (분석 결과) ├── 대시보드 업데이트 ├── PDF 리포트 생성 └── Slack/이메일로 전송

// lib/data-collectors.ts // 1. Stripe 매출 데이터 수집 async function collectStripeData(startDate: Date, endDate: Date) { const charges = await stripe.charges.list({ created: { gte: Math.floor(startDate.getTime() / 1000), lte: Math.floor(endDate.getTime() / 1000), }, limit: 100, }); return { totalRevenue: charges.data.reduce((sum, c) => sum + c.amount, 0), transactionCount: charges.data.length, avgOrderValue: charges.data.length > 0 ? charges.data.reduce((sum, c) => sum + c.amount, 0) / charges.data.length : 0, }; } // 2. Google Analytics 트래픽 데이터 수집 async function collectGAData(startDate: string, endDate: string) { const response = await analytics.properties.runReport({ property: `properties/${GA_PROPERTY_ID}`, requestBody: { dateRanges: [{ startDate, endDate }], metrics: [ { name: 'activeUsers' }, { name: 'sessions' }, { name: 'bounceRate' }, { name: 'averageSessionDuration' }, ], }, }); return parseGAResponse(response.data); } // 3. 자체 DB 데이터 수집 async function collectAppData(startDate: Date, endDate: Date) { const newUsers = await db.user.count({ where: { createdAt: { gte: startDate, lte: endDate } }, }); const activeUsers = await db.user.count({ where: { lastActiveAt: { gte: startDate } }, }); return { newUsers, activeUsers }; }