update

task/daily_search_word_count.py

@@ -63,9 +63,9 @@ if __name__ == "__main__":
             partition_date = date_str
             pid = hashlib.md5((partition_date+word).encode("utf8")).hexdigest()
             insert_sql = """replace into daily_search_word_count(
-               word, nums, uv,date_str,pid) VALUES(
-              '{word}',{nums},{uv},'{date_str}','{pid}');""".format(
-                word=word, nums=nums, uv=uv,date_str=date_str,pid=pid
+               word, nums, uv,pid,partition_day) VALUES(
+              '{word}',{nums},{uv},'{pid}','{partition_day}');""".format(
+                word=word, nums=nums, uv=uv,partition_day=date_str,pid=pid
             )
             print(insert_sql)
             # cursor.execute("set names 'UTF8'")