astronomer.providers.amazon.aws.hooks.base_aws
¶
Module Contents¶
Classes¶
Interacts with AWS using aiobotocore asynchronously. |
- class astronomer.providers.amazon.aws.hooks.base_aws.AwsBaseHookAsync(aws_conn_id=default_conn_name, verify=None, region_name=None, client_type=None, resource_type=None, config=None)[source]¶
Bases:
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.
- Parameters:
aws_conn_id (str | None) – 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).
verify (bool | str | None) – Whether or not to verify SSL certificates.
region_name (str | None) – AWS region_name. If not specified then the default boto3 behaviour is used.
client_type (str | None) – boto3.client client_type. Eg ‘s3’, ‘emr’ etc
resource_type (str | None) – boto3.resource resource_type. Eg ‘dynamodb’ etc
config (Config | None) – Configuration for botocore client.
See also