update

task/recommend_strategy_fix.py

@@ -4,24 +4,18 @@
 # @email : litao@igengmei.com
 # @author : litao
 
-# -*- coding:UTF-8 -*-
-# @Time  : 2020/8/20 9:42
-# @File  : recommend_strategy_d.py
-# @email : litao@igengmei.com
-# @author : litao
-
 import hashlib
 import json
 
 import pymysql
 import xlwt, datetime
-import redis
+# import redis
 # from pyhive import hive
-from maintenance.func_send_email_with_file import send_file_email
-from typing import Dict, List
-from elasticsearch_7 import Elasticsearch
-from elasticsearch_7.helpers import scan
-import sys
+# from maintenance.func_send_email_with_file import send_file_email
+# from typing import Dict, List
+# from elasticsearch_7 import Elasticsearch
+# from elasticsearch_7.helpers import scan
+# import sys
 import time
 from pyspark import SparkConf
 from pyspark.sql import SparkSession, DataFrame
@@ -79,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'")
 
 
-for t in range(0, 3):
+for t in range(0, 60):
     day_num = 0 - t
     now = (datetime.datetime.now() + datetime.timedelta(days=day_num))
     last_30_day_str = (now + datetime.timedelta(days=-30)).strftime("%Y%m%d")