`airflow.providers.amazon.aws.operators.rds`¶

模块内容¶

类¶

`RdsCreateDbSnapshotOperator`	创建数据库实例或数据库集群的快照。
`RdsCopyDbSnapshotOperator`	复制指定的数据库实例或数据库集群快照。
`RdsDeleteDbSnapshotOperator`	删除数据库实例或集群快照，或者终止复制操作。
`RdsStartExportTaskOperator`	开始将快照导出到 Amazon S3。提供的 IAM 角色必须有权访问 S3 存储桶。
`RdsCancelExportTaskOperator`	取消正在进行中的将快照导出到 Amazon S3 的导出任务。
`RdsCreateEventSubscriptionOperator`	创建 RDS 事件通知订阅。
`RdsDeleteEventSubscriptionOperator`	删除 RDS 事件通知订阅。
`RdsCreateDbInstanceOperator`	创建 RDS 数据库实例。
`RdsDeleteDbInstanceOperator`	删除 RDS 数据库实例。
`RdsStartDbOperator`	启动 RDS 数据库实例/集群。
`RdsStopDbOperator`	停止 RDS 数据库实例/集群。

class airflow.providers.amazon.aws.operators.rds.RdsCreateDbSnapshotOperator(*, db_type, db_identifier, db_snapshot_identifier, tags=None, wait_for_completion=True, **kwargs)[source]¶

基类: RdsBaseOperator

创建数据库实例或数据库集群的快照。

源数据库实例或集群必须处于可用或存储优化状态。

另请参阅

有关如何使用此运算符的更多信息，请查看指南：创建数据库快照

参数

db_type (str) – 数据库类型 - “instance” 或 “cluster”
db_identifier (str) – 要创建快照的实例或集群的标识符
db_snapshot_identifier (str) – 数据库快照的标识符
tags (collections.abc.Sequence[mypy_boto3_rds.type_defs.TagTypeDef] | dict | None) – 标签字典或格式为 [{“Key”: “...”, “Value”: “...”},] 的标签列表用户标记
wait_for_completion (bool) – 如果为 True，则等待数据库快照创建完成。（默认值：True）

template_fields = ('db_snapshot_identifier', 'db_identifier', 'tags')[源]¶

execute(context)[源]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsCopyDbSnapshotOperator(*, db_type, source_db_snapshot_identifier, target_db_snapshot_identifier, kms_key_id='', tags=None, copy_tags=False, pre_signed_url='', option_group_name='', target_custom_availability_zone='', source_region='', wait_for_completion=True, **kwargs)[源]¶

基类: RdsBaseOperator

复制指定的数据库实例或数据库集群快照。

另请参阅

有关如何使用此运算符的更多信息，请查看指南：复制数据库快照

参数

db_type (str) – 数据库类型 - “instance” 或 “cluster”
source_db_snapshot_identifier (str) – 源快照的标识符
target_db_snapshot_identifier (str) – 目标快照的标识符
kms_key_id (str) – 加密数据库快照的 AWS KMS 密钥标识符
tags (collections.abc.Sequence[mypy_boto3_rds.type_defs.TagTypeDef] | dict | None) – 标签字典或格式为 [{“Key”: “...”, “Value”: “...”},] 的标签列表用户标记
copy_tags (bool) – 是否将所有标签从源快照复制到目标快照（默认为 False）
pre_signed_url (str) – 包含签名版本 4 签名请求的 URL
option_group_name (str) – 要与快照副本关联的选项组的名称。仅当 db_type=’instance’ 时
target_custom_availability_zone (str) – 目标的外部自定义可用区标识符。仅当 db_type=’instance’ 时
source_region (str) – 包含要复制的快照的区域 ID
wait_for_completion (bool) – 如果为 True，则等待快照复制完成。（默认值：True）

