This commit is contained in:
2025-08-19 13:34:33 +08:00
parent adfc3a38f6
commit 121772672c

View File

@@ -88,8 +88,8 @@ def get_student_info_from_es(user_id):
es_conn = search_util.es_pool.get_connection() es_conn = search_util.es_pool.get_connection()
try: try:
# 确保索引存在 # 确保索引存在
if es_conn.indices.exists(index="student_info"): if es_conn.indices.exists(index=Config.ES_CONFIG.get("student_info_index")):
result = es_conn.get(index="student_info", id=doc_id) result = es_conn.get(index=Config.ES_CONFIG.get("student_info_index"), id=doc_id)
if result and '_source' in result: if result and '_source' in result:
logger.info(f"从ES获取到学生 {user_id} 的信息: {result['_source']['info']}") logger.info(f"从ES获取到学生 {user_id} 的信息: {result['_source']['info']}")
return result['_source']['info'] return result['_source']['info']