`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)[源代码]¶

基类: 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()[源代码]¶

在子类中重写以返回正确的 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)[源代码]¶

基类: 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()[源代码]¶

在子类中重写以返回正确的 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)[源代码]¶

基类: 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()[源代码]¶

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

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

模块内容¶

类¶

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