From 89fe45c81337455d56d1a8e3657af8249a56da8b Mon Sep 17 00:00:00 2001 From: Nixevol Date: Mon, 25 May 2026 15:05:34 +0800 Subject: [PATCH] =?UTF-8?q?style:=20=E7=A7=BB=E9=99=A4=E6=80=A7=E8=83=BD?= =?UTF-8?q?=E4=BC=98=E5=8C=96=E7=89=88=E6=8F=8F=E8=BF=B0=EF=BC=8C=E7=AE=80?= =?UTF-8?q?=E5=8C=96=E6=A8=A1=E5=9D=97=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/database.py | 4 ++-- app/processor.py | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/app/database.py b/app/database.py index a647196..eafacd3 100644 --- a/app/database.py +++ b/app/database.py @@ -1,5 +1,5 @@ """ -数据库连接与操作模块 - 性能优化版 +数据库连接与操作模块 """ import pymysql from contextlib import contextmanager @@ -9,7 +9,7 @@ from app.config import AppConfig class DatabaseManager: - """数据库管理器 - 高性能版""" + """数据库管理器""" def __init__(self, config: AppConfig): self.config = config diff --git a/app/processor.py b/app/processor.py index 33a37ef..95802a0 100644 --- a/app/processor.py +++ b/app/processor.py @@ -1,5 +1,5 @@ """ -数据处理核心模块 - 性能优化版 +数据处理核心模块 """ import chardet import os @@ -78,7 +78,7 @@ class ProcessLogger: class DataProcessor: - """数据处理器 - 高性能版""" + """数据处理器""" # 批量插入大小(根据实际测试,5000 是比较好的平衡点) BATCH_SIZE = 5000 @@ -414,7 +414,7 @@ class DataProcessor: def _process_csv_file_fast(self, csv_file: Path, table_name: str, conn=None, table_created: bool = False) -> Tuple[int, bool]: """ - 高性能处理单个 CSV 文件 + 处理单个 CSV 文件 使用 LOAD DATA LOCAL INFILE,比 executemany 快 10-50 倍 Args: @@ -776,7 +776,7 @@ class DataProcessor: return data_dirs def _process_csv_files(self): - """处理所有 CSV 文件(高性能版 - 使用 LOAD DATA INFILE + 连接复用)""" + """处理所有 CSV 文件(使用 LOAD DATA INFILE + 连接复用)""" self.logger.info("正在处理 CSV 文件并上传到数据库...") # 查找数据目录