airflow.providers.amazon.aws.triggers.rds

Module Contents

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.
class airflow.providers.amazon.aws.triggers.rds.RdsDbAvailableTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=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.

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.rds.RdsDbDeletedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=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.

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.rds.RdsDbStoppedTrigger(db_identifier, waiter_delay, waiter_max_attempts, aws_conn_id, response, db_type, region_name=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.

hook()[source]

Override in subclasses to return the right hook.

Was this entry helpful?