update

tasks/from_sparksql_to_mysql.py

@@ -94,7 +94,7 @@ for res in sql_res:
     slide_wel_click_pv = res.slide_wel_click_pv
     self_wel_click_pv = res.self_wel_click_pv
     partition_day = res.PARTITION_DAY
-    pid = hashlib.md5((day_id + device_os_type + active_type + grey_type + page_name).encode("utf8"))
+    pid = hashlib.md5((day_id + device_os_type + active_type + grey_type + page_name).encode("utf8")).hexdigest()
     sql = """INSERT INTO conent_detail_page_grayscale_ctr(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