Blame view
README
11.7 KB
ad1775341
OSS from Aliyun
|
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 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 |
阿里云开放存储服务 Open Storage Service (OSS) Python SDK说明文档
===============================================================
阿里云开放存储服务官方网站:
http://oss.aliyun.com
阿里云开放存储
===============================================================
存储在OSS里的文件叫做"object". 所有的object都放在bucket里面。
简介
===============================================================
这篇文档主要介绍如何使用Python来进行OSS API调用，并且介绍osscmd
的简单使用。
这篇文档假设你已经熟悉Python，熟悉OSS的相关概念，并且已经注册了
阿里云的OSS服务，且获得了相应的ID和KEY。
如果你还没有开通或者还不了解OSS，请移步OSS官方网站。
环境要求
===============================================================
Python SDK需要：安装python 2.5（包括）以上且在3.0（不包括）以下
的版本。
可以在Windows平台和Linux平台使用。
如何获取
===============================================================
1. 打开浏览器，输入oss.aliyun.com
2. 找到Python SDK链接：
3. 下载后可以得到类似OSS_Python_API_xxxxxxxx.tar.gz的包
4. 进入压缩包所在的目录，进行解压缩
5. 解压缩后得到，oss文件夹和osscmd文件
使用说明
===============================================================
使用oss_api.py
===============================================================
1. 创建bucket
def put_bucket(self, bucket, acl='', headers=None):
等同create_bucket函数
def create_bucket(self, bucket, acl='', headers=None):
参数说明：
bucket，类型：string
acl，类型：string，目前为private，public-read，
public-read-write中的一种
headers， 类型：dict，默认为空
返回值说明：
HTTP Response
参见http://docs.python.org/2/library/httplib.html
def put_bucket_with_location(self, bucket, acl='', \
location='', headers=None):
参数说明：
bucket，类型：string
acl，类型：string
location， 类型：string
headers， 类型：dict
返回值说明：
HTTP Response
2. 删除bucket
def delete_bucket(self, bucket, headers=None):
参数说明：
bucket，类型：string
headers， 类型：dict
返回值说明：
HTTP Response
3. 修改bucket访问权限
def put_bucket(self, bucket, acl='', headers=None):
def create_bucket(self, bucket, acl='', headers=None):
同1中的put_bucket和create_bucket
4. 获取bucket访问权限
def get_bucket_acl(self, bucket):
参数说明：
bucket，类型：string
返回值说明：
HTTP Response
5. 显示创建的bucket
def get_service(self, headers=None):
参数说明：
headers， 类型：dict
返回值说明：
HTTP Response
def list_all_my_buckets(self, headers=None):
参数说明：
headers， 类型：dict
返回值说明：
HTTP Response
6. 上传object
def put_object_from_string(self, bucket, object,\
input_content,\
content_type=DefaultContentType,\
headers=None, params=None):
参数说明：
bucket，类型：string
object，类型：string
input_content，类型：string
content_type，类型：string
headers，类型：dict
params，类型：dict
返回值说明：
HTTP Response
def put_object_from_file(self, bucket, object,\
filename, content_type='',\
headers=None, params=None):
参数说明：
bucket，类型：string
object，类型：string
filename，类型：string，本地需要上传的文件名
content_type，类型：string，object的类型
headers，类型：dict
params，类型：dict
返回值说明：
HTTP Response
7. 显示上传的object
def get_bucket(self, bucket, prefix='', marker='',\
delimiter='', maxkeys='', headers=None):
同list_bucket
def list_bucket(self, bucket, prefix='', marker='',\
delimiter='', maxkeys='', headers=None):
参数说明：
bucket，类型：string
prefix，类型：string
marker，类型：string
delimiter，类型：string
maxkeys，类型：string
headers，类型：dict
返回值说明：
HTTP Response
8. 删除object
def delete_object(self, bucket, object, headers=None):
参数说明：
bucket，类型：string
object，类型：string
headers，类型：dict
返回值说明：
HTTP Response
9. 下载object
def get_object_to_file(self, bucket, object,\
filename, headers=None):
参数说明：
bucket，类型：string
object，类型：string
filename，类型：string，
将object内容下载到本地文件的文件名
headers，类型：dict
返回值说明：
HTTP Response
10. 使用示例：
在解压的oss目录下，创建一个测试文件test.py内容如下，
并将ACCESS_ID和SECRET_ACCESS_KEY的内容填写正确，
并且将BUCKET填写一个唯一的名字。
#!/usr/bin/env python
#coding=utf8
import time
from oss_api import *
from oss_xml_handler import *
HOST="oss.aliyuncs.com"
ACCESS_ID = ""
SECRET_ACCESS_KEY = ""
#ACCESS_ID and SECRET_ACCESS_KEY 默认是空，
#请填入您申请的正确的ID和KEY.
BUCKET = ""
#bucket 默认是空，请填入唯一的bucket名称
#例如test-bucket-20130101等带唯一日期的bucket名字.
def check_not_empty(input, msg=""):
if not input:
print "Please make sure %s not empty!" % msg
exit(-1)
def check_res(res, msg=""):
if res.status / 100 == 2:
print "%s OK" % msg
else:
print "%s FAIL" % msg
print "ret:%s" % res.status
print "request-id:%s" % res.getheader("x-oss-request-id")
print "reason:%s" % res.read()
exit(-1)
if __name__ == "__main__":
#初始化
check_not_empty(ACCESS_ID, "ACCESS_ID")
check_not_empty(SECRET_ACCESS_KEY, "SECRET_ACCESS_KEY")
oss = OssAPI(HOST, ACCESS_ID, SECRET_ACCESS_KEY)
#创建属于自己的bucket
bucket = BUCKET
check_not_empty(bucket, "bucket")
acl = 'private'
headers = {}
res = oss.put_bucket(bucket, acl, headers)
check_res(res, "create bucket")
#列出创建的bucket
res = oss.get_service()
check_res(res, "list all buckets")
#把指定的字符串内容上传到bucket中,在bucket中的文件名叫object。
object = "object_test"
input_content = "hello, OSS"
content_type = "text/HTML"
headers = {}
res = oss.put_object_from_string(bucket, object, input_content, content_type, headers)
check_res(res, "upload from string")
#指定文件名, 把这个文件上传到bucket中,在bucket中的文件名叫object。
object = "object_test"
filename = __file__
content_type = "text/HTML"
headers = {}
res = oss.put_object_from_file(bucket, object, filename, content_type, headers)
check_res(res, "upload from localfile")
#下载bucket中的object，内容在body中
object = "object_test"
headers = {}
res = oss.get_object(bucket, object, headers)
check_res(res, "download object")
#下载bucket中的object，把内容写入到本地文件中
object = "object_test"
headers = {}
filename = "get_object_test_file"
res = oss.get_object_to_file(bucket, object, filename, headers)
if os.path.isfile(filename):
os.remove(filename)
check_res(res, "download object to localfile")
#查看bucket中所拥有的权限
res = oss.get_bucket_acl(bucket)
check_res(res, "get bucket acl")
#列出bucket中所拥有的object
prefix = ""
marker = ""
delimiter = "/"
maxkeys = "100"
headers = {}
res = oss.get_bucket(bucket, prefix, marker, delimiter, maxkeys, headers)
check_res(res, "list objects in bucket")
#删除bucket中的object
object = "object_test"
headers = {}
res = oss.delete_object(bucket, object, headers)
check_res(res, "delete object")
#删除bucket
res = oss.delete_bucket(bucket)
check_res(res, "delete bucket")
11. 示例的预期结果：
create bucket OK
list all buckets OK
upload from string OK
upload from localfile OK
download object OK
download object to localfile OK
get bucket acl OK
list objects in bucket OK
delete object OK
delete bucket OK
使用osscmd
===============================================================
1. 在Linux上安装 osscmd.
sudo rm -r /usr/local/oss
sudo mkdir -p /usr/local/oss
sudo tar -zxf oss.tar.gz -C /usr/local/oss
sudo rm -f /usr/bin/osscmd
sudo ln -s /usr/local/oss/osscmd /usr/bin/osscmd
sudo chmod 755 /usr/local/oss/osscmd
在Windows上安装osscmd
解压缩包
2. 运行"python osscmd config --id=YOUR_ID --key=YOUR_KEY"
用来配置访问OSS所需要的认证码
3. 运行"python osscmd getallbucket" 列出创建的bucket.
如果是刚刚使用OSS的用户因为没有创建bucket，输出是空
4. 运行"python osscmd createbucket mybucket" 创建一个名字
叫mybucket的bucket，有可能不成功，这个时候需要换一个名字。
因为OSS中的bucket名字是全局唯一的。
5. 可以再次运行"python osscmd getallbucket" 查看是否创建成功。
如果没有成功请检查osscmd返回的错误信息。
6. 成功创建bucket后。运行"python osscmd list oss://mybucket/",
查看bucket中有哪些object。
由于bucket中还没有
object，输出是空的。
7. 向bucket中上传一个object.
$ md5sum my_local_file
7625e1adc3a4b129763d580ca0a78e44 my_local_file
$ python osscmd put my_local_file oss://mybucket/myobject
8. 如果创建成功，再次运行"python osscmd list oss://mybucket/"
9. 从bucket中下载object到本地文件，并比对下载的文件的md5值
$ python osscmd get oss://mybucket/myobject local_file
$ md5sum local_file
7625e1adc3a4b129763d580ca0a78e44 local_file
10. 删除bucket中的object
$ python osscmd delete oss://mybucket/myobject
11. 删除bucket, 注意，如果bucket中有object或者parts
则这个bucket不能被删除
$ python osscmd deletebucket test-oss-aliyun-com
ChangeHistory
===============================================================
0.3.2 - 2013-10-20
* 修复osscmd的uploadfromdir命令中，在中文目录下，上传的object名字被截断的问题。
* 修复oss_util.py中DEBUG被设置成True的情况下无法打印log的问题。
* oss_api.py中增加了设置每次上传和下载大小的接口。
* osscmd增加了--debug=true来打印日志。
* oss_api.py中增加了上传失败时候的重试，最大重试100次。
0.3.1 - 2013-08-02
* 支持跳转。
* 给oss_api.py部分函数增加说明。
0.1.3 - 2013-07-12
* 支持multipart相关操作，osscmd增加multipart相关的接口。
osscmd支持本地目录上传。
osscmd支持将bucket的某一个prefix的object下载到本地的目录。
0.1.0 - 2011-11-15
* 第一次操作支持基本的创建，删除和显示bucket。
支持创建，删除和显示object。
|