update

new_user_analysis/new_user_project_protratit.py

@@ -105,7 +105,7 @@ es_query_tractate = {"query": {
     }
 }
 }
-tractate_res_scan = scan(client=es, query=es_query_tractate, index="gm-dbmw-tractate-read", doc_type="tractate")
+tractate_res_scan = scan(client=es, query=json.dumps(es_query_tractate), index="gm-dbmw-tractate-read", doc_type="tractate", scroll='3m')
 tractate_dict = {}
 for tractate_json in tractate_res_scan:
     # print(tractate_json)
@@ -128,7 +128,7 @@ es_query_answer = {"query": {
     }
 }
 }
-answer_res_scan = scan(client=es, query=es_query_tractate, index="gm-dbmw-answer-read", doc_type="answer")
+answer_res_scan = scan(client=es, query=json.dumps(es_query_answer), index="gm-dbmw-answer-read", doc_type="answer", scroll='3m')
 answer_dict = {}
 for answer_json in answer_res_scan:
     _id = answer_json["_id"]