diff --git a/polymarket.db b/polymarket.db deleted file mode 100644 index 27ee3b8ff..000000000 Binary files a/polymarket.db and /dev/null differ diff --git a/polymarket/btc抓取.py b/polymarket/数据抓取/btc抓取.py similarity index 99% rename from polymarket/btc抓取.py rename to polymarket/数据抓取/btc抓取.py index ec7bb48e6..7e2de531f 100644 --- a/polymarket/btc抓取.py +++ b/polymarket/数据抓取/btc抓取.py @@ -231,7 +231,7 @@ def save_snapshot(bucket_ts: int, fetched_at: int, raw: Dict[str, Any], db_path: if __name__ == "__main__": - init_db("../polymarket.db") + init_db("../../polymarket.db") while True: data = fetch_current_market( @@ -242,5 +242,5 @@ if __name__ == "__main__": probe_offsets=(0, -900, 900), # 先试当前,再试前一档/后一档 ) - save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../polymarket.db") + save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../../polymarket.db") print("saved:", data["bucket_ts"], data["fetched_at"]) diff --git a/polymarket/eth抓取.py b/polymarket/数据抓取/eth抓取.py similarity index 99% rename from polymarket/eth抓取.py rename to polymarket/数据抓取/eth抓取.py index 60e970703..fb8f38a2a 100644 --- a/polymarket/eth抓取.py +++ b/polymarket/数据抓取/eth抓取.py @@ -231,7 +231,7 @@ def save_snapshot(bucket_ts: int, fetched_at: int, raw: Dict[str, Any], db_path: if __name__ == "__main__": - init_db("../polymarket.db") + init_db("../../polymarket.db") while True: data = fetch_current_market( @@ -242,5 +242,5 @@ if __name__ == "__main__": probe_offsets=(0, -900, 900), # 先试当前,再试前一档/后一档 ) - save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../polymarket.db") + save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../../polymarket.db") print("saved:", data["bucket_ts"], data["fetched_at"]) diff --git a/polymarket/数据抓取/polymarket.db b/polymarket/数据抓取/polymarket.db new file mode 100644 index 000000000..a50bf3092 Binary files /dev/null and b/polymarket/数据抓取/polymarket.db differ diff --git a/polymarket/sol抓取.py b/polymarket/数据抓取/sol抓取.py similarity index 99% rename from polymarket/sol抓取.py rename to polymarket/数据抓取/sol抓取.py index 8c8240dd0..a3150d635 100644 --- a/polymarket/sol抓取.py +++ b/polymarket/数据抓取/sol抓取.py @@ -231,7 +231,7 @@ def save_snapshot(bucket_ts: int, fetched_at: int, raw: Dict[str, Any], db_path: if __name__ == "__main__": - init_db("../polymarket.db") + init_db("../../polymarket.db") while True: data = fetch_current_market( @@ -242,5 +242,5 @@ if __name__ == "__main__": probe_offsets=(0, -900, 900), # 先试当前,再试前一档/后一档 ) - save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../polymarket.db") + save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../../polymarket.db") print("saved:", data["bucket_ts"], data["fetched_at"]) diff --git a/polymarket/xrp抓取.py b/polymarket/数据抓取/xrp抓取.py similarity index 99% rename from polymarket/xrp抓取.py rename to polymarket/数据抓取/xrp抓取.py index 0350a392c..9e0d01358 100644 --- a/polymarket/xrp抓取.py +++ b/polymarket/数据抓取/xrp抓取.py @@ -231,7 +231,7 @@ def save_snapshot(bucket_ts: int, fetched_at: int, raw: Dict[str, Any], db_path: if __name__ == "__main__": - init_db("../polymarket.db") + init_db("../../polymarket.db") while True: data = fetch_current_market( @@ -242,5 +242,5 @@ if __name__ == "__main__": probe_offsets=(0, -900, 900), # 先试当前,再试前一档/后一档 ) - save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../polymarket.db") + save_snapshot(data["bucket_ts"], data["fetched_at"], data, "../../polymarket.db") print("saved:", data["bucket_ts"], data["fetched_at"]) diff --git a/polymarket/批量抓取.py b/polymarket/数据抓取/批量抓取.py similarity index 99% rename from polymarket/批量抓取.py rename to polymarket/数据抓取/批量抓取.py index 0e1bfb228..f5a8d2aef 100644 --- a/polymarket/批量抓取.py +++ b/polymarket/数据抓取/批量抓取.py @@ -340,7 +340,7 @@ def fetch_crypto_worker(crypto_config: Dict[str, str], db_path: str, stop_event: def main(): """主函数:启动多个线程并行抓取所有币种数据""" - db_path = "../polymarket.db" + db_path = "./polymarket.db" init_db(db_path) stop_event = threading.Event()