template_fields = ('source_db_snapshot_identifier', 'target_db_snapshot_identifier', 'tags', 'pre_signed_url',...[源]¶

execute(context)[源]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsDeleteDbSnapshotOperator(*, db_type, db_snapshot_identifier, wait_for_completion=True, **kwargs)[源代码]¶

基类: RdsBaseOperator

删除数据库实例或集群快照，或者终止复制操作。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：删除数据库快照

参数

db_type (str) – 数据库类型 - “instance” 或 “cluster”
db_snapshot_identifier (str) – 数据库实例或数据库集群快照的标识符

template_fields = ('db_snapshot_identifier',)[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsStartExportTaskOperator(*, export_task_identifier, source_arn, s3_bucket_name, iam_role_arn, kms_key_id, s3_prefix='', export_only=None, wait_for_completion=True, waiter_interval=30, waiter_max_attempts=40, **kwargs)[源代码]¶

基类: RdsBaseOperator

开始将快照导出到 Amazon S3。提供的 IAM 角色必须有权访问 S3 存储桶。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：将 Amazon RDS 快照导出到 Amazon S3

参数

export_task_identifier (str) – 快照导出任务的唯一标识符。
source_arn (str) – 要导出到 Amazon S3 的快照的 Amazon 资源名称 (ARN)。
s3_bucket_name (str) – 要将快照导出到的 Amazon S3 存储桶的名称。
iam_role_arn (str) – 用于写入 Amazon S3 存储桶的 IAM 角色的名称。
kms_key_id (str) – 用于加密快照的 Amazon Web Services KMS 密钥的 ID。
s3_prefix (str) – 用作导出快照的文件名和路径的 Amazon S3 存储桶前缀。
export_only (list[str] | None) – 要从快照中导出的数据。
wait_for_completion (bool) – 如果为 True，则等待数据库快照导出完成。（默认：True）
waiter_interval (int) – 在检查导出状态之前等待的秒数。（默认：30）
waiter_max_attempts (int) – 在失败之前尝试的次数。（默认：40）

template_fields = ('export_task_identifier', 'source_arn', 's3_bucket_name', 'iam_role_arn', 'kms_key_id',...[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsCancelExportTaskOperator(*, export_task_identifier, wait_for_completion=True, check_interval=30, max_attempts=40, **kwargs)[源代码]¶

基类: RdsBaseOperator

取消正在进行中的将快照导出到 Amazon S3 的导出任务。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：取消 Amazon RDS 导出任务

参数

export_task_identifier (str) – 要取消的快照导出任务的标识符
wait_for_completion (bool) – 如果为 True，则等待数据库快照导出取消。（默认：True）
check_interval (int) – 尝试之间等待的时间（秒）
max_attempts (int) – 要尝试的最大次数

template_fields = ('export_task_identifier',)[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsCreateEventSubscriptionOperator(*, subscription_name, sns_topic_arn, source_type='', event_categories=None, source_ids=None, enabled=True, tags=None, wait_for_completion=True, **kwargs)[源代码]¶

基类: RdsBaseOperator

创建 RDS 事件通知订阅。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：订阅 Amazon RDS 事件通知

参数

subscription_name (str) – 订阅的名称（必须少于 255 个字符）
sns_topic_arn (str) – 为事件通知创建的 SNS 主题的 ARN
source_type (str) – 生成事件的源的类型。有效值：db-instance | db-cluster | db-parameter-group | db-security-group | db-snapshot | db-cluster-snapshot | db-proxy
event_categories (collections.abc.Sequence[str] | None) – 您要订阅的源类型的事件类别列表用户事件
source_ids (collections.abc.Sequence[str] | None) – 返回事件的事件源的标识符列表
enabled (bool) – 一个值，指示是否激活订阅（默认为 True）
tags (collections.abc.Sequence[mypy_boto3_rds.type_defs.TagTypeDef] | dict | None) – 标签字典或格式为 [{“Key”: “...”, “Value”: “...”},] 的标签列表用户标记
wait_for_completion (bool) – 如果为 True，则等待订阅创建完成。(默认值: True)

template_fields = ('subscription_name', 'sns_topic_arn', 'source_type', 'event_categories', 'source_ids', 'tags')[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsDeleteEventSubscriptionOperator(*, subscription_name, **kwargs)[源代码]¶

基类: RdsBaseOperator

删除 RDS 事件通知订阅。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：取消订阅 Amazon RDS 事件通知

参数: subscription_name (str) – 您要删除的 RDS 事件通知订阅的名称

template_fields = ('subscription_name',)[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

class airflow.providers.amazon.aws.operators.rds.RdsCreateDbInstanceOperator(*, db_instance_identifier, db_instance_class, engine, rds_kwargs=None, wait_for_completion=True, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), waiter_delay=30, waiter_max_attempts=60, **kwargs)[源代码]¶

基类: RdsBaseOperator

创建 RDS 数据库实例。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：创建数据库实例

参数

db_instance_identifier (str) – 数据库实例标识符，必须以字母开头，并包含 1 到 63 个字母、数字或连字符
db_instance_class (str) – 数据库实例的计算和内存容量，例如 db.m5.large
engine (str) – 要用于此实例的数据库引擎的名称
rds_kwargs (dict | None) – 传递给 boto3 RDS 客户端函数 create_db_instance 的命名参数 https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/rds.html#RDS.Client.create_db_instance
wait_for_completion (bool) – 如果为 True，则等待数据库实例创建完成。（默认值：True）
waiter_delay (int) – 两次连续调用以检查数据库实例状态之间等待的时间（以秒为单位）
waiter_max_attempts (int) – 检查数据库实例状态的最大尝试次数
deferrable (bool) – 如果为 True，操作符将异步等待数据库实例创建完成。这意味着等待完成。此模式需要安装 aiobotocore 模块。(默认值: False)

template_fields = ('db_instance_identifier', 'db_instance_class', 'engine', 'rds_kwargs')[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

execute_complete(context, event=None)[源代码]¶

class airflow.providers.amazon.aws.operators.rds.RdsDeleteDbInstanceOperator(*, db_instance_identifier, rds_kwargs=None, wait_for_completion=True, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), waiter_delay=30, waiter_max_attempts=60, **kwargs)[源代码]¶

基类: RdsBaseOperator

删除 RDS 数据库实例。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：删除数据库实例

参数

db_instance_identifier (str) – 要删除的数据库实例的数据库实例标识符
rds_kwargs (dict | None) – 传递给 boto3 RDS 客户端函数 delete_db_instance 的命名参数 https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/rds.html#RDS.Client.delete_db_instance
wait_for_completion (bool) – 如果为 True，则等待数据库实例删除完成。（默认值：True）
waiter_delay (int) – 两次连续调用以检查数据库实例状态之间等待的时间（以秒为单位）
waiter_max_attempts (int) – 检查数据库实例状态的最大尝试次数
deferrable (bool) – 如果为 True，操作符将异步等待数据库实例创建完成。这意味着等待完成。此模式需要安装 aiobotocore 模块。(默认值: False)

template_fields = ('db_instance_identifier', 'rds_kwargs')[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

execute_complete(context, event=None)[源代码]¶

class airflow.providers.amazon.aws.operators.rds.RdsStartDbOperator(*, db_identifier, db_type=RdsDbType.INSTANCE, wait_for_completion=True, waiter_delay=30, waiter_max_attempts=40, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶

基类: RdsBaseOperator

启动 RDS 数据库实例/集群。

另请参阅

有关如何使用此操作符的更多信息，请查看以下指南：启动数据库实例或集群

参数

db_identifier (str) – 要启动的数据库的 AWS 标识符
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型 - “instance” 或 “cluster”（默认值：“instance”）
wait_for_completion (bool) – 如果为 True，则等待数据库启动。（默认值：True）
waiter_delay (int) – 两次连续调用以检查数据库实例状态之间等待的时间（以秒为单位）
waiter_max_attempts (int) – 检查数据库实例状态的最大尝试次数
deferrable (bool) – 如果为 True，操作符将异步等待数据库实例被创建。这意味着等待完成。此模式需要安装 aiobotocore 模块。

template_fields = ('db_identifier', 'db_type')[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

execute_complete(context, event=None)[源代码]¶

class airflow.providers.amazon.aws.operators.rds.RdsStopDbOperator(*, db_identifier, db_type=RdsDbType.INSTANCE, db_snapshot_identifier=None, wait_for_completion=True, waiter_delay=30, waiter_max_attempts=40, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶

基类: RdsBaseOperator

停止 RDS 数据库实例/集群。

另请参阅

有关如何使用此操作符的更多信息，请查看以下指南：停止数据库实例或集群

参数

db_identifier (str) – 要停止的数据库的 AWS 标识符
db_type (airflow.providers.amazon.aws.utils.rds.RdsDbType | str) – 数据库类型 - “instance” 或 “cluster”（默认值：“instance”）
db_snapshot_identifier (str | None) – 要在停止数据库实例之前创建的数据库快照的实例标识符。默认值 (None) 跳过快照创建。当 db_type 为 “cluster” 时，将忽略此参数
wait_for_completion (bool) – 如果为 True，则等待数据库停止。（默认值：True）
waiter_delay (int) – 两次连续调用以检查数据库实例状态之间等待的时间（以秒为单位）
waiter_max_attempts (int) – 检查数据库实例状态的最大尝试次数
deferrable (bool) – 如果为 True，操作符将异步等待数据库实例被创建。这意味着等待完成。此模式需要安装 aiobotocore 模块。

template_fields = ('db_identifier', 'db_snapshot_identifier', 'db_type')[源代码]¶

execute(context)[源代码]¶

快照、任务和事件的不同实现。

execute_complete(context, event=None)[源代码]¶

airflow.providers.amazon.aws.operators.rds¶

模块内容¶

类¶

`airflow.providers.amazon.aws.operators.rds`¶