add bucket policy

Author: zhuxiaolong37

alibabacloud_oss_v2/__init__.py

@@ -22,6 +22,7 @@
 from .models.bucket_cname import *
 from .models.bucket_lifecycle import *
 from .models.bucket_cors import *
+from .models.bucket_policy import *
 from .models.bucket_encryption import *
 from .models.bucket_logging import *
 

alibabacloud_oss_v2/client.py

@@ -1226,6 +1226,62 @@ def option_object(self, request: models.OptionObjectRequest, **kwargs
         return operations.option_object(self._client, request, **kwargs)
 
 
+    # bucket policy
+    def put_bucket_policy(self, request: models.PutBucketPolicyRequest, **kwargs
+                          ) -> models.PutBucketPolicyResult:
+        """
+        Configures a policy for a bucket.
+
+        Args:
+            request (PutBucketPolicyRequest): Request parameters for PutBucketPolicy operation.
+
+        Returns:
+            PutBucketPolicyResult: Response result for PutBucketPolicy operation.
+        """
+        return operations.put_bucket_policy(self._client, request, **kwargs)
+
+    def get_bucket_policy(self, request: models.GetBucketPolicyRequest, **kwargs
+                          ) -> models.GetBucketPolicyResult:
+        """
+        Queries the policies configured for a bucket.
+
+        Args:
+            request (GetBucketPolicyRequest): Request parameters for GetBucketPolicy operation.
+
+        Returns:
+            GetBucketPolicyResult: Response result for GetBucketPolicy operation.
+        """
+        return operations.get_bucket_policy(self._client, request, **kwargs)
+
+
+    def delete_bucket_policy(self, request: models.DeleteBucketPolicyRequest, **kwargs
+                             ) -> models.DeleteBucketPolicyResult:
+        """
+        Deletes a policy for a bucket.
+
+        Args:
+            request (DeleteBucketPolicyRequest): Request parameters for DeleteBucketPolicy operation.
+
+        Returns:
+            DeleteBucketPolicyResult: Response result for DeleteBucketPolicy operation.
+        """
+        return operations.delete_bucket_policy(self._client, request, **kwargs)
+
+
+    def get_bucket_policy_status(self, request: models.GetBucketPolicyStatusRequest, **kwargs
+                                 ) -> models.GetBucketPolicyStatusResult:
+        """
+        Checks whether the current bucket policy allows public access.
+
+        Args:
+            request (GetBucketPolicyStatusRequest): Request parameters for GetBucketPolicyStatus operation.
+
+        Returns:
+            GetBucketPolicyStatusResult: Response result for GetBucketPolicyStatus operation.
+        """
+        return operations.get_bucket_policy_status(self._client, request, **kwargs)
+
+
     # bucket logging
     def put_bucket_logging(self, request: models.PutBucketLoggingRequest, **kwargs
                            ) -> models.PutBucketLoggingResult:

alibabacloud_oss_v2/models/__init__.py

@@ -10,5 +10,6 @@
 from .bucket_cname import *
 from .bucket_lifecycle import *
 from .bucket_cors import *
+from .bucket_policy import *
 from .bucket_logging import *
 from .bucket_encryption import *

alibabacloud_oss_v2/models/bucket_policy.py

@@ -0,0 +1,172 @@
+from typing import Optional, List, Any, Union
+from .. import serde
+
+
+class PolicyStatus(serde.Model):
+    """
+    The container that stores public access information.
+    """
+
+    _attribute_map = { 
+        'is_public': {'tag': 'xml', 'rename': 'IsPublic', 'type': 'bool'},
+    }
+
+    _xml_map = {
+        'name': 'PolicyStatus'
+    }
+
+    def __init__(
+        self,
+        is_public: Optional[bool] = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        is_public (bool, optional): Indicates whether the current bucket policy allows public access.truefalse
+        """
+        super().__init__(**kwargs)
+        self.is_public = is_public
+
+
+
+
+class PutBucketPolicyRequest(serde.RequestModel):
+    """
+    The request for the PutBucketPolicy operation.
+    """
+
+    _attribute_map = { 
+        'bucket': {'tag': 'input', 'position': 'host', 'rename': 'bucket', 'type': 'str', 'required': True},
+        'body': {'tag': 'input', 'position': 'body', 'rename': 'nop', 'type': 'str', 'required': True},
+    }
+
+    def __init__(
+        self,
+        bucket: str = None,
+        body: Optional[str] = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        bucket (str, required): The name of the bucket.
+        body (str, required): The request parameters.
+        """
+        super().__init__(**kwargs)
+        self.bucket = bucket
+        self.body = body
+
+
+class PutBucketPolicyResult(serde.ResultModel):
+    """
+    The request for the PutBucketPolicy operation.
+    """
+
+class GetBucketPolicyRequest(serde.RequestModel):
+    """
+    The request for the GetBucketPolicy operation.
+    """
+
+    _attribute_map = { 
+        'bucket': {'tag': 'input', 'position': 'host', 'rename': 'bucket', 'type': 'str', 'required': True},
+    }
+
+    def __init__(
+        self,
+        bucket: str = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        bucket (str, required): The name of the bucket.
+        """
+        super().__init__(**kwargs)
+        self.bucket = bucket
+
+
+class GetBucketPolicyResult(serde.ResultModel):
+    """
+    The request for the GetBucketPolicy operation.
+    """
+
+    _attribute_map = { 
+        'body': {'tag': 'output', 'position': 'body', 'type': 'str'},
+    }
+
+    def __init__(
+        self,
+        body: Optional[str] = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        body (io.ReadCloser, optional): <no value>
+        """
+        super().__init__(**kwargs)
+        self.body = body
+
+class DeleteBucketPolicyRequest(serde.RequestModel):
+    """
+    The request for the DeleteBucketPolicy operation.
+    """
+
+    _attribute_map = { 
+        'bucket': {'tag': 'input', 'position': 'host', 'rename': 'bucket', 'type': 'str', 'required': True},
+    }
+
+    def __init__(
+        self,
+        bucket: str = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        bucket (str, required): The name of the bucket.
+        """
+        super().__init__(**kwargs)
+        self.bucket = bucket
+
+
+class DeleteBucketPolicyResult(serde.ResultModel):
+    """
+    The request for the DeleteBucketPolicy operation.
+    """
+
+class GetBucketPolicyStatusRequest(serde.RequestModel):
+    """
+    The request for the GetBucketPolicyStatus operation.
+    """
+
+    _attribute_map = { 
+        'bucket': {'tag': 'input', 'position': 'host', 'rename': 'bucket', 'type': 'str'},
+    }
+
+    def __init__(
+        self,
+        bucket: Optional[str] = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        bucket (str, optional): The name of the bucket.
+        """
+        super().__init__(**kwargs)
+        self.bucket = bucket
+
+
+class GetBucketPolicyStatusResult(serde.ResultModel):
+    """
+    The request for the GetBucketPolicyStatus operation.
+    """
+
+    _attribute_map = { 
+        'policy_status': {'tag': 'output', 'position': 'body', 'rename': 'PolicyStatus', 'type': 'PolicyStatus,xml'},
+    }
+
+    _dependency_map = { 
+        'PolicyStatus': {'new': lambda: PolicyStatus()},
+    }
+
+    def __init__(
+        self,
+        policy_status: Optional[PolicyStatus] = None,
+        **kwargs: Any
+    ) -> None:
+        """
+        policy_status (PolicyStatus, optional): The container that stores public access information.
+        """
+        super().__init__(**kwargs)
+        self.policy_status = policy_status

alibabacloud_oss_v2/operations/__init__.py

@@ -7,6 +7,8 @@
 from .bucket_access_monitor import *
 from .bucket_archive_direct_read import *
 from .bucket_cname import *
+from .bucket_cors import *
+from .bucket_policy import *
 from .bucket_lifecycle import *
 from .bucket_cors import *
 from .bucket_logging import *