From 970e365c8d39336ce9c4233e771892a3e2d78731 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 18:34:23 +0800
Subject: [PATCH] 'commit'

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

diff --git a/ClickHouse/services/__pycache__/sync_service.cpython-310.pyc b/ClickHouse/services/__pycache__/sync_service.cpython-310.pyc
index 50af2a5c992994acaeac4c6db1013c4a36790a3b..c12158be86aaec0b33ebbdad07443975d7fb2171 100644
GIT binary patch
delta 278
zcmbQEFkOK+pO=@50SHu9>`ZUo$oq_mQGD_jrb&z<o7<VY7#Sre3$cbVzL}iKs>n5)
zA%&@ic{ambmdO)X^BH|7u~jloo?OKyFFHG%AuqayFNIx_p_adfzlJB9rD*Bob!?i9
zrzc0TOHKa7Cdv3^G7r18aD56_tzeyCIb%6PVM7h~1jZsZpbA%A*>Xlk1`vz{;&6r<
z7NCqz6?+ZK0_lZdkrb|A1{Q`AnF)-Q-jmO;+lrS~u_0v3VR9vt6*#hmd4V2!zo+NL
z*6mN1cYC^6DOA}{Zr~K%yoW=XnNJxgS-c2H@Gx^Ri*0_({fmjQYVr%db&MR7r}MW0
E0MzqMZvX%Q

delta 278
zcmbQPFh_wmpO=@50SI0$-<jUIk@p!BquAsxOp_ReH@7o)F)~U_7Ge!!d@(tbRgq1c
zA%#htVe%B#d`9odENqpG6DQZP$&1bmXUL1L;Y(qcWT@q@;jiJzW+_@cc@vu^<H^Z!
z>{64zu}Lz1nk>L>EnJ(zRV!F0Sk73^P*_*PJ%O=^1*pPRSGt^$kpToFfjFF@h6O0&
zRmEPzvOszvSR{ojn1O|%L}mhGrRU@e?6%^?Rcr{^a+qAvWEGBVDKVgL-tXyov32{?
z<=vhxRtnWQiNz)HnJKlK7jRfH^C<!4ix&Y29%e3Pq0KM2e=#vuPJYa{j*)%xB>q+a
Ds=iJ3

diff --git a/ClickHouse/services/sync_service.py b/ClickHouse/services/sync_service.py
index 14678107..1abaa9f7 100644
--- a/ClickHouse/services/sync_service.py
+++ b/ClickHouse/services/sync_service.py
@@ -16,6 +16,7 @@ class SyncService:
         self.primary_key = 'id'  # 主键字段名
         self.columns = None
 
+
     def _load_table_columns(self, table):
         """加载表的列信息"""
         result = self.ch_conn.connect().execute(f"DESCRIBE TABLE {table}")
@@ -38,7 +39,7 @@ class SyncService:
 
         # 获取最后同步ID
         last_id = self._get_last_id_from_ch(table)
-        logger.info(f"开始增量同步" + table + "，起始ID: {last_id}")
+        logger.info(f"开始增量同步{table}，起始ID: {last_id}")
 
         # 使用同一个MySQL连接
         mysql_conn = self.mysql_conn.connect()
@@ -140,4 +141,4 @@ class SyncService:
             )
         except Exception as e:
             logger.error(f"批量插入失败: {str(e)}")
-            # 可选：实现重试逻辑
+            # 可选：实现重试逻辑
\ No newline at end of file