update

task/spark_test.py

@@ -187,7 +187,7 @@ WHERE spam_pv.device_id IS NULL
         # print(count, res)
         portratit_res = get_user_portrait_tag3_from_redis(res.device_id)
         sql = """select cl_id, projects from kafka_tag3_log
-  where cl_id = '%s' and event_cn = 'kyc' """
+  where cl_id = '%s' and event_cn = 'kyc' """ % res.device_id
         # print(count_user_count, res, portratit_res)
         sql_res_list = con_sql(sql)
         kyc_str_list= []
@@ -239,8 +239,7 @@ WHERE spam_pv.device_id IS NULL
         db.commit()
         print(res)
 
-    cursor.executemany()
-    db.close()
+