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

模块内容¶

类¶

OpenSearchServerlessCollectionActiveSensor

轮询集合的状态，直到它达到最终状态；如果查询失败，则失败。

class airflow.providers.amazon.aws.sensors.opensearch_serverless.OpenSearchServerlessCollectionActiveSensor(*, collection_id=None, collection_name=None, poke_interval=10, max_retries=60, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[源代码]¶

基类：airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.opensearch_serverless.OpenSearchServerlessHook]

轮询集合的状态，直到它达到最终状态；如果查询失败，则失败。

另请参阅

有关如何使用此传感器的更多信息，请查看指南：等待 Amazon OpenSearch Serverless 集合变为活动状态

参数

collection_id (str | None) – 集合 ID。您不能在同一请求中同时提供名称和 ID。
collection_name (str | None) – 集合名称。您不能在同一请求中同时提供名称和 ID。
deferrable (bool) – 如果为 True，则传感器将在可延迟模式下运行。此模式需要安装 aiobotocore 模块。（默认值：False，但可以通过在配置文件中将 default_deferrable 设置为 True 来覆盖）
poke_interval (int) – 轮询作业状态的间隔（以秒为单位）。（默认值：10）
max_retries (int) – 返回当前状态前的重试次数（默认值：60）
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此值为 None 或为空，则使用默认的 boto3 行为。如果在分布式方式下运行 Airflow 并且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个 worker 节点上维护）。
region_name – AWS region_name。如果未指定，则使用默认的 boto3 行为。
verify – 是否验证 SSL 证书。请参阅： https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客户端的配置字典（键值对）。请参阅： https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

INTERMEDIATE_STATES = ('CREATING',)[源代码]¶

FAILURE_STATES = ('DELETING', 'FAILED')[源代码]¶

SUCCESS_STATES = ('ACTIVE',)[源代码]¶

FAILURE_MESSAGE = 'OpenSearch Serverless 集合传感器失败'[源代码]¶

aws_hook_class[源代码]¶

template_fields: collections.abc.Sequence[str][源代码]¶

ui_color = '#66c3ff'[源代码]¶

poke(context, **kwargs)[源代码]¶

在派生此类时覆盖。

execute(context)[源代码]¶

在创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

airflow.providers.amazon.aws.sensors.opensearch_serverless¶

模块内容¶

类¶

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