update

new_user_analysis/new_user_project_protratit.py

@@ -14,10 +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 import Elasticsearch
-# from elasticsearch.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
@@ -108,7 +108,7 @@ es_query_tractate = {"query": {
 tractate_res_scan = scan(client=es, query=es_query_tractate, index="gm-dbmw-tractate-read", doc_type="tractate")
 tractate_dict = {}
 for tractate_json in tractate_res_scan:
-    print(tractate_json)
+    # print(tractate_json)
     _id = tractate_json["_id"]
     content_keyword_list = tractate_json["_source"]["content_keyword"]
     for content_keyword in content_keyword_list: