From a9da6c1cb44fb8b6671d74bb13be76ff596c6817 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Sat, 22 Feb 2025 16:58:45 +0800
Subject: [PATCH] 'commit'

---
 ClickHouse/main.py                            |   3 ++-
 .../__pycache__/sync_service.cpython-310.pyc  | Bin 2632 -> 2617 bytes
 ClickHouse/services/sync_service.py           |   4 ----
 3 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/ClickHouse/main.py b/ClickHouse/main.py
index e9b25f4f..c455daf9 100644
--- a/ClickHouse/main.py
+++ b/ClickHouse/main.py
@@ -42,9 +42,10 @@ def main():
     )
 
     try:
+        # 创建ClickHouse表
         service.create_ch_table()
+        # 同步数据
         service.sync_data()
-        pass
     except Exception as e:
         logger.error(f"同步失败: {str(e)}", exc_info=True)
     finally:
diff --git a/ClickHouse/services/__pycache__/sync_service.cpython-310.pyc b/ClickHouse/services/__pycache__/sync_service.cpython-310.pyc
index 6c6ffab2092f55482750102c2229fc2caececbce..3f2dc5944e8c02104da6ad956fa2d599789bf715 100644
GIT binary patch
delta 294
zcmZutyGlbr5S_Vq-*GiyAlN8ah&GlMf&}cWQ(1{{A&@}C7!Y9=3mXeXWP8~yEyXGy
zAlM4_{((PW<J_$?!yL{qXCBOFZ_)D?-aBA>d0vdR-u#a^+(ZC^1ex&+3C2~bGlZ%z
z!K|h#$qY~HL6AtQ!HfvZbljI4w|m!|wSLM$bx{t3BE?G4D(8k|BOBG|$2#Z{1Y?1#
znkQSbS0~eL-ei+wM6$UGj!f#1E4?dZ?vQXIXJfw6lPSA(TAi0l#$AMV<mEA$+0AkZ
mpQY1U{FQyYk4k-DH-4!<b--V6^8H&sAP(ZWeZ`&FaYz5{{YmWr

delta 348
zcmZ{gJxc^J5Qb+q->d5fo`qm#p_PT5jbL@1jaP^u*aQw#R@^(VnQ+CmrxyDMlG0MF
zuJ^!y;SW*7$=cYMz~l`x@5__Sd+)vKwyH|tb@MnMUc6Kva<Yp61Q8NoJ~45<EC{Yd
zlnKJGQmh0OQ73rX2$Ezp9uu-dMw`GFTM*P4cp*W;R3Oy$07m=wJdyW#&K8|}5Hx9a
z%j_OInkcWl_U1tZGlXCraGN88BR4v!cNnCMOI!<bsR$+6xJ+eduE<W2@LDxBgRhY7
zfJ|H+cb$C8iFbXnP55tOn@n8GZ~sg0#Q>Op)_$vnUT-$}!`e6fX%AUgQHs}vnIRsx
Mr|uc|+AnwX1ASFfRsaA1

diff --git a/ClickHouse/services/sync_service.py b/ClickHouse/services/sync_service.py
index 13618e8d..c0b06b38 100644
--- a/ClickHouse/services/sync_service.py
+++ b/ClickHouse/services/sync_service.py
@@ -23,10 +23,6 @@ class SyncService:
         return [row[0] for row in result]
 
     def sync_data(self, batch_size=5000):
-        """同步数据到ClickHouse"""
-        # 创建ClickHouse表
-        self.create_ch_table()
-
         # 加载表的列信息
         self.columns = self._load_table_columns()