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
@@ -134,7 +134,7 @@ for answer_json in answer_res_scan:
     _id = answer_json["_id"]
     content_keyword_list = answer_json["_source"]["content_keyword"]
     for content_keyword in content_keyword_list:
-        if content_keyword in tractate_dict:
+        if content_keyword in answer_dict:
             answer_dict[content_keyword] += 1
         else:
             answer_dict[content_keyword] = 1