- 将查询语句中任务状态条件由“state != 0”更改为“state = 0” - 确保只处理状态为0的任务,避免处理已完成或异常任务 - 优化任务选择逻辑,提高数据处理准确性
@@ -164,7 +164,7 @@ def pcg_main(log):
try:
while True:
- sql_cert_id_list = sql_pool.select_all("select cert_id from pcg_task where state != 0 limit 10000")
+ sql_cert_id_list = sql_pool.select_all("select cert_id from pcg_task where state = 0 limit 10000")
sql_cert_id_list = [i[0] for i in sql_cert_id_list]
log.info(f"开始处理 {len(sql_cert_id_list)} 条数据")
if not sql_cert_id_list: