add async client

alibabacloud_oss_v2/_client.py

@@ -20,7 +20,7 @@
 from .types import (
     Retryer,
     CredentialsProvider,
-    HttpClient,
+    HttpClient, AsyncHttpClient,
     HttpRequest,
     HttpResponse,
     SigningContext,
@@ -100,7 +100,7 @@ def __init__(
         retryer: Optional[Retryer] = None,
         signer: Optional[Signer] = None,
         credentials_provider: Optional[CredentialsProvider] = None,
-        http_client: Optional[Union[HttpClient]] = None,
+        http_client: Optional[Union[HttpClient, AsyncHttpClient]] = None,
         address_style: Optional[AddressStyle] = None,
         readwrite_timeout: Optional[Union[int, float]] = None,
         response_handlers: Optional[List] = None,
@@ -211,7 +211,7 @@ def verify_operation(self, op_input: OperationInput, options: _Options) -> None:
     def apply_operation(self, options: _Options, op_input: OperationInput) -> None:
         """apply operation"""
         self._apply_operation_options(options) # pylint: disable=no-member
-        _apply_operation_metadata(op_input, options)
+        self._apply_operation_metadata(op_input, options)
 
 
     def build_request_context(self, op_input: OperationInput, options: _Options, inner: _InnerOptions
@@ -377,6 +377,15 @@ def service_error_response_handler(response: HttpResponse) -> None:
 
         options.response_handlers = handlers
 
+    def _apply_operation_metadata(self, op_input: OperationInput, options: _Options) -> None:
+        handlers = op_input.op_metadata.get('opm-response-handler', None)
+        if handlers is not None:
+            options.response_handlers.extend(handlers)
+
+        stream = op_input.op_metadata.get('response-stream', None)
+        if stream is not None:
+            options.response_stream = stream
+
     def _sent_request(self, op_input: OperationInput, options: _Options) -> OperationOutput:
         context = self.build_request_context(op_input, options, self._inner)
         response = self._sent_http_request(context, options)
@@ -592,15 +601,6 @@ def _resolve_cloud_box(config: Config, options: _Options) -> None:
     options.product = defaults.CLOUD_BOX_PRODUCT
 
 
-def _apply_operation_metadata(op_input: OperationInput, options: _Options) -> None:
-    handlers = op_input.op_metadata.get('opm-response-handler', None)
-    if handlers is not None:
-        options.response_handlers.extend(handlers)
-
-    stream = op_input.op_metadata.get('response-stream', None)
-    if stream is not None:
-        options.response_stream = stream
-
 
 def _build_url(op_input: OperationInput, options: _Options) -> str:
     host = ""

alibabacloud_oss_v2/aio/__init__.py

@@ -0,0 +1 @@
+from .client import AsyncClient