from keystoneauth1 import session
from keystoneauth1.identity import v3
from swiftclient import client
username = 'admin'
tenant_name = 'admin'
password = 'password'
auth_url='http://192.x.x.x/identity/v3'
auth = v3.Password(auth_url=auth_url,
username=username,
password=password,
project_name=tenant_name,
user_domain_id='default',
project_domain_id='default')
sess = session.Session(auth=auth)
swift_conn = client.Connection(session=sess)
I tried to write exception handling, but ... about a memo
try:
resp_headers, containers = swift_conn.get_account()
except session.exceptions.Unauthorized:
print "The request you have made requires authentication."
except client.ClientException:
print "Account GET failed"
print(containers)
Method information displayed in bpython.
swift_conn.get_account: (self, marker=None, limit=None, prefix=None,
end_marker=None, full_listing=False, headers=None)
get_account
Wrapper for :func:`get_account`
container = 'new-container'
swift_conn.put_container(container)
Method information displayed in bpython.
container
is required.
swift_conn.put_container: (self, container, headers=None,
response_dict=None, query_string=None)
put_container
Wrapper for :func:`put_container`
container = 'new-container'
with open('local.txt', 'r') as local:
swift_conn.put_object(
container=container,
obj='local_object.txt',
contents=local,
content_type='text/plain'
)
Method information displayed in bpython.
container, obj, contents
are required.
swift_conn.put_object: (self, container, obj, contents,
content_length=None, etag=None, chunk_size=None, content_type=None,
headers=None, query_string=None, response_dict=None)
put_object
Wrapper for :func:`put_object`
obj = 'local_object.txt
container = 'new-container'
resp_headers, obj_contents = swift_conn.get_object(container, obj)
with open('local_copy.txt','w') as local:
local.write(obj_contents)
Method information displayed in bpython.
container, obj
is required.
swift_conn.get_object: (self, container, obj, resp_chunk_size=None,
query_string=None, response_dict=None, headers=None)
get_object
Wrapper for :func:`get_object`
obj = 'local_object.txt'
container = 'new-container'
try:
swift_conn.delete_object(container, obj)
print("Successfully deleted the object")
except ClientException as e:
print("Failed to delete the object with error: %s" % e)
Method information displayed in bpython.
container, obj
is required.
swift_conn.delete_object: (self, container, obj, query_string=None,
response_dict=None, headers=None)
delete_object
Wrapper for :func:`delete_object`
Specify the normal path with ʻobj, but the path ending with
/` is recognized as a folder.
Is a folder created inside the container? ??
I'm sorry I don't understand Swift so much (´ ・ ω ・ `)
container = 'new-container'
swift_conn.put_object(
container=container,
obj="folder/",
contents=None,
content_type="application/octet-stream"
)
container = 'new-container'
with open('local.txt', 'r') as local:
swift_conn.put_object(
container=container,
obj='folder/local_object.txt',
contents=local,
content_type='text/plain'
)
Recommended Posts