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
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
|
# -*- encoding: utf-8 -*-
$LOAD_PATH.unshift(File.expand_path("../../../../lib", __FILE__))
require 'yaml'
require 'aliyun/oss'
# 初始化OSS client
Aliyun::Common::Logging.set_log_level(Logger::DEBUG)
conf_file = '~/.oss.yml'
conf = YAML.load(File.read(File.expand_path(conf_file)))
bucket = Aliyun::OSS::Client.new(
:endpoint => conf['endpoint'],
:cname => conf['cname'],
:access_key_id => conf['access_key_id'],
:access_key_secret => conf['access_key_secret']).get_bucket(conf['bucket'])
# 辅助打印函数
def demo(msg)
puts "######### #{msg} ########"
puts
yield
puts "-------------------------"
puts
end
# 上传一个object
# 流式上传请参考：examples/streaming.rb
demo "Put object from input" do
bucket.put_object('files/hello') do |content|
content << 'hello world.'
end
puts "Put object: files/hello"
end
# 上传一个文件
# 断点续传请参考：examples/resumable_upload.rb
demo "Put object from local file" do
File.open('/tmp/x', 'w'){ |f| f.write("hello world\n") }
bucket.put_object('files/world', :file => '/tmp/x')
puts "Put object: files/world"
end
# 创建一个Appendable object
demo "Create appendable object" do
size = bucket.get_object('files/appendable').size rescue 0
bucket.append_object('files/appendable', size) do |content|
content << 'hello appendable.'
end
puts "Append object: files/appendable"
end
# 向files/appendable中追加内容
# 首先要获取object当前的长度
demo "Append to object" do
size = bucket.get_object('files/appendable').size
bucket.append_object('files/appendable', size) do |content|
content << 'again appendable.'
end
puts "Append object: files/appendable"
end
# 使用错误的position进行追加会失败
demo "Append with wrong pos" do
begin
bucket.append_object('files/appendable', 0) do |content|
content << 'again appendable.'
end
rescue => e
puts "Append failed: #{e.message}"
end
end
# 向一个normal object中追加内容会失败
demo "Append to normal object(fail)" do
begin
bucket.append_object('files/hello', 0) do |content|
content << 'hello appendable.'
end
rescue => e
puts "Append object failed: #{e.message}"
end
end
# 拷贝一个object
demo "Copy object" do
bucket.copy_object('files/hello', 'files/copy')
puts "Copy object files/hello => files/copy"
end
# 拷贝一个appendable object会失败
demo "Copy appendable object(fail)" do
begin
bucket.copy_object('files/appendable', 'files/copy')
rescue => e
puts "Copy object failed: #{e.message}"
end
end
# 下载一个object：流式处理
# 流式下载请参考：examples/streaming.rb
demo "Get object: handle content" do
total_size = 0
bucket.get_object('files/hello') do |chunk|
total_size += chunk.size
end
puts "Total size: #{total_size}"
end
# 下载一个object：下载到文件中
demo "Get object to local file" do
bucket.get_object('files/hello', :file => '/tmp/hello')
puts "Get object: files/hello => /tmp/hello"
end
# 删除一个object
demo "Delete object" do
bucket.delete_object('files/world')
puts "Delete object: files/world"
end
# 删除一个不存在的object返回OK
# 这意味着delete_object是幂等的，在删除失败的时候可以不断重试，直到成
# 功，成功意味着object已经不存在
demo "Delete a non-existent object(OK)" do
bucket.delete_object('non-existent-object')
puts "Delete object: non-existent-object"
end
# 设置Object metas
demo "Put objec with metas" do
bucket.put_object(
'files/hello',
:metas => {'year' => '2015', 'people' => 'mary'}
) do |content|
content << 'hello world.'
end
o = bucket.get_object('files/hello', :file => '/tmp/x')
puts "Object metas: #{o.metas}"
end
# 修改Object metas
demo "Update object metas" do
bucket.update_object_metas(
'files/hello', {'year' => '2016', 'people' => 'jack'})
o = bucket.get_object('files/hello')
puts "Meta changed: #{o.metas}"
end
# 设置Object的ACL
demo "Set object ACL" do
puts "Object acl before: #{bucket.get_object_acl('files/hello')}"
bucket.set_object_acl('files/hello', Aliyun::OSS::ACL::PUBLIC_READ)
puts "Object acl now: #{bucket.get_object_acl('files/hello')}"
end
# 指定条件get_object
demo "Get object with conditions" do
o = bucket.get_object('files/hello')
begin
o = bucket.get_object(
'files/hello',
:condition => {:if_match_etag => o.etag + 'x'})
rescue Aliyun::OSS::ServerError => e
puts "Get object failed: #{e.message}"
end
begin
o = bucket.get_object(
'files/hello',
:condition => {:if_unmodified_since => o.last_modified - 60})
rescue Aliyun::OSS::ServerError => e
puts "Get object failed: #{e.message}"
end
o = bucket.get_object(
'files/hello',
:condition => {:if_match_etag => o.etag, :if_unmodified_since => Time.now})
puts "Get object: #{o.to_s}"
end
|
