airflow.providers.amazon.aws.operators.neptune¶
模块内容¶
类¶
启动 Amazon Neptune 数据库集群。 |
|
停止 Amazon Neptune 数据库集群。 |
函数¶
|
处理因集群或实例状态无效而产生的临时客户端异常。 |
- airflow.providers.amazon.aws.operators.neptune.handle_waitable_exception(operator, err)[源代码]¶
处理因集群或实例状态无效而产生的临时客户端异常。
状态更改后，可以重试。 等待器将处理最终状态。
- class airflow.providers.amazon.aws.operators.neptune.NeptuneStartDbClusterOperator(db_cluster_id, wait_for_completion=True, waiter_delay=30, waiter_max_attempts=60, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶
基类:
airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.neptune.NeptuneHook]启动 Amazon Neptune 数据库集群。
Amazon Neptune 数据库是一种专为卓越的可扩展性和可用性而设计的无服务器图数据库。 Neptune 数据库提供内置安全性、连续备份以及与其他 AWS 服务的集成
另请参阅
有关如何使用此操作符的更多信息，请查看指南： 启动 Neptune 数据库集群
- 参数
db_cluster_id (str) – 要启动的 Neptune 数据库集群的数据库集群标识符。
wait_for_completion (bool) – 是否等待集群启动。（默认值：True）
deferrable (bool) – 如果为 True，则操作符将异步等待集群启动。 这意味着等待完成。 此模式需要安装 aiobotocore 模块。（默认值：False）
waiter_delay (int) – 状态检查之间等待的时间（以秒为单位）。
waiter_max_attempts (int) – 检查作业完成情况的最大尝试次数。
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。 如果此项为
None或为空，则使用默认的 boto3 行为。 如果以分布式方式运行 Airflow 并且 aws_conn_id 为 None 或空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。region_name – AWS 区域名称。 如果未指定，则使用默认的 boto3 行为。
botocore_config – botocore 客户端的配置字典（键值对）。 请参阅：https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html
- 返回
带有 Neptune 集群 ID 的字典
- template_fields: collections.abc.Sequence[str][源代码]¶
- class airflow.providers.amazon.aws.operators.neptune.NeptuneStopDbClusterOperator(db_cluster_id, wait_for_completion=True, waiter_delay=30, waiter_max_attempts=60, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶
基类:
airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.neptune.NeptuneHook]停止 Amazon Neptune 数据库集群。
Amazon Neptune 数据库是一种专为卓越的可扩展性和可用性而设计的无服务器图数据库。 Neptune 数据库提供内置安全性、连续备份以及与其他 AWS 服务的集成
另请参阅
有关如何使用此操作符的更多信息，请查看指南： 启动 Neptune 数据库集群
- 参数
db_cluster_id (str) – 要停止的 Neptune 数据库集群的数据库集群标识符。
wait_for_completion (bool) – 是否等待集群停止。（默认值：True）
deferrable (bool) – 如果为 True，则操作符将异步等待集群停止。 这意味着等待完成。 此模式需要安装 aiobotocore 模块。（默认值：False）
waiter_delay (int) – 状态检查之间等待的时间（以秒为单位）。
waiter_max_attempts (int) – 检查作业完成情况的最大尝试次数。
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。 如果此项为
None或为空，则使用默认的 boto3 行为。 如果以分布式方式运行 Airflow 并且 aws_conn_id 为 None 或空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。region_name – AWS 区域名称。 如果未指定，则使用默认的 boto3 行为。
botocore_config – botocore 客户端的配置字典（键值对）。 请参阅：https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html
- 返回
带有 Neptune 集群 ID 的字典
- template_fields: collections.abc.Sequence[str][源代码]¶