:py:mod:`astronomer.providers.amazon.aws.hooks.base_aws`
========================================================

.. py:module:: astronomer.providers.amazon.aws.hooks.base_aws


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.amazon.aws.hooks.base_aws.AwsBaseHookAsync




.. py:class:: AwsBaseHookAsync(aws_conn_id = default_conn_name, verify = None, region_name = None, client_type = None, resource_type = None, config = None)

   Bases: :py:obj:`airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook`

   Interacts with AWS using aiobotocore asynchronously.

   .. note::
       AwsBaseHookAsync uses aiobotocore to create asynchronous S3 hooks. Hence, AwsBaseHookAsync
       only supports the authentication mechanism that aiobotocore supports. The ability to assume
       roles provided in the Airflow connection extra args via aiobotocore is not supported by the
       library yet.

   :param aws_conn_id: The Airflow connection used for AWS credentials.
       If this is None or empty then the default boto3 behaviour is used. If
       running Airflow in a distributed manner and aws_conn_id is None or
       empty, then default boto3 configuration would be used (and must be
       maintained on each worker node).
   :param verify: Whether or not to verify SSL certificates.
   :param region_name: AWS region_name. If not specified then the default boto3 behaviour is used.
   :param client_type: boto3.client client_type. Eg 's3', 'emr' etc
   :param resource_type: boto3.resource resource_type. Eg 'dynamodb' etc
   :param config: Configuration for botocore client.

   .. seealso::

       `AWS API <https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html>`_

   .. py:method:: get_client_async()
      :async:

      Create an Async Client object to communicate with AWS services.