import requests
# API endpoint
api_url = "xxxxxx"
reports = "test/"
file_name = "test.csv"
OBJECT_NAME_TO_UPLOAD = "test.csv"
params = {"action": "upload",
"file_key": reports + file_name,
"bucket_name": "xxxx"
}
headers = {"x-api-key": "xxxx"}
session = requests.session()
# Generate pre-signed-url
response = session.get(api_url, headers=headers, json=params)
res = response.json()
print(res)
# # # # # Upload file to S3 using pre-signed URL
with open(OBJECT_NAME_TO_UPLOAD) as f:
upload_response = session.request('PUT', res['url'], data=f.read().encode('utf-8'))
print(f"Upload response: {upload_response.status_code}")
No comments:
Post a Comment