adai/MemoryBear
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[MODIFY] sync file path

Browse Source
This commit is contained in:
lixiangcheng1
2026-02-10 12:12:07 +08:00
parent ba73ade2a0
commit e3074b833f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
api/app/tasks.py
View File

@@ -439,7 +439,7 @@ def sync_knowledge_for_kb(kb_id: uuid.UUID):
db.commit() db.commit()
db.refresh(db_file) db.refresh(db_file)
# Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension} # Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension}
save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.parent_id)) save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.id))
Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists
save_path = os.path.join(save_dir, f"{db_file.id}{db_file.file_ext}") save_path = os.path.join(save_dir, f"{db_file.id}{db_file.file_ext}")
# update file # update file
@@ -571,7 +571,7 @@ def sync_knowledge_for_kb(kb_id: uuid.UUID):
else: # --update else: # --update
# 1. update file # 1. update file
# Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension} # Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension}
save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.parent_id)) save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.id))
Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists
# download document from Feishu FileInfo # download document from Feishu FileInfo
@@ -613,7 +613,7 @@ def sync_knowledge_for_kb(kb_id: uuid.UUID):
else: # --add else: # --add
# 1. update file # 1. update file
# Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension} # Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension}
save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.parent_id)) save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), str(db_knowledge.id))
Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists
# download document from Feishu FileInfo # download document from Feishu FileInfo
@@ -727,7 +727,7 @@ def sync_knowledge_for_kb(kb_id: uuid.UUID):
# 1. update file # 1. update file
# Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension} # Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension}
save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id),
str(db_knowledge.parent_id)) str(db_knowledge.id))
Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists
# download document from Feishu FileInfo # download document from Feishu FileInfo
async def async_download_document(api_client: FeishuAPIClient, doc: FileInfo, save_dir: str): async def async_download_document(api_client: FeishuAPIClient, doc: FileInfo, save_dir: str):
@@ -768,7 +768,7 @@ def sync_knowledge_for_kb(kb_id: uuid.UUID):
# 1. update file # 1. update file
# Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension} # Construct a save path：/files/{kb_id}/{parent_id}/{file.id}{file_extension}
save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id), save_dir = os.path.join(settings.FILE_PATH, str(db_knowledge.id),
str(db_knowledge.parent_id)) str(db_knowledge.id))
Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists Path(save_dir).mkdir(parents=True, exist_ok=True) # Ensure that the directory exists
# download document from Feishu FileInfo # download document from Feishu FileInfo
async def async_download_document(api_client: FeishuAPIClient, doc: FileInfo, save_dir: str): async def async_download_document(api_client: FeishuAPIClient, doc: FileInfo, save_dir: str):