Python boto与boto3操作S3 Bucket示例及HTTPS连接问题排查
本文对比了Python中boto与boto3库操作S3 Bucket的方法,重点解决使用自签证书时HTTPS连接失败的问题。详细记录了boto库在is_secure设置下出现的SSL证书验证错误及远程断开异常,并提供了boto3结合urllib3禁用警告的正确配置示例,涵盖Bucket创建、列表获取、文件上传及删除等完整操作。
boto库操作S3 Bucket基础示例
boto库操作S3 Bucket的基础示例
import datetime
import boto.s3.connection
from boto.s3.key import Key
conn = boto.connect_s3(
aws_access_key_id="123456",
aws_secret_access_key="123456",
host="127.0.0.1",
port=8080,
is_secure=False,
calling_format=boto.s3.connection.OrdinaryCallingFormat(),
)
str_bucket_name = "bucket_test"
conn.create_bucket(str_bucket_name) # 创建bucket
for bucket in conn.get_all_buckets(): # 获取所有bucket
# 将实际转为本地时间
print({"name": bucket.name, "create_date": str(datetime.datetime.strptime(bucket.creation_date, "%Y-%m-%dT%H:%M:%S.%fZ") + datetime.timedelta(hours=8))})
# 删除指定的bucket
for bucket in conn.get_all_buckets():
if bucket.name == str_bucket_name:
for key in bucket.list(): # 必须将bucket里清空后,才能删除掉对应的bucket
bucket.delete_key(key.name)
conn.delete_bucket(bucket.name)
break
# 存储文件流或字符串中的数据
key = Key('hello.txt')
key.set_contents_from_file('/tmp/hello.txt')
boto库HTTPS连接失败问题分析
在使用boto库尝试建立HTTPS连接时,发现无论将validate_certs参数设置为True还是False,均无法成功连接
当配置is_secure为True时,系统抛出如下错误信息
ssl.SSLCertVerificationError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1076)
当配置is_secure为False时,则遇到另一种连接异常
http.client.RemoteDisconnected: Remote end closed connection without response
切换至boto3库的解决方案
鉴于上述问题,决定切换至boto3库进行后续操作
boto3库HTTPS连接完整操作示例
以下是使用boto3库通过HTTPS连接S3 Bucket的示例代码。此前boto库无法连接HTTPS可能源于自签名证书导致的兼容性问题,因此改用boto3库解决
import urllib3
import boto3
urllib3.disable_warnings()
s3 = boto3.resource(
service_name='s3',
aws_access_key_id="123456",
aws_secret_access_key="123456",
endpoint_url='https://192.168.150.20:8080',
verify=False
)
str_bucket_name = "bucket_test"
s3.create_bucket(Bucket=str_bucket_name)
for bucket in s3.buckets.all(): # 获取所有bucket
# 将实际转为本地时间
print({"name": bucket.name, "create_date": datetime.datetime.strftime(bucket.creation_date + datetime.timedelta(hours=8), "%Y-%m-%d %H:%M:%S")})
# 删除指定的bucket
for bucket in s3.buckets.all():
if bucket.name == str_bucket_name:
bucket.objects.all().delete() # 等价于下面两行
# for obj in bucket.objects.all():
# obj.delete()
bucket.delete()
# 存储文件流或字符串中的数据
s3.Object('mybucket', 'hello.txt').put(Body=open('/tmp/hello.txt', 'rb'))
以上即为Python中boto与boto3操作Bucket的完整示例,更多Python操作Bucket的相关资料请持续关注本站其他技术文章
本站声明
本文内容仅供参考,不代表本站观点。转载或引用请注明出处。如发现内容问题,请通过联系我们页面反馈。













