apunkt/MetaGPT
1
0
Fork 0
mirror of https://github.com/FoundationAgents/MetaGPT.git synced 2026-05-01 11:56:24 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: +skill config

Browse source
This commit is contained in:
莘权 马 2023-09-02 19:25:06 +08:00
parent 2148e4e4f4
commit 610dd8b4ba
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
metagpt/utils/s3.py
View file

@ -131,9 +131,11 @@ class S3:
async def cache(self, data: str, format: str = "") -> str:
"""Save data to remote S3 and return url"""
object_name = str(uuid.uuid4()).replace("-", "")
pathname = WORKSPACE_ROOT / "s3_tmp" / object_name
path = WORKSPACE_ROOT / "s3_tmp"
path.mkdir(exist_ok=True)
pathname = path / object_name
try:
async with aiofiles.open(pathname, mode="w") as file:
async with aiofiles.open(str(pathname), mode="w") as file:
if format == BASE64_FORMAT:
data = base64.b64decode(data)
await file.write(data)
@ -142,7 +144,7 @@ class S3:
object_pathname = CONFIG.S3.get("path") or "system"
object_pathname += f"/{object_name}"
object_pathname = os.path.normpath(object_pathname)
await self.upload_file(bucket=bucket, local_path=pathname, object_name=object_pathname)
await self.upload_file(bucket=bucket, local_path=str(pathname), object_name=object_pathname)
return await self.get_object_url(bucket=bucket, object_name=object_pathname)
except Exception as e:
logger.exception(f"{e}, stack:{traceback.format_exc()}")