update

task/core_indicators_monitoring.py

@@ -540,10 +540,11 @@ FROM
 
     device_df.show(1, False)
     sql_res = device_df.collect()
-    db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
-                         db='jerry_prod')
-    cursor = db.cursor()
+
     for res in sql_res:
+        db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
+                             db='jerry_prod', )
+        cursor = db.cursor()
         print(res)
         partition_date = res.partition_date
         device_os_type = res.device_os_type
@@ -596,5 +597,6 @@ FROM
         res = cursor.execute(instert_sql)
         db.commit()
         print(res)
-db.close()
+        cursor.close()
+        db.close()