Update data.py

data.py

@@ -1,13 +1,10 @@
 from __future__ import annotations
 import os
 import json
-from typing import Optional, Dict, Any
 from datetime import datetime
 import pandas as pd
 
-# ✅ 書き込み可能な場所をデフォルトにする
-#   - 既定: /tmp/adcopy_data（ephemeral）
-#   - 環境変数 DATA_DIR を設定すると、例: /data/adcopy_mab（HF Spaces の Persistent Storage）
+# 書き込み可能な場所をデフォルトにする
 DEFAULT_WRITABLE_DIR = "/tmp/adcopy_data"
 DATA_DIR = os.environ.get("DATA_DIR", DEFAULT_WRITABLE_DIR)
 
@@ -15,20 +12,11 @@ LOG_PATH = os.path.join(DATA_DIR, "events.csv")
 META_PATH = os.path.join(DATA_DIR, "meta.json")
 
 SCHEMA = [
-    "ts",            # ISO timestamp
-    "date",          # YYYY-MM-DD (便宜)
-    "medium",        # 媒体名 (例: FB, GDN)
-    "creative",      # クリエイティブID/名前 (例: A1)
-    "is_control",    # 0/1（コントロール群）
-    "impressions",   # 表示数
-    "clicks",        # クリック数（または目的コンバージョン）
-    "conversions",   # 追加のCV（任意: 0 でもOK）
-    "cost",          # コスト（任意）
-    "features_json"  # クリエイティブ特徴量（dict をJSON文字列で）
+    "ts", "date", "medium", "creative", "is_control",
+    "impressions", "clicks", "conversions", "cost", "features_json"
 ]
 
 def _ensure_storage():
-    """初回起動時に保存先と空ファイルを準備。"""
     os.makedirs(DATA_DIR, exist_ok=True)
     if not os.path.exists(LOG_PATH):
         pd.DataFrame(columns=SCHEMA).to_csv(LOG_PATH, index=False)
@@ -36,7 +24,7 @@ def _ensure_storage():
         with open(META_PATH, "w", encoding="utf-8") as f:
             json.dump({"created_at": datetime.utcnow().isoformat()}, f)
 
-# インポート時に準備（書き込み可能ディレクトリなのでOK）
+# インポート時に準備
 _ensure_storage()
 
 def read_events() -> pd.DataFrame:
@@ -44,7 +32,6 @@ def read_events() -> pd.DataFrame:
     df = pd.read_csv(LOG_PATH)
     if df.empty:
         return df
-    # 型整備
     df["date"] = pd.to_datetime(df["date"]).dt.date.astype(str)
     df["is_control"] = df["is_control"].fillna(0).astype(int)
     for col in ["impressions", "clicks", "conversions"]:
@@ -55,7 +42,6 @@ def read_events() -> pd.DataFrame:
 
 def append_events(rows: pd.DataFrame) -> None:
     _ensure_storage()
-    # 必須列チェック & 補完
     for c in SCHEMA:
         if c not in rows.columns:
             if c == "features_json":