remove operational script from the public space

publish_prices.py

@@ -1,84 +0,0 @@
-# -*- coding: utf-8 -*-
-"""시세 발행기 — 네트워크가 되는 곳에서 돌려 데이터셋에 올린다.
-
-왜 필요한가
-  HF Space에서 Yahoo·Stooq·CoinGecko가 전부 데이터센터 IP를 막는다(실측:
-  429 / 봇차단 / 차단). 바깥 인터넷 자체는 되는데 시세 제공자만 막힌다.
-  그래서 서버가 시세를 '가져오지' 않고 '받게' 한다.
-
-어디서 돌리나
-  본 PC 또는 젠(H100). 둘 다 일반 회선이라 시세 제공자가 막지 않는다.
-  cron / 작업 스케줄러로 하루 몇 번 돌린다.
-
-🔴 발행에 실패하면 **올리지 않는다**. 반쪽 파일을 올리면 그날 전 참가자의
-   수익률이 틀어진다. 이전 파일을 그대로 두는 편이 언제나 낫다.
-
-    python publish_prices.py            # 발행
-    python publish_prices.py --dry      # 받아만 보고 안 올림
-"""
-import os, sys, io
-import pandas as pd
-
-HERE = os.path.dirname(os.path.abspath(__file__))
-sys.path[:0] = [os.path.join(HERE, "app"), HERE]
-import fetch as FE
-
-REPO = os.environ.get("FINCHAL_FEED", "FINAL-Bench/finchal-prices")
-ASSETS = ["NVDA", "BTC", "GOLD", "OIL"]
-MIN_BARS = 400          # 5년치를 기대한다. 이보다 적으면 소스가 반쪽이다
-
-
-def collect():
-    """전 종목을 모아 온다. 하나라도 못 받으면 그 사실을 그대로 돌려준다."""
-    out, bad = {}, []
-    for a in ASSETS:
-        # 피드 자신은 건너뛴다 — 자기가 쓴 걸 다시 읽어 올리면 갱신이 멈춘다
-        ladder = [(n, f) for n, f in FE.LADDER if n != "feed"]
-        keep = FE.LADDER
-        FE.LADDER = ladder
-        try:
-            s, src, trail = FE.daily(a, 2200)
-        finally:
-            FE.LADDER = keep
-        if s is None or len(s) < MIN_BARS:
-            bad.append((a, trail))
-            print("  %-5s 실패  %s" % (a, " · ".join(trail)))
-            continue
-        out[a] = s
-        print("  %-5s %-6s %4d봉  %s  마지막 %.4f"
-              % (a, src, len(s), s.index[-1].date(), float(s.iloc[-1])))
-    return out, bad
-
-
-def publish(data, dry=False):
-    from huggingface_hub import HfApi
-    tok = os.environ.get("HF_TOKEN")
-    if not tok:
-        raise SystemExit("HF_TOKEN 이 필요합니다")
-    api = HfApi(token=tok)
-    api.create_repo(REPO, repo_type="dataset", private=True, exist_ok=True)
-    for a, s in data.items():
-        d = pd.DataFrame({"date": s.index.strftime("%Y-%m-%d"),
-                          "close": s.values})
-        buf = io.BytesIO(d.to_csv(index=False).encode())
-        if dry:
-            print("  (모의) prices/%s.csv %d행" % (a, len(d)))
-            continue
-        api.upload_file(path_or_fileobj=buf, path_in_repo="prices/%s.csv" % a,
-                        repo_id=REPO, repo_type="dataset",
-                        commit_message="prices %s %s" % (a, s.index[-1].date()))
-        print("  올림 prices/%s.csv %d행" % (a, len(d)))
-
-
-if __name__ == "__main__":
-    dry = "--dry" in sys.argv
-    print("시세 수집")
-    data, bad = collect()
-    if not data:
-        raise SystemExit("🔴 한 종목도 못 받았습니다. 올리지 않습니다.")
-    print("\n발행 → %s" % REPO)
-    publish(data, dry)
-    if bad:
-        # 받은 것만 올리고, 못 받은 종목은 이전 파일이 그대로 남는다.
-        print("\n🔴 실패 %d종목 — 이전 파일 유지: %s"
-              % (len(bad), ", ".join(a for a, _ in bad)))