update

tasks/from_sparksql_to_mysql.py

@@ -95,7 +95,7 @@ for res in sql_res:
     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")).hexdigest()
-    instert_sql = """INSERT INTO conent_detail_page_grayscale_ctr(
+    instert_sql = """replace 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,slide_wel_click_pv,self_wel_click_pv,partition_day,pid
     ) VALUES('{day_id}','{device_os_type}','{active_type}','{grey_type}','{page_name}',{content_pv},{content_uv},