使用BOTO进行S3各种操作

蔚落 2023-06-05 08:51 3阅读 0赞

### [使用BOTO进行S3各种操作][BOTO_S3] ###

BOTO是一个开源的PYTHON发布包，是AWS（AMAZON WEBSERVICE）的PYTHON封装。

近期，我们公司用到国内某知名公司的S3云存储服务，需要调用该公司提供的S3 PYTHON SDK。鉴于该公司没有PYTHON版本的SDK，所以我决定利用开源的BOTO的S3模块稍加改进。在经过easy\_install boto之后便开始了BOTO的封装

以下是我最开始封装的代码模型

1）获取S3连接：

Python代码   ![收藏代码][icon_star.png]

1. <span style="font-size: medium;">**from** boto.s3.connection **import** S3Connection  
2. conn = S3Connection(S3\_ACCESSED\_ID, S3\_SECRECT\_ACCESS\_KEY,host=S3\_HOST）

参数说明：

S3\_HOST是提供开放式云存储服务的公司提供的云主机域名

S3\_ACCESSED\_ID, S3\_SECRECT\_ACCESS\_KEY是该公司提供给我们公司的唯一访问标识

2)PUT上传文件

Python代码   ![收藏代码][icon_star.png]

1. <span style="font-size: medium;"> **def** put(bucket\_name, s3\_path, local\_file):   
2.        b = conn.get\_bucket(bucket\_name)  
3.        k = Key(b)  
4.        k.key = s3\_path  
5.        k.set\_contents\_from\_filename(local\_file,policy='public-read')

参数说明:

bucket\_name是云主机上的云储存分类标识，类型是字符串，可以说是云储存的第一层目录，比如你们公司可以有mp3,mp4,wma等N个一层目录，也就是所谓的bucket，这个可以通过代码创建，也可以登录到云储存网页的控制台进行手动操作

** local\_file**指的是你要上传的文件，类型是字符串，就是文件绝对路径

** s3\_path**就是文件上传到s3后要在s3上生成的目录结构,上传时会在指定的bucket下生成该多级目录，当然目录的结尾肯定是文件名

3)get下载文件

Python代码   ![收藏代码][icon_star.png]

1. <span style="font-size: medium;">**def** get(bucket\_name,s3\_path,local\_file):  
2.     b = conn.get\_bucket(bucket\_name)  
3.     key = b.lookup(s3\_path)  
4.     key.get\_contents\_to\_filename(local\_file)  
5.

该方法的参数与put方法中的解释类似

这些代码如果在普通的机器上测试的话，会发现没有任何问题，包括上传下载删除之类的操作都能够成功进行。实际开发过程我发现，将这些代码部署到提供云存储的一套云虚拟机环境中，所有的代码都会执行失败。这个过程中，经历了千辛万苦，我还是没有发现个中原因，主要是在云虚拟机环境中创建conn连接是成功的，就是执行到conn.get\_bucket(bucket\_name)这一步始终通不过，我考虑到是否在get\_bucket加入headers认证什么的，后来研究源码发现没有什么可以加入的，经历了两天的苦苦挣扎（这期间，我考虑过放弃BOTO，而封装使用该公司非常复杂难以理解的REST接口，后来发现，他们的REST接口在本地机器更是一个操作都执行不成功，更别说是虚拟机环境，到了周末陷入了两难的境地，开源的封装了搞不好，他们REST封装了也搞不好。）我还是选择重新研究这个报错的信息

Python代码   ![收藏代码][icon_star.png]

1. <span style="font-size: medium;">Traceback (most recent call last):  
2.   File "s3tester.py", line 35, **in** <module>  
3.     main()  
4.   File "s3tester.py", line 22, **in** main  
5.     s3.get\_bucket()  
6.   File "/srv/store/20120913111600/common/file/huaweiyun.py", line 77, **in** get\_bucket  
7.     b = conn.get\_bucket('vodmedia', validate=True)  
8.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/s3/connection.py", line 391, **in** get\_bucket  
9.     bucket.get\_all\_keys(headers, maxkeys=0)  
10.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/s3/bucket.py", line 360, **in** get\_all\_keys  
11.     '', headers, \*\*params)  
12.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/s3/bucket.py", line 317, **in** \_get\_all  
13.     query\_args=s)  
14.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/s3/connection.py", line 470, **in** make\_request  
15.     override\_num\_retries=override\_num\_retries)  
16.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/connection.py", line 913, **in** make\_request  
17.     **return** self.\_mexe(http\_request, sender, override\_num\_retries)  
18.   File "/usr/local/lib/python2.6/dist-packages/boto-2.5.2-py2.6.egg/boto/connection.py", line 859, **in** \_mexe  
19.     **raise** e  
20. socket.gaierror: \[Errno -2\] Name **or** service **not** known

后来，在始终不愿放弃的情况下艰难搜索，终于发现解决方案

具体是一下两个网上的建议给了我帮助：

[http://www.somic.org/2010/11/16/connecting-to-eucalyptus-walrus-s3-with-boto-and-socket-gaierror/][http_www.somic.org_2010_11_16_connecting-to-eucalyptus-walrus-s3-with-boto-and-socket-gaierror]

[http://www.eucalyptus.com/eucalyptus-cloud/tools/boto][http_www.eucalyptus.com_eucalyptus-cloud_tools_boto]

后来遵照他们的说法，我折腾了两天没发现原因的地方，仅仅因为一个小小的配置就成功了。

那就是创建连接是多加入一个参数：calling\_format=calling\_format

具体代码为：

Python代码   ![收藏代码][icon_star.png]

1. <span style="font-size: medium;">**from** boto.s3.connection **import** S3Connection,OrdinaryCallingFormat  
2. calling\_format=OrdinaryCallingFormat()  
3. conn = S3Connection(S3\_ACCESSED\_ID, S3\_SECRECT\_ACCESS\_KEY,host=S3\_HOST,calling\_format=calling\_format)

将这段代码改进之后，虚拟机上的一套都能够测试通过，包括最需要的上传下载操作，事实证明遇到难题，千万不要放弃，一定要寻找到答案为止。

这个代码改进的成功也打消了我对该公司云存储虚拟机的误解：之前我的代码在普通机器上执行完全正常的情况下到了他们虚拟上就执行失败，我当时非常怀疑是他们的虚拟机做了什么特殊的配置限定了代码访问云主机，后来跟他们的技术交流他们说没有任何特殊配置，可是我还是心存怀疑。直到今天发现问题所在，看来我是误解他们了！抱歉。

[BOTO_S3]: http://javacrazyer.iteye.com/blog/1679083
[icon_star.png]: /images/20230601/9253688a644949709d5255d7d0f2b90b.png
[http_www.somic.org_2010_11_16_connecting-to-eucalyptus-walrus-s3-with-boto-and-socket-gaierror]: http://www.somic.org/2010/11/16/connecting-to-eucalyptus-walrus-s3-with-boto-and-socket-gaierror/
[http_www.eucalyptus.com_eucalyptus-cloud_tools_boto]: http://www.eucalyptus.com/eucalyptus-cloud/tools/boto