update

task/search_meigou_ctr.py

@@ -213,8 +213,8 @@ and (dev.device_id is null or dev.device_id='')
 
     for active_type in res_dict:
         for device_os_type in res_dict[active_type]:
-            day_id = yesterday_str
-            pid = hashlib.md5((day_id + device_os_type + active_type).encode("utf8")).hexdigest()
+            partition_date = yesterday_str
+            pid = hashlib.md5((partition_date + device_os_type + active_type).encode("utf8")).hexdigest()
             click_num = res_dict[active_type][device_os_type]["click_num"]
             exposure = res_dict[active_type][device_os_type]["exposure"]
             try:
@@ -222,8 +222,8 @@ and (dev.device_id is null or dev.device_id='')
             except:
                 search_ctr = 0
             instert_sql = """replace into search_meigou_ctr(
-            day_id,device_os_type,active_type,pid,click_num,exposure,search_ctr) VALUES('{day_id}','{device_os_type}','{active_type}','{pid}',{click_num},{exposure},{search_ctr});""".format(
-                day_id=day_id, device_os_type=device_os_type, active_type=active_type, pid=pid, click_num=click_num,
+            partition_date,device_os_type,active_type,pid,click_num,exposure,search_ctr) VALUES('{day_id}','{device_os_type}','{active_type}','{pid}',{click_num},{exposure},{search_ctr});""".format(
+                partition_date=partition_date, device_os_type=device_os_type, active_type=active_type, pid=pid, click_num=click_num,
                 exposure=exposure, search_ctr=search_ctr
             )
             print(instert_sql)