update

task/daily_search_word_count.py

@@ -194,7 +194,7 @@ for t in range(0, task_days):
         nums = name.all_search_pv
         uv = name.all_search_uv
         partition_date = str(now + datetime.timedelta(days=-1))
-        tag_names_list_week.append((word, nums, uv, partition_date))
+        tag_names_list_week.append((word, nums, uv,partition_date))
 
     db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
                          db='jerry_prod')
@@ -202,15 +202,14 @@ for t in range(0, task_days):
     insert_sql = "replace into daily_search_word_count(word, nums, uv,pid,partition_day) VALUES(%s,%s,%s,%s,%s)"
     insert_list = []
     for count, item in enumerate(tag_names_list_week):
-        word, nums, uv, date_str = item
-        partition_date = date_str
+        word, nums, uv,partition_date = item
         try:
             pid = hashlib.md5((partition_date + word).encode("utf8")).hexdigest()
-            insert_sql_tuple = (word, nums, uv, pid, date_str)
+            insert_sql_tuple = (word, nums, uv, pid, partition_date)
             insert_list.append(insert_sql_tuple)
+            print(insert_sql_tuple)
         except:
             continue
-        print(insert_sql)
         if count % 100 == 0:
             cursor.execute("set names 'UTF8'")
             res = cursor.executemany(insert_sql, insert_list)