'commit'

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)}")
-            # 可选：实现重试逻辑
+            # 可选：实现重试逻辑