update

tasks/from_sparksql_to_mysql.py

@@ -78,7 +78,7 @@ device_df.show(1, False)
 sql_res = device_df.collect()
 print("-----------------------------------------------------------------------------")
 for res in sql_res:
-    print(res)
+    # print(res)
     day_id = res.day_id
     device_os_type = res.device_os_type
     active_type = res.active_type
@@ -100,12 +100,13 @@ for res in sql_res:
     wel_click_pv,content_click_pv,slide_wel_click_pv,partition_day,pid
     ) VALUES('{day_id}','{device_os_type}',
     '{active_type}','{grey_type}','{page_name}',{content_pv},{content_uv},{wel_exp_pv},{content_exp_pv},{wel_click_pv},{content_click_pv},
-    {wel_click_pv},{content_click_pv},{slide_wel_click_pv},'{partition_day}','{pid})'""".format(
+    {wel_click_pv},{content_click_pv},{slide_wel_click_pv},'{partition_day}','{pid}')""".format(
         day_id=day_id,device_os_type=device_os_type,active_type=active_type,grey_type=grey_type,page_name=page_name,
         content_pv=content_pv,content_uv=content_uv,wel_exp_pv=wel_exp_pv,content_exp_pv=content_exp_pv,wel_click_pv=wel_click_pv,
         content_click_pv=content_click_pv,slide_wel_click_pv=slide_wel_click_pv,self_wel_click_pv=self_wel_click_pv,
         partition_day=partition_day, pid=pid
     )
+    print(sql)
     cursor.execute(sql)
 # cursor.executemany()
 db.close()
\ No newline at end of file