-
Notifications
You must be signed in to change notification settings - Fork 0
/
object_storage.py
38 lines (29 loc) · 1.14 KB
/
object_storage.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
import asyncio
import aiobotocore
AWS_ACCESS_KEY_ID = "MEIO96JMJ5I8TLSI0830"
AWS_SECRET_ACCESS_KEY = "Fxp7KuOKyjSReEBWrlhB7dim7ITKvKEATlqA0DOG"
async def go():
bucket = 'agora-vr-storage'
filename = 'dummy.bin'
folder = 'aiobotocore'
key = '{}/{}'.format(folder, filename)
session = aiobotocore.get_session()
async with session.create_client(
's3', region_name='us-east-1',
endpoint_url="https://us-east-1.linodeobjects.com/",
aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
aws_access_key_id=AWS_ACCESS_KEY_ID) as client:
# upload object to amazon s3
data = b'\x01' * 1024
resp = await client.put_object(Bucket=bucket,
Key=key,
Body=data)
print(resp)
# getting s3 object properties of file we just uploaded
resp = await client.get_object_acl(Bucket=bucket, Key=key)
print(resp)
# # delete object from s3
resp = await client.delete_object(Bucket=bucket, Key=key)
print(resp)
loop = asyncio.get_event_loop()
loop.run_until_complete(go())