airflow.providers.amazon.aws.triggers.rds¶

Classes¶

`RdsDbAvailableTrigger`	Trigger to wait asynchronously for a DB instance or cluster to be available.
`RdsDbDeletedTrigger`	Trigger to wait asynchronously for a DB instance or cluster to be deleted.
`RdsDbStoppedTrigger`	Trigger to wait asynchronously for a DB instance or cluster to be stopped.

Module Contents¶

class airflow.providers.amazon.aws.triggers.rds.RdsDbAvailableTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None, verify=None, botocore_config=None)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger to wait asynchronously for a DB instance or cluster to be available.

Parameters:

db_identifier (str) – The DB identifier for the DB instance or cluster to be polled.
waiter_delay (int) – The amount of time in seconds to wait between attempts.
waiter_max_attempts (int) – The maximum number of attempts to be made.
aws_conn_id (str | None) – The Airflow connection used for AWS credentials.
region_name (str | None) – AWS region where the DB is located, if different from the default one.
response (dict[str, Any]) – The response from the RdsHook, to be passed back to the operator.
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – The type of DB: instance or cluster.
verify (bool | str | None) – Whether or not to verify SSL certificates. See: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config (dict | None) – Configuration dictionary (key-values) for botocore client. See: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[source]¶

class airflow.providers.amazon.aws.triggers.rds.RdsDbDeletedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None, verify=None, botocore_config=None)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger to wait asynchronously for a DB instance or cluster to be deleted.

Parameters:

db_identifier (str) – The DB identifier for the DB instance or cluster to be polled.
waiter_delay (int) – The amount of time in seconds to wait between attempts.
waiter_max_attempts (int) – The maximum number of attempts to be made.
aws_conn_id (str | None) – The Airflow connection used for AWS credentials.
region_name (str | None) – AWS region where the DB is located, if different from the default one.
response (dict[str, Any]) – The response from the RdsHook, to be passed back to the operator.
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – The type of DB: instance or cluster.
verify (bool | str | None) – Whether or not to verify SSL certificates. See: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config (dict | None) – Configuration dictionary (key-values) for botocore client. See: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[source]¶

class airflow.providers.amazon.aws.triggers.rds.RdsDbStoppedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=None, verify=None, botocore_config=None)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger to wait asynchronously for a DB instance or cluster to be stopped.

Parameters:

db_identifier (str) – The DB identifier for the DB instance or cluster to be polled.
waiter_delay (int) – The amount of time in seconds to wait between attempts.
waiter_max_attempts (int) – The maximum number of attempts to be made.
aws_conn_id (str | None) – The Airflow connection used for AWS credentials.
region_name (str | None) – AWS region where the DB is located, if different from the default one.
response (dict[str, Any]) – The response from the RdsHook, to be passed back to the operator.
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – The type of DB: instance or cluster.
verify (bool | str | None) – Whether or not to verify SSL certificates. See: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config (dict | None) – Configuration dictionary (key-values) for botocore client. See: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[source]¶