From 7fcc377a277a647318d98e377d8944245f67450e Mon Sep 17 00:00:00 2001 From: "mingsheng.li" Date: Mon, 28 Jul 2025 21:58:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AF=BC=E5=85=A5=E7=9A=84?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=A1=A8=E5=90=8D=E7=A7=B0bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/pipelines/dbf_to_postgres_ctllog.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/pipelines/dbf_to_postgres_ctllog.py b/src/pipelines/dbf_to_postgres_ctllog.py index e55a2f8..9c6e326 100644 --- a/src/pipelines/dbf_to_postgres_ctllog.py +++ b/src/pipelines/dbf_to_postgres_ctllog.py @@ -153,7 +153,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline): if len(batch_data) >= batch_size: # todo：本地调试先注释掉 self.db.execute_batch( - "INSERT INTO current_states (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)", + "INSERT INTO controller_log (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)", batch_data ) # todo：本地调试先注释掉 @@ -169,7 +169,7 @@ class DbfToPostgresCtllogPipeline(BasePipeline): if batch_data: # todo：本地调试先注释掉 self.db.execute_batch( - "INSERT INTO current_states (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)", + "INSERT INTO controller_log (created, control_group_controller_id, point_id, real_value) VALUES (%s, %s, %s, %s)", batch_data ) # todo：本地调试先注释掉