Update app.py

app.py

@@ -9,6 +9,7 @@ import http.server
 import socketserver
 import threading
 import socket
+import boto3
 import s3fs
 import os 
 
@@ -20,12 +21,14 @@ output_dir.mkdir(exist_ok=True)
 AWS_S3_BUCKET = os.getenv("AWS_S3_BUCKET")
 AWS_ACCESS_KEY_ID = os.getenv("AWS_ACCESS_KEY_ID")
 AWS_SECRET_ACCESS_KEY = os.getenv("AWS_SECRET_ACCESS_KEY")
-print("AWS CONFIG:")
-print(AWS_S3_BUCKET)
-print(AWS_ACCESS_KEY_ID)
+session = boto3.Session(
+    aws_access_key_id=AWS_ACCESS_KEY_ID,
+    aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
+    region_name='us-east-1'
+)
 
-storage_options = {"key": AWS_ACCESS_KEY_ID, "secret": AWS_SECRET_ACCESS_KEY}
-fs = s3fs.S3FileSystem(**storage_options)
+s3 = session.client('s3')
+fs = s3fs.S3FileSystem(anon=False, client_kwargs={'region_name': 'us-east-1'})
 
 logging.basicConfig(level=logging.INFO)
 
@@ -116,8 +119,13 @@ def convert_video(video_file, quality, aspect_ratio, video_url):
     output_links = []
     for path in output_paths:
         output_links.append(f'<a href="http://{server_ip}:8000{path}" target="_blank">Download {Path(path).stem}</a>')
+        print("Read local file")
+        with open(path, 'rb') as file:
+            file_content = file.read()
         print("Upload " + Path(path).stem + " to AWS")
-        fs.mv(str(output_dir / f"{output_path.stem}_%03d.ts"), f"s3://{AWS_S3_BUCKET}/{Path(path).stem}",)
+        # fs.mv(str(output_dir / f"{output_path.stem}_%03d.ts"), f"s3://{AWS_S3_BUCKET}/{Path(path).stem}",)
+        with fs.open(f"s3://{AWS_S3_BUCKET}/{Path(path).stem}", 'wb') as file:
+            file.write(your_file_content)
 
     output_html = "<br>".join(output_links)
     return output_html