hj

calc_result/RiskComputer.py

@@ -100,6 +100,7 @@ class RiskComputer:
                 sql='INSERT INTO result_set(Batchno,indexName,status,biztype) VALUES (%s,"%s","%s","%s")'%(insert_batch_No,insert_key,insert_status,ss[i])
                 try:
                     cursor.execute(sql)
+                    print("数据入库成功")
                 # 提交到数据库执行
                     db.commit()
                 except Exception as e:

calc_result/main.py

@@ -216,6 +216,7 @@ def report(BatchNo):
 redisPool = redis.ConnectionPool(host=FK_REDIS_HOST, port=int(FK_REDIS_PORT), password=FK_REDIS_PWD,db=FK_REDIS_DB)
 client = redis.Redis(connection_pool=redisPool)
 a =client.rpop('notifyRule')
+print("获取任务号")
 if a is None:
     print("notifyRule数据为空")
     quit()