Merge pull request #252 from bernieyangmh/example_move_to

add delete_after_days

Author: longbai

examples/delete_afte_days.py

@@ -0,0 +1,26 @@
+# -*- coding: utf-8 -*-
+# flake8: noqa
+
+from qiniu import Auth
+from qiniu import BucketManager
+
+access_key = '...'
+secret_key = '...'
+
+#初始化Auth状态
+q = Auth(access_key, secret_key)
+
+#初始化BucketManager
+bucket = BucketManager(q)
+
+#你要测试的空间， 并且这个key在你空间中存在
+bucket_name = 'Bucket_Name'
+key = 'python-test.png'
+
+#您要更新的生命周期
+days = '5'
+
+ret, info = bucket.delete_after_days(bucket_name, key, days)
+print(info)
+
+

examples/move_to.py

@@ -19,6 +19,6 @@
 #将文件从文件key 移动到文件key2，可以实现文件的重命名 可以在不同bucket移动
 key2 = 'python-logo2.png'
 
-ret, info = bucket.move(bucket_name, key, bucket, key2)
+ret, info = bucket.move(bucket_name, key, bucket_name, key2)
 print(info)
 assert ret == {}

qiniu/services/storage/bucket.py

@@ -246,6 +246,28 @@ def buckets(self):
         """
         return self.__rs_do('buckets')
 
+    def delete_after_days(self, bucket, key, days):
+        """更新文件生命周期
+
+        Returns:
+            一个dict变量，返回结果类似：
+                [
+                    { "code": <HttpCode int>, "data": <Data> },
+                    { "code": <HttpCode int> },
+                    { "code": <HttpCode int> },
+                    { "code": <HttpCode int> },
+                    { "code": <HttpCode int>, "data": { "error": "<ErrorMessage string>" } },
+                    ...
+                ]
+            一个ResponseInfo对象
+        Args:
+            bucket: 目标资源空间
+            key:    目标资源文件名
+            days:   指定天数
+        """
+        resource = entry(bucket, key)
+        return self.__rs_do('deleteAfterDays', resource, days)
+
     def __rs_do(self, operation, *args):
         return self.__server_do(config.get_default('default_rs_host'), operation, *args)
 

test_qiniu.py

@@ -264,6 +264,15 @@ def test_batch_stat(self):
         print(info)
         assert ret[0]['code'] == 200
 
+    def test_delete_after_days(self):
+        days = '5'
+        ret, info = self.bucket.delete_after_days(bucket_name,'invaild.html', days)
+        assert info.status_code == 612
+        key = 'copyto'+rand_string(8)
+        ret, info = self.bucket.copy(bucket_name, 'copyfrom', bucket_name, key)
+        ret, info = self.bucket.delete_after_days(bucket_name, key, days)
+        assert info.status_code == 200
+
 
 class UploaderTestCase(unittest.TestCase):