Class: Fog::Storage::OpenStack::Real
- Inherits:
-
Object
- Object
- Fog::Storage::OpenStack::Real
- Includes:
- OpenStack::Core, PublicUrl, Utils
- Defined in:
- lib/fog/storage/openstack.rb,
lib/fog/storage/openstack/requests/get_object.rb,
lib/fog/storage/openstack/requests/public_url.rb,
lib/fog/storage/openstack/requests/put_object.rb,
lib/fog/storage/openstack/requests/copy_object.rb,
lib/fog/storage/openstack/requests/head_object.rb,
lib/fog/storage/openstack/requests/post_object.rb,
lib/fog/storage/openstack/requests/delete_object.rb,
lib/fog/storage/openstack/requests/get_container.rb,
lib/fog/storage/openstack/requests/put_container.rb,
lib/fog/storage/openstack/requests/get_containers.rb,
lib/fog/storage/openstack/requests/head_container.rb,
lib/fog/storage/openstack/requests/head_containers.rb,
lib/fog/storage/openstack/requests/delete_container.rb,
lib/fog/storage/openstack/requests/get_object_http_url.rb,
lib/fog/storage/openstack/requests/put_object_manifest.rb,
lib/fog/storage/openstack/requests/get_object_https_url.rb,
lib/fog/storage/openstack/requests/delete_multiple_objects.rb,
lib/fog/storage/openstack/requests/put_static_obj_manifest.rb,
lib/fog/storage/openstack/requests/put_dynamic_obj_manifest.rb,
lib/fog/storage/openstack/requests/delete_static_large_object.rb,
lib/fog/storage/openstack/requests/post_set_meta_temp_url_key.rb
Instance Attribute Summary
Attributes included from OpenStack::Core
#auth_token, #auth_token_expiration, #current_tenant, #current_user, #current_user_id, #openstack_cache_ttl, #openstack_domain_id, #openstack_domain_name, #openstack_identity_prefix, #openstack_project_domain, #openstack_project_domain_id, #openstack_project_id, #openstack_user_domain, #openstack_user_domain_id, #unscoped_token
Class Method Summary collapse
Instance Method Summary collapse
-
#change_account(account) ⇒ Object
Change the current account while re-using the auth token.
-
#copy_object(source_container_name, source_object_name, target_container_name, target_object_name, options = {}) ⇒ Object
Copy object.
-
#create_temp_url(container, object, expires, method, options = {}) ⇒ Object
creates a temporary url.
-
#delete_container(name) ⇒ Object
Delete an existing container.
-
#delete_multiple_objects(container, object_names, options = {}) ⇒ Excon::Response
Deletes multiple objects or containers with a single request.
-
#delete_object(container, object) ⇒ Object
Delete an existing object.
-
#delete_static_large_object(container, object, options = {}) ⇒ Excon::Response
Delete a static large object.
-
#get_container(container, options = {}) ⇒ Object
Get details for container and total bytes stored.
-
#get_containers(options = {}) ⇒ Object
List existing storage containers.
-
#get_object(container, object, &block) ⇒ Object
Get details for object.
-
#get_object_http_url(container, object, expires, options = {}) ⇒ Object
Get an expiring object http url.
-
#get_object_https_url(container, object, expires, options = {}) ⇒ Object
Get an expiring object https url from Cloud Files.
-
#head_container(container) ⇒ Object
List number of objects and total bytes stored.
-
#head_containers ⇒ Object
List number of containers and total bytes stored.
-
#head_object(container, object) ⇒ Object
Get headers for object.
-
#initialize(options = {}) ⇒ Real
constructor
A new instance of Real.
-
#post_object(container, object, headers = {}) ⇒ Object
Update object metadata.
-
#post_set_meta_temp_url_key(key) ⇒ Object
Set the account wide Temp URL Key.
-
#put_container(name, options = {}) ⇒ Object
Create a new container.
-
#put_dynamic_obj_manifest(container, object, options = {}) ⇒ Object
Create a new dynamic large object manifest.
-
#put_object(container, object, data, options = {}, &block) ⇒ Object
Create a new object.
-
#put_object_manifest(container, object, options = {}) ⇒ Object
Create a new dynamic large object manifest.
-
#put_static_obj_manifest(container, object, segments, options = {}) ⇒ Object
Create a new static large object manifest.
- #reset_account_name ⇒ Object
Methods included from PublicUrl
Methods included from OpenStack::Core
#credentials, #initialize_identity, #reload
Methods included from Utils
Constructor Details
#initialize(options = {}) ⇒ Real
Returns a new instance of Real.
115 116 117 118 119 120 121 122 123 124 125 126 127 |
# File 'lib/fog/storage/openstack.rb', line 115 def initialize( = {}) require_mime_types initialize_identity @openstack_service_type = [:openstack_service_type] || ['object-store'] @openstack_service_name = [:openstack_service_name] @connection_options = [:connection_options] || {} authenticate @persistent = [:persistent] || false @connection = Fog::Core::Connection.new("#{@scheme}://#{@host}:#{@port}", @persistent, @connection_options) end |
Class Method Details
Instance Method Details
#change_account(account) ⇒ Object
Change the current account while re-using the auth token.
This is usefull when you have an admin role and you’re able to HEAD other user accounts, set quotas, list files, etc.
For example:
# List current user account details
service = Fog::Storage[:openstack]
service.request :method => 'HEAD'
Would return something like:
Account: AUTH_1234
Date: Tue, 05 Mar 2013 16:50:52 GMT
X-Account-Bytes-Used: 0 (0.00 Bytes)
X-Account-Container-Count: 0
X-Account-Object-Count: 0
Now let’s change the account
service.change_account('AUTH_3333')
service.request :method => 'HEAD'
Would return something like:
Account: AUTH_3333
Date: Tue, 05 Mar 2013 16:51:53 GMT
X-Account-Bytes-Used: 23423433
X-Account-Container-Count: 2
X-Account-Object-Count: 10
If we wan’t to go back to our original admin account:
service.reset_account_name
165 166 167 168 169 |
# File 'lib/fog/storage/openstack.rb', line 165 def change_account(account) @original_path ||= @path version_string = @path.split('/')[1] @path = "/#{version_string}/#{account}" end |
#copy_object(source_container_name, source_object_name, target_container_name, target_object_name, options = {}) ⇒ Object
Copy object
Parameters
-
source_container_name<~String> - Name of source bucket
-
source_object_name<~String> - Name of source object
-
target_container_name<~String> - Name of bucket to create copy in
-
target_object_name<~String> - Name for new copy of object
-
options<~Hash> - Additional headers
13 14 15 16 17 18 19 |
# File 'lib/fog/storage/openstack/requests/copy_object.rb', line 13 def copy_object(source_container_name, source_object_name, target_container_name, target_object_name, = {}) headers = {'X-Copy-From' => "/#{source_container_name}/#{source_object_name}"}.merge() request(:expects => 201, :headers => headers, :method => 'PUT', :path => "#{Fog::OpenStack.escape(target_container_name)}/#{Fog::OpenStack.escape(target_object_name)}") end |
#create_temp_url(container, object, expires, method, options = {}) ⇒ Object
creates a temporary url
Parameters
-
container<~String> - Name of container containing object
-
object<~String> - Name of object to get expiring url for
-
expires<~Time> - An expiry time for this url
-
method<~String> - The method to use for accessing the object (GET, PUT, HEAD)
-
options<~Hash> - An optional options hash
-
‘scheme’<~String> - The scheme to use (http, https)
-
‘host’<~String> - The host to use
-
‘port’<~Integer> - The port to use
-
Returns
-
response<~Excon::Response>:
-
body<~String> - url for object
-
See Also
docs.rackspace.com/files/api/v1/cf-devguide/content/Create_TempURL-d1a444.html
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
# File 'lib/fog/storage/openstack/requests/get_object_https_url.rb', line 37 def create_temp_url(container, object, expires, method, = {}) raise ArgumentError, "Insufficient parameters specified." unless container && object && expires && method raise ArgumentError, "Storage must be instantiated with the :openstack_temp_url_key option" if @openstack_temp_url_key.nil? scheme = [:scheme] || @scheme host = [:host] || @host port = [:port] || @port # POST not allowed allowed_methods = %w(GET PUT HEAD) unless allowed_methods.include?(method) raise ArgumentError, "Invalid method '#{method}' specified. Valid methods are: #{allowed_methods.join(', ')}" end expires = expires.to_i object_path_escaped = "#{@path}/#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object, "/")}" object_path_unescaped = "#{@path}/#{Fog::OpenStack.escape(container)}/#{object}" string_to_sign = "#{method}\n#{expires}\n#{object_path_unescaped}" hmac = Fog::HMAC.new('sha1', @openstack_temp_url_key.to_s) sig = sig_to_hex(hmac.sign(string_to_sign)) = { :scheme => scheme, :host => host, :port => port, :path => object_path_escaped, :query => "temp_url_sig=#{sig}&temp_url_expires=#{expires}" } URI::Generic.build().to_s end |
#delete_container(name) ⇒ Object
Delete an existing container
Parameters
-
name<~String> - Name of container to delete
10 11 12 13 14 15 16 |
# File 'lib/fog/storage/openstack/requests/delete_container.rb', line 10 def delete_container(name) request( :expects => 204, :method => 'DELETE', :path => Fog::OpenStack.escape(name) ) end |
#delete_multiple_objects(container, object_names, options = {}) ⇒ Excon::Response
Deletes multiple objects or containers with a single request.
To delete objects from a single container, container
may be provided and object_names
should be an Array of object names within the container.
To delete objects from multiple containers or delete containers, container
should be nil
and all object_names
should be prefixed with a container name.
Containers must be empty when deleted. object_names
are processed in the order given, so objects within a container should be listed first to empty the container.
Up to 10,000 objects may be deleted in a single request. The server will respond with 200 OK for all requests. response.body
must be inspected for actual results.
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
# File 'lib/fog/storage/openstack/requests/delete_multiple_objects.rb', line 45 def delete_multiple_objects(container, object_names, = {}) body = object_names.map do |name| object_name = container ? "#{container}/#{name}" : name URI.encode(object_name) end.join("\n") response = request({ :expects => 200, :method => 'DELETE', :headers => .merge('Content-Type' => 'text/plain', 'Accept' => 'application/json'), :body => body, :query => {'bulk-delete' => true} }, false) response.body = Fog::JSON.decode(response.body) response end |
#delete_object(container, object) ⇒ Object
Delete an existing object
Parameters
-
container<~String> - Name of container to delete
-
object<~String> - Name of object to delete
11 12 13 14 15 16 17 |
# File 'lib/fog/storage/openstack/requests/delete_object.rb', line 11 def delete_object(container, object) request( :expects => 204, :method => 'DELETE', :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" ) end |
#delete_static_large_object(container, object, options = {}) ⇒ Excon::Response
Delete a static large object.
Deletes the SLO manifest object
and all segments that it references. The server will respond with 200 OK for all requests. response.body
must be inspected for actual results.
26 27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/fog/storage/openstack/requests/delete_static_large_object.rb', line 26 def delete_static_large_object(container, object, = {}) response = request({ :expects => 200, :method => 'DELETE', :headers => .merge('Content-Type' => 'text/plain', 'Accept' => 'application/json'), :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}", :query => {'multipart-manifest' => 'delete'} }, false) response.body = Fog::JSON.decode(response.body) response end |
#get_container(container, options = {}) ⇒ Object
Get details for container and total bytes stored
Parameters
-
container<~String> - Name of container to retrieve info for
-
options<~String>:
-
‘limit’<~String> - Maximum number of objects to return
-
‘marker’<~String> - Only return objects whose name is greater than marker
-
‘prefix’<~String> - Limits results to those starting with prefix
-
‘path’<~String> - Return objects nested in the pseudo path
-
Returns
-
response<~Excon::Response>:
-
headers<~Hash>:
-
‘X-Account-Container-Count’<~String> - Count of containers
-
‘X-Account-Bytes-Used’<~String> - Bytes used
-
-
body<~Array>:
-
‘bytes’<~Integer> - Number of bytes used by container
-
‘count’<~Integer> - Number of items in container
-
‘name’<~String> - Name of container
-
item<~Hash>:
-
‘bytes’<~String> - Size of object
-
‘content_type’<~String> Content-Type of object
-
‘hash’<~String> - Hash of object (etag?)
-
‘last_modified’<~String> - Last modified timestamp
-
‘name’<~String> - Name of object
-
-
-
30 31 32 33 34 35 36 37 38 |
# File 'lib/fog/storage/openstack/requests/get_container.rb', line 30 def get_container(container, = {}) = .reject { |_key, value| value.nil? } request( :expects => 200, :method => 'GET', :path => Fog::OpenStack.escape(container), :query => {'format' => 'json'}.merge!() ) end |
#get_containers(options = {}) ⇒ Object
List existing storage containers
Parameters
-
options<~Hash>:
-
‘limit’<~Integer> - Upper limit to number of results returned
-
‘marker’<~String> - Only return objects with name greater than this value
-
Returns
-
response<~Excon::Response>:
-
body<~Array>:
-
container<~Hash>:
-
‘bytes’<~Integer>: - Number of bytes used by container
-
‘count’<~Integer>: - Number of items in container
-
‘name’<~String>: - Name of container
-
-
-
19 20 21 22 23 24 25 26 27 |
# File 'lib/fog/storage/openstack/requests/get_containers.rb', line 19 def get_containers( = {}) = .reject { |_key, value| value.nil? } request( :expects => [200, 204], :method => 'GET', :path => '', :query => {'format' => 'json'}.merge!() ) end |
#get_object(container, object, &block) ⇒ Object
Get details for object
Parameters
-
container<~String> - Name of container to look in
-
object<~String> - Name of object to look for
11 12 13 14 15 16 17 18 19 20 21 22 23 |
# File 'lib/fog/storage/openstack/requests/get_object.rb', line 11 def get_object(container, object, &block) params = { :expects => 200, :method => 'GET', :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" } if block_given? params[:response_block] = block end request(params, false) end |
#get_object_http_url(container, object, expires, options = {}) ⇒ Object
Get an expiring object http url
Parameters
-
container<~String> - Name of container containing object
-
object<~String> - Name of object to get expiring url for
-
expires<~Time> - An expiry time for this url
Returns
-
response<~Excon::Response>:
-
body<~String> - url for object
-
15 16 17 |
# File 'lib/fog/storage/openstack/requests/get_object_http_url.rb', line 15 def get_object_http_url(container, object, expires, = {}) create_temp_url(container, object, expires, "GET", {:port => 80}.merge().merge(:scheme => "http")) end |
#get_object_https_url(container, object, expires, options = {}) ⇒ Object
Get an expiring object https url from Cloud Files
Parameters
-
container<~String> - Name of container containing object
-
object<~String> - Name of object to get expiring url for
-
expires<~Time> - An expiry time for this url
Returns
-
response<~Excon::Response>:
-
body<~String> - url for object
-
15 16 17 |
# File 'lib/fog/storage/openstack/requests/get_object_https_url.rb', line 15 def get_object_https_url(container, object, expires, = {}) create_temp_url(container, object, expires, "GET", {:port => 443}.merge().merge(:scheme => "https")) end |
#head_container(container) ⇒ Object
List number of objects and total bytes stored
Parameters
-
container<~String> - Name of container to retrieve info for
Returns
-
response<~Excon::Response>:
-
headers<~Hash>:
-
‘X-Container-Object-Count’<~String> - Count of containers
-
‘X-Container-Bytes-Used’<~String> - Bytes used
-
-
15 16 17 18 19 20 21 22 |
# File 'lib/fog/storage/openstack/requests/head_container.rb', line 15 def head_container(container) request( :expects => 204, :method => 'HEAD', :path => Fog::OpenStack.escape(container), :query => {'format' => 'json'} ) end |
#head_containers ⇒ Object
List number of containers and total bytes stored
Returns
-
response<~Excon::Response>:
-
headers<~Hash>:
-
‘X-Account-Container-Count’<~String> - Count of containers
-
‘X-Account-Bytes-Used’<~String> - Bytes used
-
-
12 13 14 15 16 17 18 19 |
# File 'lib/fog/storage/openstack/requests/head_containers.rb', line 12 def head_containers request( :expects => 200..299, :method => 'HEAD', :path => '', :query => {'format' => 'json'} ) end |
#head_object(container, object) ⇒ Object
Get headers for object
Parameters
-
container<~String> - Name of container to look in
-
object<~String> - Name of object to look for
11 12 13 14 15 16 17 |
# File 'lib/fog/storage/openstack/requests/head_object.rb', line 11 def head_object(container, object) request({ :expects => 200, :method => 'HEAD', :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" }, false) end |
#post_object(container, object, headers = {}) ⇒ Object
Update object metadata
Parameters
-
container<~String> - Name for container, should be < 256 bytes and must not contain ‘/’
-
object<~String> - Name for object
-
headers<~Hash> - metadata headers for object. Defaults to {}.
12 13 14 15 16 17 18 19 20 21 22 |
# File 'lib/fog/storage/openstack/requests/post_object.rb', line 12 def post_object(container, object, headers = {}) params = { :expects => 202, :headers => headers, :method => 'POST', :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" } request(params) end |
#post_set_meta_temp_url_key(key) ⇒ Object
Set the account wide Temp URL Key. This is a secret key that’s used to generate signed expiring URLs.
Once the key has been set with this request you should create new Storage objects with the :openstack_temp_url_key option then use the get_object_https_url method to generate expiring URLs.
*** CAUTION *** changing this secret key will invalidate any expiring URLS generated with old keys.
Parameters
-
key<~String> - The new Temp URL Key
Returns
-
response<~Excon::Response>
See Also
docs.rackspace.com/files/api/v1/cf-devguide/content/Set_Account_Metadata-d1a4460.html
23 24 25 26 27 28 29 |
# File 'lib/fog/storage/openstack/requests/post_set_meta_temp_url_key.rb', line 23 def (key) request( :expects => [201, 202, 204], :method => 'POST', :headers => {'X-Account-Meta-Temp-Url-Key' => key} ) end |
#put_container(name, options = {}) ⇒ Object
Create a new container
Parameters
-
name<~String> - Name for container, should be < 256 bytes and must not contain ‘/’
10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/fog/storage/openstack/requests/put_container.rb', line 10 def put_container(name, = {}) headers = [:headers] || {} headers['X-Container-Read'] = '.r:*' if [:public] headers['X-Remove-Container-Read'] = 'x' if [:public] == false request( :expects => [201, 202], :method => 'PUT', :path => Fog::OpenStack.escape(name), :headers => headers ) end |
#put_dynamic_obj_manifest(container, object, options = {}) ⇒ Object
Create a new dynamic large object manifest
Creates an object with a X-Object-Manifest
header that specifies the common prefix (“<container>/<prefix>”) for all uploaded segments. Retrieving the manifest object streams all segments matching this prefix. Segments must sort in the order they should be concatenated. Note that any future objects stored in the container along with the segments that match the prefix will be included when retrieving the manifest object.
All segments must be stored in the same container, but may be in a different container than the manifest object. The default X-Object-Manifest
header is set to “container
/object
”, but may be overridden in options
to specify the prefix and/or the container where segments were stored. If overridden, names should be CGI escaped (excluding spaces) if needed (see OpenStack.escape).
28 29 30 31 32 33 34 35 36 37 |
# File 'lib/fog/storage/openstack/requests/put_dynamic_obj_manifest.rb', line 28 def put_dynamic_obj_manifest(container, object, = {}) path = "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" headers = {'X-Object-Manifest' => path}.merge() request( :expects => 201, :headers => headers, :method => 'PUT', :path => path ) end |
#put_object(container, object, data, options = {}, &block) ⇒ Object
Create a new object
When passed a block, it will make a chunked request, calling the block for chunks until it returns an empty string. In this case the data parameter is ignored.
Parameters
-
container<~String> - Name for container, should be < 256 bytes and must not contain ‘/’
-
object<~String> - Name for object
-
data<~String|File> - data to upload
-
options<~Hash> - config headers for object. Defaults to {}.
-
block<~Proc> - chunker
18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/fog/storage/openstack/requests/put_object.rb', line 18 def put_object(container, object, data, = {}, &block) if block_given? params = {:request_block => block} headers = else data = Fog::Storage.parse_data(data) headers = data[:headers].merge!() params = {:body => data[:body]} end params.merge!( :expects => 201, :idempotent => !params[:request_block], :headers => headers, :method => 'PUT', :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}" ) request(params) end |
#put_object_manifest(container, object, options = {}) ⇒ Object
Create a new dynamic large object manifest
This is an alias for #put_dynamic_obj_manifest for backward compatibility.
8 9 10 |
# File 'lib/fog/storage/openstack/requests/put_object_manifest.rb', line 8 def put_object_manifest(container, object, = {}) put_dynamic_obj_manifest(container, object, ) end |
#put_static_obj_manifest(container, object, segments, options = {}) ⇒ Object
Create a new static large object manifest.
A static large object is similar to a dynamic large object. Whereas a GET for a dynamic large object manifest will stream segments based on the manifest’s X-Object-Manifest
object name prefix, a static large object manifest streams segments which are defined by the user within the manifest. Information about each segment is provided in segments
as an Array of Hash objects, ordered in the sequence which the segments should be streamed.
When the SLO manifest is received, each segment’s etag
and size_bytes
will be verified. The etag
for each segment is returned in the response to #put_object, but may also be calculated. e.g. Digest::MD5.hexdigest(segment_data)
The maximum number of segments for a static large object is 1000, and all segments (except the last) must be at least 1 MiB in size. Unlike a dynamic large object, segments are not required to be in the same container.
42 43 44 45 46 47 48 49 50 51 |
# File 'lib/fog/storage/openstack/requests/put_static_obj_manifest.rb', line 42 def put_static_obj_manifest(container, object, segments, = {}) request( :expects => 201, :method => 'PUT', :headers => , :body => Fog::JSON.encode(segments), :path => "#{Fog::OpenStack.escape(container)}/#{Fog::OpenStack.escape(object)}", :query => {'multipart-manifest' => 'put'} ) end |
#reset_account_name ⇒ Object
171 172 173 |
# File 'lib/fog/storage/openstack.rb', line 171 def reset_account_name @path = @original_path end |