Modify Bucket

Author: dt3310321

README.rst

@@ -26,13 +26,12 @@ cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
 
 .. code:: python
 
-    # 设置用户属性, 包括appid, secret_id, secret_key, region
-    appid = '100000'           # 替换为用户的appid
+    # 设置用户属性, 包括secret_id, secret_key, region
     secret_id = 'xxxxxxxx'     # 替换为用户的secret_id
     secret_key = 'xxxxxxx'     # 替换为用户的secret_key
     region = 'ap-beiging-1'    # 替换为用户的region 
     token = ''                 # 使用临时秘钥需要传入Token，默认为空,可不填
-    config = CosConfig(Appid=appid, Region=region, Access_id=secret_id, Access_key=secret_key, Token=token)  #获取配置对象
+    config = CosConfig(Region=region, Access_id=secret_id, Access_key=secret_key, Token=token)  #获取配置对象
     client = CosS3Client(config)                                                                #获取客户端对象
 
 
@@ -41,7 +40,7 @@ cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
     ############################################################################
     # 1. 上传单个文件
     response = client.put_object(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Body='TY'*1024*512*file_size,
         Key=file_name,
         CacheControl='no-cache',
@@ -50,46 +49,46 @@ cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
 
     # 2. 下载单个文件
     response = client.get_object(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key=file_name,
     )
 
     # 3. 获取文件属性
     response = client.head_object(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key=file_name
     )
 
     # 4. 删除单个文件
     response = client.delete_object(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key=file_name
     )
 
     # 5. 创建分片上传
     response = client.create_multipart_upload(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='multipartfile.txt',
     )
     uploadid = get_id_from_xml(response.text)
 
     # 6. 删除分片上传
     response = client.abort_multipart_upload(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='multipartfile.txt',
         UploadId=uploadid
     )
 
     # 7. 再次创建分片上传
     response = client.create_multipart_upload(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='multipartfile.txt',
     )
     uploadid = response['UploadId']
 
     # 8. 上传分片
     response = client.upload_part(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='multipartfile.txt',
         UploadId=uploadid,
         PartNumber=1,
@@ -99,15 +98,15 @@ cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
 
     # 9. 列出分片
     response = clieent.list_parts(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='mutilpartfile.txt',
         UploadId=uploadid
     )
     lst = response['Part'] # list_parts最大数量为1000
 
     # 10. 完成分片上传
     response = client.complete_multipart_upload(
-        Bucket='test01',
+        Bucket='test01-123456789',
         Key='multipartfile.txt',
         UploadId=uploadid,
         MultipartUpload={'Part': lst} # 超过1000个分块，请本地保存分块信息，再complete
@@ -119,16 +118,16 @@ cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
     ############################################################################
     # 1. 创建Bucket
     response = client.create_bucket(
-        Bucket='test02',
+        Bucket='test02-123456789',
         ACL='public-read'
     )   
 
     # 2. 删除Bucket
     response = client.delete_bucket(
-        Bucket='test02'
+        Bucket='test02-123456789'
     )
 
     # 3. 获取文件列表
     response = client.list_objects(
-        Bucket='test01'
+        Bucket='test01-123456789'
     )

qcloud_cos/demo.py

@@ -10,32 +10,30 @@
 
 # cos最新可用地域,参照https://www.qcloud.com/document/product/436/6224
 
-# 设置用户属性, 包括appid, secret_id, secret_key, region
-appid = '1242338703'        # 替换为用户的appid
+# 设置用户属性, 包括secret_id, secret_key, region
 secret_id = 'AKID15IsskiBQACGbAo6WhgcQbVls7HmuG00'     # 替换为用户的secret_id
 secret_key = 'csivKvxxrMvSvQpMWHuIz12pThQQlWRW'     # 替换为用户的secret_key
 region = 'ap-beijing-1'    # 替换为用户的region
 token = ''                 # 使用临时秘钥需要传入Token，默认为空,可不填
-config = CosConfig(Appid=appid, Region=region, Access_id=secret_id, Access_key=secret_key, Token=token)  # 获取配置对象
+config = CosConfig(Region=region, Access_id=secret_id, Access_key=secret_key, Token=token)  # 获取配置对象
 client = CosS3Client(config)
 
 # 文件流 简单上传
-fp = open('test.txt', 'rb')
 file_name = 'test.txt'
-response = client.put_object(
-    Bucket='test04',
-    Body=fp,
-    Key=file_name,
-    StorageClass='STANDARD',
-    CacheControl='no-cache',
-    ContentDisposition='download.txt'
-)
-fp.close()
-print response['ETag']
+with open('test.txt', 'rb') as fp:
+    response = client.put_object(
+        Bucket='test04-123456789',
+        Body=fp,
+        Key=file_name,
+        StorageClass='STANDARD',
+        CacheControl='no-cache',
+        ContentDisposition='download.txt'
+    )
+    print response['ETag']
 
 # 字节流 简单上传
 response = client.put_object(
-    Bucket='test04',
+    Bucket='test04-123456789',
     Body='abcdefg',
     Key=file_name,
     CacheControl='no-cache',
@@ -45,14 +43,14 @@
 
 # 文件下载 获取文件到本地
 response = client.get_object(
-    Bucket='test04',
+    Bucket='test04-123456789',
     Key=file_name,
 )
 response['Body'].get_stream_to_file('output.txt')
 
 # 文件下载 获取文件流
 response = client.get_object(
-    Bucket='test04',
+    Bucket='test04-123456789',
     Key=file_name,
 )
 fp = response['Body'].get_raw_stream()
@@ -61,7 +59,7 @@
 # 文件下载 捕获异常
 try:
     response = client.get_object(
-        Bucket='test04',
+        Bucket='test04-123456789',
         Key='not_exist.txt',
     )
     fp = response['Body'].get_raw_stream()

qcloud_cos/test.py

@@ -11,11 +11,10 @@
 
 ACCESS_ID = os.environ["ACCESS_ID"]
 ACCESS_KEY = os.environ["ACCESS_KEY"]
-test_bucket = "test01"
+test_bucket = "test01-1252448703"
 test_object = "test.txt"
 special_file_name = "中文" + "→↓←→↖↗↙↘! \"#$%&'()*+,-./0123456789:;<=>@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^_`abcdefghijklmnopqrstuvwxyz{|}~"
 conf = CosConfig(
-    Appid="1252448703",
     Region="ap-beijing-1",
     Access_id=ACCESS_ID,
     Access_key=ACCESS_KEY
@@ -134,7 +133,7 @@ def test_put_object_non_exist_bucket():
     """文件上传至不存在bucket"""
     try:
         response = client.put_object(
-            Bucket='test0xx',
+            Bucket='test0xx-1252448703',
             Body='T'*1024*1024,
             Key=test_object,
             CacheControl='no-cache',
@@ -164,7 +163,7 @@ def test_get_object_acl():
 
 def test_copy_object_diff_bucket():
     """从另外的bucket拷贝object"""
-    copy_source = {'Appid': '1252448703', 'Bucket': 'test04', 'Key': '/test.txt', 'Region': 'ap-beijing-1'}
+    copy_source = {'Bucket': 'test04-1252448703', 'Key': '/test.txt', 'Region': 'ap-beijing-1'}
     response = client.copy_object(
         Bucket=test_bucket,
         Key='test.txt',
@@ -256,7 +255,7 @@ def test_upload_part_copy():
     )
 
     # upload part copy
-    copy_source = {'Appid': '1252448703', 'Bucket': 'test04', 'Key': '/test.txt', 'Region': 'ap-beijing-1'}
+    copy_source = {'Bucket': 'test04-1252448703', 'Key': '/test.txt', 'Region': 'ap-beijing-1'}
     response = client.upload_part_copy(
         Bucket=test_bucket,
         Key='multipartfile.txt',
@@ -318,7 +317,7 @@ def test_delete_multiple_objects():
 def test_create_head_delete_bucket():
     """创建一个bucket,head它是否存在,最后删除一个空bucket"""
     bucket_id = str(random.randint(0, 1000)) + str(random.randint(0, 1000))
-    bucket_name = 'buckettest' + bucket_id
+    bucket_name = 'buckettest' + bucket_id + '-1252448703'
     response = client.create_bucket(
         Bucket=bucket_name,
         ACL='public-read'
@@ -564,7 +563,7 @@ def test_upload_file_multithreading():
 
 def test_copy_file_automatically():
     """根据拷贝源文件的大小自动选择拷贝策略，不同园区,小于5G直接copy_object，大于5G分块拷贝"""
-    copy_source = {'Appid': '1252448703', 'Bucket': 'testbucket', 'Key': '/thread_1MB', 'Region': 'ap-guangzhou'}
+    copy_source = {'Bucket': 'testtiedu-1252448703', 'Key': '/thread_1MB', 'Region': 'ap-guangzhou'}
     response = client.copy(
         Bucket=test_bucket,
         Key='copy_10G.txt',
@@ -590,9 +589,9 @@ def test_upload_empty_file():
 
 def test_copy_10G_file_in_same_region():
     """同园区的拷贝,应该直接用copy_object接口,可以直接秒传"""
-    copy_source = {'Appid': '1252448703', 'Bucket': 'test01', 'Key': '/10G.txt', 'Region': 'ap-beijing-1'}
+    copy_source = {'Bucket': 'test01-1252448703', 'Key': '/10G.txt', 'Region': 'ap-beijing-1'}
     response = client.copy(
-        Bucket='test04',
+        Bucket='test04-1252448703',
         Key='10G.txt',
         CopySource=copy_source,
         MAXThread=10