|
@@ -49,12 +49,11 @@ class R2RFileService(OSSFileService):
|
|
|
while content := await file.read(1024):
|
|
while content := await file.read(1024):
|
|
|
await f.write(content)
|
|
await f.write(content)
|
|
|
|
|
|
|
|
- storage.save_from_path(filename=file_key, local_file_path=tmp_file_path)
|
|
|
|
|
|
|
+ # storage.save_from_path(filename=file_key, local_file_path=tmp_file_path)
|
|
|
await r2r.init()
|
|
await r2r.init()
|
|
|
await r2r.ingest_file(
|
|
await r2r.ingest_file(
|
|
|
file_path=tmp_file_path, metadata={"file_key": file_key}
|
|
file_path=tmp_file_path, metadata={"file_key": file_key}
|
|
|
)
|
|
)
|
|
|
-
|
|
|
|
|
# 存储
|
|
# 存储
|
|
|
db_file = File(
|
|
db_file = File(
|
|
|
purpose=purpose, filename=file.filename, bytes=file.size, key=file_key
|
|
purpose=purpose, filename=file.filename, bytes=file.size, key=file_key
|
