流批一体 + 端到端项目Batch & Stream

import json
from collections import defaultdict
from datetime import datetime

buckets = defaultdict(float)
with open("data/events.jsonl", encoding="utf-8") as f:
    for line in f:
        event = json.loads(line)
        t = datetime.fromisoformat(event["event_time"])
        minute = (t.minute // 5) * 5
        window = t.replace(minute=minute, second=0).isoformat()
        buckets[(event["symbol"], window)] += float(event["amount"])
for key, value in sorted(buckets.items()):
    print(*key, round(value, 2))