| 82 | - meta.json：本次运行参数（方便复现） |
| 83 | """ |
| 84 | def __init__(self, log_dir: str, meeting_id: str, flush_every: int = 1): |
| 85 | self.meeting_id = str(meeting_id) |
| 86 | self.base = os.path.join(log_dir, f"meeting_{self.meeting_id}") |
| 87 | os.makedirs(self.base, exist_ok=True) |
| 88 | |
| 89 | self.fp_events = open(os.path.join(self.base, "events.jsonl"), "a", encoding="utf-8") |
| 90 | self.flush_every = max(1, int(flush_every)) |
| 91 | self._cnt = 0 |
| 92 | |
| 93 | meta_path = os.path.join(self.base, "meta.json") |
| 94 | if not os.path.exists(meta_path): |
| 95 | with open(meta_path, "w", encoding="utf-8") as f: |
| 96 | meta = { |
| 97 | "created_at": _iso(time.time()), |
| 98 | "meeting_id": self.meeting_id, |
| 99 | "args": vars(args), |
| 100 | } |
| 101 | f.write(json.dumps(meta, ensure_ascii=False, indent=2)) |
| 102 | |
| 103 | def write_event(self, obj: dict): |
| 104 | self.fp_events.write(json.dumps(obj, ensure_ascii=False) + "\n") |