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

模块内容¶

类¶

OpenSearchServerlessCollectionActiveTrigger

当 Amazon OpenSearch Serverless 集合达到 ACTIVE 状态时触发。

class airflow.providers.amazon.aws.triggers.opensearch_serverless.OpenSearchServerlessCollectionActiveTrigger(*, collection_id=None, collection_name=None, waiter_delay=60, waiter_max_attempts=20, aws_conn_id=None)[来源]¶

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

当 Amazon OpenSearch Serverless 集合达到 ACTIVE 状态时触发。

参数

collection_id (str | None) – 集合 ID。您不能在同一请求中同时提供名称和 ID。
collection_name (str | None) – 集合名称。您不能在同一请求中同时提供名称和 ID。
waiter_delay (int) – 两次尝试之间等待的秒数。（默认值：60）
waiter_max_attempts (int) – 要尝试的最大次数。（默认值：20）
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。

hook()[来源]¶

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

airflow.providers.amazon.aws.triggers.opensearch_serverless¶

模块内容¶

类¶

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