This commit is contained in:
Misha4ca228 2025-04-30 21:53:01 +03:00
parent 2a3be5ff79
commit 7c906a3ff0

View File

@ -577,15 +577,31 @@ class Api:
filename = str(uid_int)[0:18] filename = str(uid_int)[0:18]
folder = "ddcn_results" folder = "ddcn_results"
s3_client.put_object( retry = 0
Bucket=get_env_var(key="S3_BUCKET"),
Key=f"{folder}/{filename}.jpg", while retry <= 5:
Body=image_bytes,
ContentType="image/jpeg" try:
) s3_client.put_object(
s3_url = f"{get_env_var('S3_ENDPOINT')}/{get_env_var('S3_BUCKET')}/{folder}/{filename}.jpg" Bucket=get_env_var(key="S3_BUCKET"),
Key=f"{folder}/{filename}.jpg",
Body=image_bytes,
ContentType="image/jpeg"
)
s3_url = f"{get_env_var('S3_ENDPOINT')}/{get_env_var('S3_BUCKET')}/{folder}/{filename}.jpg"
return models.ImageToImageResponse(parameters=vars(img2imgreq), info=processed.js(), s3_url=s3_url)
except Exception as e:
print(f"Error save on s3: {e}")
retry =+ 1
continue
else:
raise HTTPException(status_code=500, detail="Error save on s3:")
return models.ImageToImageResponse(parameters=vars(img2imgreq), info=processed.js(), s3_url=s3_url)
def extras_single_image_api(self, req: models.ExtrasSingleImageRequest): def extras_single_image_api(self, req: models.ExtrasSingleImageRequest):
reqDict = setUpscalers(req) reqDict = setUpscalers(req)