`airflow.providers.amazon.aws.hooks.neptune`¶

模块内容¶

类¶

与 Amazon Neptune 交互。

class airflow.providers.amazon.aws.hooks.neptune.NeptuneHook(*args, **kwargs)[源代码]¶

基类：airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Neptune 交互。

可以指定其他参数（例如 aws_conn_id），并将其传递给底层 AwsBaseHook。

另请参阅

AwsBaseHook

AVAILABLE_STATES = ['available'][源代码]¶

STOPPED_STATES = ['stopped'][源代码]¶

ERROR_STATES = ['cloning-failed', 'inaccessible-encryption-credentials',...[源代码]¶

wait_for_cluster_availability(cluster_id, delay=30, max_attempts=60)[源代码]¶

等待 Neptune 集群启动。

参数

cluster_id (str) – 要等待的集群的 ID。
delay (int) – 轮询之间延迟的秒数。
max_attempts (int) – 轮询完成的最大尝试次数。

返回

集群的状态。

返回类型

wait_for_cluster_stopped(cluster_id, delay=30, max_attempts=60)[源代码]¶

等待 Neptune 集群停止。

参数

cluster_id (str) – 要等待的集群的 ID。
delay (int) – 轮询之间延迟的秒数。
max_attempts (int) – 轮询完成的最大尝试次数。

返回

集群的状态。

返回类型

get_cluster_status(cluster_id)[源代码]¶

获取 Neptune 集群的状态。

参数: cluster_id (str) – 要获取状态的集群的 ID。
返回: 集群的状态。
返回类型: str

get_db_instance_status(instance_id)[源代码]¶

获取 Neptune 实例的状态。

参数: instance_id (str) – 要获取状态的实例的 ID。
返回: 实例的状态。
返回类型: str

wait_for_cluster_instance_availability(cluster_id, delay=30, max_attempts=60)[源代码]¶

等待集群中的 Neptune 实例变为可用。

参数

cluster_id (str) – 要等待的实例的集群 ID。
delay (int) – 轮询之间延迟的秒数。
max_attempts (int) – 轮询完成的最大尝试次数。

返回

实例的状态。

返回类型

无

此条目是否有帮助？