mingsheng.li/tool-databridge
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复batch size是字符串的问题
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
mingsheng.li 2025-08-01 12:09:08 +08:00
parent 76cbaa8200
commit 134e31a5bb
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipelines/dbf_to_postgres_ctllog.py
View File

@ -32,7 +32,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline):
self.db = None self.db = None
self.group_cache = {} self.group_cache = {}
self.batch_size = os.getenv('BATCH_SIZE', 1000) self.batch_size = int(os.getenv('BATCH_SIZE', 1000))
self.batch_data = [] self.batch_data = []
self.processed_records = 0 self.processed_records = 0
self.current_date = None # 当前处理的日期 self.current_date = None # 当前处理的日期