update

task/search_strategy_d.py

@@ -8,19 +8,20 @@ import hashlib
 import json
 
 import pymysql
-import xlwt, datetime
-import redis
+# import xlwt
+import datetime
+# 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
-from pyspark.sql.functions import lit
-import pytispark.pytispark as pti
+# from pyspark.sql.functions import lit
+# import pytispark.pytispark as pti
 
 db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user', passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
                      db='jerry_prod')