From 893781ec7fbd60ab0f734049cda0db7fb4c8d9d0 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Tue, 30 Jul 2024 10:01:42 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20db=5Finsert=5Fmplogx=E4=B8=8D=E7=94=A8t?= =?UTF-8?q?hread?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/enm/tasks.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/enm/tasks.py b/apps/enm/tasks.py index c0e63b56..316657c2 100644 --- a/apps/enm/tasks.py +++ b/apps/enm/tasks.py @@ -58,11 +58,11 @@ def db_insert_mplogx(): if count > 400: raise Exception("db inset count > 400") cursor.execute( - "select id, val, tag_code, update_time from tag_value where id > %s order by id, update_time", (last_tag_id)) + "select id, val, tag_code, update_time from tag_value where id > %s order by id, update_time", (last_tag_id, )) rows = cursor.fetchall() # 获取数据后保存至本地 if rows: last_tag_id = rows[-1][0] - MyThread(target=db_insert_mplogx_batch, args=(rows,)).start() + db_insert_mplogx_batch(rows) update_sysconfig({'enm': {'last_tag_id': last_tag_id}})