gardel/Mofox-Core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 使用inspect安全访问detached对象，避免触发lazy loading

Browse Source
This commit is contained in:
Windpicker-owo
2025-11-01 17:16:04 +08:00
parent bcf1dcf7c6
commit cf9ce20bd5
1 changed files with 40 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/person_info/relationship_fetcher.py
View File

@@ -196,18 +196,31 @@ class RelationshipFetcher:
if relationship:
# 将SQLAlchemy对象转换为字典以保持兼容性
# 使用 try-except 防止 detached 对象访问错误
# 使用 inspect 安全访问 detached 对象，避免触发 lazy loading
from sqlalchemy import inspect as sa_inspect
rel_data = {}
try:
# 使用 inspect 获取对象状态，避免触发 ORM 机制
state = sa_inspect(relationship)
rel_data = {
"user_aliases": getattr(relationship, "user_aliases", None),
"relationship_text": getattr(relationship, "relationship_text", None),
"preference_keywords": getattr(relationship, "preference_keywords", None),
"relationship_score": getattr(relationship, "relationship_score", None),
"user_aliases": state.attrs.user_aliases.value if hasattr(state.attrs, "user_aliases") else None,
"relationship_text": state.attrs.relationship_text.value if hasattr(state.attrs, "relationship_text") else None,
"preference_keywords": state.attrs.preference_keywords.value if hasattr(state.attrs, "preference_keywords") else None,
"relationship_score": state.attrs.relationship_score.value if hasattr(state.attrs, "relationship_score") else None,
}
except Exception as attr_error:
logger.warning(f"访问relationship对象属性失败: {attr_error}")
rel_data = {}
# 如果 inspect 也失败，尝试使用 __dict__ 直接访问
try:
rel_data = {
"user_aliases": relationship.__dict__.get("user_aliases"),
"relationship_text": relationship.__dict__.get("relationship_text"),
"preference_keywords": relationship.__dict__.get("preference_keywords"),
"relationship_score": relationship.__dict__.get("relationship_score"),
}
except Exception:
rel_data = {}
# 5.1 用户别名
if rel_data.get("user_aliases"):
@@ -271,12 +284,27 @@ class RelationshipFetcher:
return ""
# 将SQLAlchemy对象转换为字典以保持兼容性
stream_data = {
"group_name": stream.group_name,
"stream_impression_text": stream.stream_impression_text,
"stream_chat_style": stream.stream_chat_style,
"stream_topic_keywords": stream.stream_topic_keywords,
}
# 使用 inspect 安全访问 detached 对象，避免触发 lazy loading
from sqlalchemy import inspect as sa_inspect
try:
state = sa_inspect(stream)
stream_data = {
"group_name": state.attrs.group_name.value if hasattr(state.attrs, "group_name") else None,
"stream_impression_text": state.attrs.stream_impression_text.value if hasattr(state.attrs, "stream_impression_text") else None,
"stream_chat_style": state.attrs.stream_chat_style.value if hasattr(state.attrs, "stream_chat_style") else None,
"stream_topic_keywords": state.attrs.stream_topic_keywords.value if hasattr(state.attrs, "stream_topic_keywords") else None,
}
except Exception as e:
logger.warning(f"访问stream对象属性失败: {e}")
# 回退到 __dict__ 访问
stream_data = {
"group_name": stream.__dict__.get("group_name"),
"stream_impression_text": stream.__dict__.get("stream_impression_text"),
"stream_chat_style": stream.__dict__.get("stream_chat_style"),
"stream_topic_keywords": stream.__dict__.get("stream_topic_keywords"),
}
impression_parts = []
# 1. 聊天环境基本信息