update

new_user_analysis/new_user_project_protratit.py

@@ -14,8 +14,10 @@ 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
+#from elasticsearch_7 import Elasticsearch
+#from elasticsearch_7.helpers import scan
+from elasticsearch import Elasticsearch
+from elasticsearch.helpers import scan
 import sys
 import time
 from pyspark import SparkConf