airflow.providers.amazon.aws.hooks.mwaa

This module contains AWS MWAA hook.

Classes

MwaaHook

Interact with AWS Manager Workflows for Apache Airflow.

Module Contents

class airflow.providers.amazon.aws.hooks.mwaa.MwaaHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Interact with AWS Manager Workflows for Apache Airflow.

Provide thin wrapper around boto3.client("mwaa")

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

invoke_rest_api(env_name, path, method, body=None, query_params=None)[source]

Invoke the REST API on the Airflow webserver with the specified inputs.

See also

Parameters:

  • env_name (str) – name of the MWAA environment

  • path (str) – Apache Airflow REST API endpoint path to be called

  • method (str) – HTTP method used for making Airflow REST API calls

  • body (dict | None) – Request body for the Apache Airflow REST API call

  • query_params (dict | None) – Query parameters to be included in the Apache Airflow REST API call

Was this entry helpful?