airflow.providers.amazon.aws.triggers.neptune¶

类¶

`NeptuneClusterAvailableTrigger`	当 Neptune 集群可用时触发。
`NeptuneClusterStoppedTrigger`	当 Neptune 集群停止时触发。
`NeptuneClusterInstancesAvailableTrigger`	当 Neptune 集群实例可用时触发。

模块内容¶

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterAvailableTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

当 Neptune 集群可用时触发。

参数:

db_cluster_id (str) – 要轮询的集群 ID。
waiter_delay (int) – 尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – AWS 区域名称（例如：us-east-1）

hook()[source]¶

在子类中重写以返回正确的 hook。

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterStoppedTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

当 Neptune 集群停止时触发。

参数:

db_cluster_id (str) – 要轮询的集群 ID。
waiter_delay (int) – 尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – AWS 区域名称（例如：us-east-1）

hook()[source]¶

在子类中重写以返回正确的 hook。

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterInstancesAvailableTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

当 Neptune 集群实例可用时触发。

参数:

db_cluster_id (str) – 要等待实例的集群 ID
waiter_delay (int) – 尝试之间的等待时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。
region_name (str | None) – AWS 区域名称（例如：us-east-1）

hook()[source]¶

在子类中重写以返回正确的 hook。