Class: RightAws::S3
- Inherits:
-
Object
- Object
- RightAws::S3
- Defined in:
- lib/s3/right_s3.rb
Overview
RightAws::S3 – RightScale’s Amazon S3 interface
The RightAws::S3 class provides a complete interface to Amazon’s Simple Storage Service. For explanations of the semantics of each call, please refer to Amazon’s documentation at developer.amazonwebservices.com/connect/kbcategory.jspa?categoryID=48
See examples below for the bucket and buckets methods.
Error handling: all operations raise an RightAws::AwsError in case of problems. Note that transient errors are automatically retried.
It is a good way to use domain naming style getting a name for the buckets. See docs.amazonwebservices.com/AmazonS3/2006-03-01/UsingBucket.html about the naming convention for the buckets. This case they can be accessed using a virtual domains.
Let assume you have 3 buckets: ‘awesome-bucket’, ‘awesome_bucket’ and ‘AWEsomE-bucket’. The first ones objects can be accessed as: http:// awesome-bucket.s3.amazonaws.com/key/object
But the rest have to be accessed as: http:// s3.amazonaws.com/awesome_bucket/key/object and http:// s3.amazonaws.com/AWEsomE-bucket/key/object
See: docs.amazonwebservices.com/AmazonS3/2006-03-01/VirtualHosting.html for better explanation.
Defined Under Namespace
Classes: Bucket, Grantee, Key, Owner
Instance Attribute Summary collapse
-
#interface ⇒ Object
readonly
Returns the value of attribute interface.
Instance Method Summary collapse
-
#bucket(name, create = false, perms = nil, headers = {}) ⇒ Object
Retrieve an individual bucket.
-
#buckets ⇒ Object
Retrieve a list of buckets.
-
#initialize(aws_access_key_id = nil, aws_secret_access_key = nil, params = {}) ⇒ S3
constructor
Create a new handle to an S3 account.
Constructor Details
#initialize(aws_access_key_id = nil, aws_secret_access_key = nil, params = {}) ⇒ S3
Create a new handle to an S3 account. All handles share the same per process or per thread HTTP connection to Amazon S3. Each handle is for a specific account. The params
are passed through as-is to RightAws::S3Interface.new
Params is a hash:
{:server => 's3.amazonaws.com' # Amazon service host: 's3.amazonaws.com'(default)
:port => 443 # Amazon service port: 80 or 443(default)
:protocol => 'https' # Amazon service protocol: 'http' or 'https'(default)
:logger => Logger Object} # Logger instance: logs to STDOUT if omitted }
63 64 65 |
# File 'lib/s3/right_s3.rb', line 63 def initialize(aws_access_key_id=nil, aws_secret_access_key=nil, params={}) @interface = S3Interface.new(aws_access_key_id, aws_secret_access_key, params) end |
Instance Attribute Details
#interface ⇒ Object (readonly)
Returns the value of attribute interface.
51 52 53 |
# File 'lib/s3/right_s3.rb', line 51 def interface @interface end |
Instance Method Details
#bucket(name, create = false, perms = nil, headers = {}) ⇒ Object
Retrieve an individual bucket. If the bucket does not exist and create
is set, a new bucket is created on S3. Launching this method with create
=true
may affect on the bucket’s ACL if the bucket already exists. Returns a RightAws::S3::Bucket instance or nil
if the bucket does not exist and create
is not set.
s3 = RightAws::S3.new(aws_access_key_id, aws_secret_access_key)
bucket1 = s3.bucket('my_awesome_bucket_1')
bucket1.keys #=> exception here if the bucket does not exists
...
bucket2 = s3.bucket('my_awesome_bucket_2', true)
bucket2.keys #=> list of keys
# create a bucket at the European location with public read access
bucket3 = s3.bucket('my-awesome-bucket-3', true, 'public-read', :location => :eu)
see http://docs.amazonwebservices.com/AmazonS3/2006-03-01/RESTAccessPolicy.html
(section: Canned Access Policies)
99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 |
# File 'lib/s3/right_s3.rb', line 99 def bucket(name, create=false, perms=nil, headers={}) result = nil if create headers['x-amz-acl'] = perms if perms @interface.create_bucket(name, headers) end begin buckets.each do |bucket| if bucket.name == name result = bucket break end end rescue RightAws::AwsError => e # With non root creds one can use bucket(s) but can't list them raise e unless e.['AccessDenied'] result = Bucket::new(self, name) end result end |