: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. Currently, AwsBaseHookAsync supports only AWS STS client method ``assume_role`` provided in the Airflow connection extra args via aiobotocore. :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 `_ .. py:method:: get_client_async() :async: Create an Async Client object to communicate with AWS services. .. py:method:: get_role_credentials(async_session, conn_config) :staticmethod: :async: Get the role_arn, method credentials from connection details and get the role credentials detail