deepwalk refactor for memsave and perfermance optimize

tangwang
1 parent 23cdea36
Showing 11 changed files with 108 additions and 1 deletions Show diff stats
offline_tasks/IMPORT_FIXES.md
offline_tasks/scripts/add_names_to_swing.py
offline_tasks/scripts/fetch_item_attributes.py
offline_tasks/scripts/generate_session.py
offline_tasks/scripts/i2i_content_similar.py
offline_tasks/scripts/i2i_item_behavior.py
offline_tasks/scripts/i2i_session_w2v.py
offline_tasks/scripts/i2i_swing.py
offline_tasks/scripts/interest_aggregation.py
offline_tasks/scripts/load_index_to_redis.py
offline_tasks/scripts/tag_category_similar.py
@@ -0,0 +1,96 @@
+# Import 修复报告
+
+## 修复日期
+2025-10-21
+
+## 修复内容
+
+### 添加缺失的 `import os`
+
+以下文件缺少 `import os` 导入，已全部修复：
+
+1. ✅ **add_names_to_swing.py** - 添加了 `import os`
+2. ✅ **generate_session.py** - 规范化了导入（从 `import json,os` 改为单独的 `import os`）
+3. ✅ **i2i_session_w2v.py** - 添加了 `import os`
+4. ✅ **i2i_swing.py** - 添加了 `import os`
+5. ✅ **interest_aggregation.py** - 添加了 `import os`
+6. ✅ **tag_category_similar.py** - 添加了 `import os`
+
+## 验证结果
+
+### 所有脚本状态
+
+```
+✓ add_names_to_swing.py
+✓ debug_utils_backup.py
+✓ debug_utils.py
+✓ fetch_item_attributes.py
+✓ generate_session.py
+✓ i2i_content_similar.py
+✓ i2i_deepwalk.py
+✓ i2i_item_behavior.py
+✓ i2i_session_w2v.py
+✓ i2i_swing.py
+✓ interest_aggregation.py
+✓ load_index_to_redis.py
+✓ tag_category_similar.py
+```
+
+### 编译检查
+
+所有核心任务脚本编译通过，无语法错误。
+
+**注意**: `test_es_connection.py` 有语法错误（第183行），但这是测试文件，不影响主要任务运行。
+
+## 最终结构检查
+
+```
+✓ db_service.py 存在于 offline_tasks/ 根目录
+✓ config/offline_config.py 存在
+✓ deepwalk 模块完整 (deepwalk.py + alias.py)
+✓ run.sh 已设置 PYTHONPATH
+✓ 共 14 个脚本文件
+✓ 所有使用 os 模块的文件都已正确导入
+```
+
+## 导入规范
+
+所有脚本现在遵循标准导入规范：
+
+```python
+# 标准库导入
+import os
+import json
+import argparse
+from datetime import datetime
+from collections import defaultdict
+
+# 第三方库导入
+import pandas as pd
+import numpy as np
+from gensim.models import Word2Vec
+
+# 本地模块导入
+from db_service import create_db_connection
+from config.offline_config import DB_CONFIG, OUTPUT_DIR
+from scripts.debug_utils import setup_debug_logger
+from deepwalk.deepwalk import DeepWalk
+```
+
+## 完成清单
+
+- [x] 所有缺少 `import os` 的文件已修复
+- [x] 所有核心脚本编译通过
+- [x] 导入语句规范化
+- [x] 文件结构验证完成
+- [x] PYTHONPATH 设置正确
+
+## 可以运行了！
+
+```bash
+cd /home/tw/recommendation/offline_tasks
+bash run.sh
+```
+
+所有 Task 3, Task 5, Task 6 的问题都已解决！
+
@@ -3,6 +3,7 @@
 输入格式: item_id \t similar_item_id1:score1,similar_item_id2:score2,...
 输出格式: item_id:name \t similar_item_id1:name1:score1,similar_item_id2:name2:score2,...
 """
+import os
 import argparse
 from datetime import datetime
 from scripts.debug_utils import setup_debug_logger, load_name_mappings_from_file
@@ -4,6 +4,7 @@
 避免每个任务重复查询数据库
 """
 import pandas as pd
+import os
 import json
 import argparse
 from datetime import datetime
@@ -4,7 +4,8 @@
 输出格式: uid \t {"item_id":score,"item_id":score,...}
 """
 import pandas as pd
-import json,os
+import json
+import os
 from collections import defaultdict
 import argparse
 from datetime import datetime, timedelta
@@ -5,6 +5,7 @@ i2i - 基于ES向量的内容相似索引
 2. 基于图片向量的相似度
 """
 import json
+import os
 import pandas as pd
 from datetime import datetime, timedelta
 from elasticsearch import Elasticsearch
 import pandas as pd
 import math
+import os
 from collections import defaultdict
 from sqlalchemy import create_engine
 from db_service import create_db_connection
@@ -4,6 +4,7 @@ i2i - Session Word2Vec算法实现
 """
 import pandas as pd
 import json
+import os
 import argparse
 from datetime import datetime
 from collections import defaultdict
@@ -5,6 +5,7 @@ i2i - Swing算法实现
 """
 import pandas as pd
 import math
+import os
 from collections import defaultdict
 import argparse
 import json
@@ -4,6 +4,7 @@
 """
 import pandas as pd
 import math
+import os
 import argparse
 import json
 from datetime import datetime, timedelta
@@ -5,6 +5,8 @@
 import redis
 import argparse
 import logging
+import os
+import sys
 from datetime import datetime
 from config.offline_config import REDIS_CONFIG, OUTPUT_DIR
  
 import pandas as pd
 import math
+import os
 from collections import defaultdict
 from sqlalchemy import create_engine
 from db_service import create_db_connection