update

task/meigou_data.py

@@ -4,18 +4,6 @@
 # @email : litao@igengmei.com
 # @author : litao
 
-# -*- coding:UTF-8 -*-
-# @Time  : 2020/9/14 14:53
-# @File  : meigou_huidu_huisu.py
-# @email : litao@igengmei.com
-# @author : litao
-
-# -*- coding:UTF-8 -*-
-# @Time  : 2020/9/4 17:07
-# @File  : search_meigou_ctr.py
-# @email : litao@igengmei.com
-# @author : litao
-
 import hashlib
 import json
 
@@ -87,7 +75,7 @@ spark.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJso
 spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDFArryMerge'")
 
 task_list = []
-task_days = 50
+task_days = 5
 for t in range(1, task_days):
     day_num = 0 - t
     now = (datetime.datetime.now() + datetime.timedelta(days=day_num))

task/search_tractate_ctr.py

@@ -73,7 +73,7 @@ spark.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJso
 spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDFArryMerge'")
 
 task_list = []
-task_days = 60
+task_days = 3
 for t in range(1, task_days):
     day_num = 0 - t
     now = (datetime.datetime.now() + datetime.timedelta(days=day_num))