'commit'

ClickHouse/config/db_config.py

@@ -0,0 +1,19 @@
+# 数据库配置
+MYSQL_CONFIG = {
+    'host': '10.10.14.101',
+    'port': 3306,
+    'user': 'ylt',
+    'password': 'Ycharge666',
+    'db': 'yltcharge',
+    'charset': 'utf8mb4'
+}
+
+CH_CONFIG = {
+    'host': '10.10.14.250',
+    'port': 9000,
+    'settings': {
+        'max_insert_block_size': 100000,
+        'async_insert': 1,
+        'wait_for_async_insert': 0
+    }
+}

ClickHouse/main.py

@@ -5,32 +5,13 @@ from services.sync_service import SyncService
 from utils.logger import configure_logger
 
 logger = configure_logger()
+from config.db_config import MYSQL_CONFIG, CH_CONFIG
 
 
 def main():
-    # 数据库配置
-    mysql_config = {
-        'host': '10.10.14.101',
-        'port': 3306,
-        'user': 'ylt',
-        'password': 'Ycharge666',
-        'db': 'yltcharge',
-        'charset': 'utf8mb4'
-    }
-
-    ch_config = {
-        'host': '10.10.14.250',
-        'port': 9000,
-        'settings': {
-            'max_insert_block_size': 100000,
-            'async_insert': 1,
-            'wait_for_async_insert': 0
-        }
-    }
-
     # 初始化组件
-    mysql_conn = MySQLConnector(mysql_config)
-    ch_conn = ClickHouseConnector(ch_config)
+    mysql_conn = MySQLConnector(MYSQL_CONFIG)
+    ch_conn = ClickHouseConnector(CH_CONFIG)
 
     mapper = DataMapper(
         date_columns=[
@@ -67,9 +48,8 @@ def main():
     except Exception as e:
         logger.error(f"同步失败: {str(e)}", exc_info=True)
     finally:
-        pass
-        #ch_conn.disconnect()
+        ch_conn.disconnect()
 
 
 if __name__ == "__main__":
-    main()
+    main()