This commit is contained in:
6
main.py
6
main.py
@@ -48,11 +48,12 @@ async def upload_handler(request: Request):
|
|||||||
logger.debug(f"Generated file key: {key}")
|
logger.debug(f"Generated file key: {key}")
|
||||||
|
|
||||||
s3 = await create_s3_client()
|
s3 = await create_s3_client()
|
||||||
object_resource = s3.Object(STORJ_BUCKET_NAME, key)
|
bucket_resource = s3.Bucket(STORJ_BUCKET_NAME)
|
||||||
|
|
||||||
logger.debug("Starting file upload to S3")
|
logger.debug("Starting file upload to S3")
|
||||||
content = await file.read()
|
content = await file.read()
|
||||||
await object_resource.put(
|
await bucket_resource.put_object(
|
||||||
|
Key=key,
|
||||||
Body=content,
|
Body=content,
|
||||||
ContentType=file.content_type,
|
ContentType=file.content_type,
|
||||||
)
|
)
|
||||||
@@ -66,6 +67,7 @@ async def upload_handler(request: Request):
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
async def home(request: Request):
|
async def home(request: Request):
|
||||||
logger.debug("Home route called")
|
logger.debug("Home route called")
|
||||||
return JSONResponse({"message": "Hello World!"})
|
return JSONResponse({"message": "Hello World!"})
|
||||||
|
|||||||
Reference in New Issue
Block a user