airflow.providers.amazon.aws.sensors.athena

类

AthenaSensor

轮询查询的状态直到其达到最终状态；如果查询失败，则此传感器失败。

模块内容

class airflow.providers.amazon.aws.sensors.athena.AthenaSensor(*, query_execution_id, max_retries=None, sleep_time=10, **kwargs)[source]

继承自: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.athena.AthenaHook]

轮询查询的状态直到其达到最终状态；如果查询失败，则此传感器失败。

另请参阅

有关如何使用此传感器的更多信息，请参阅指南： 等待 Amazon Athena 查询结果

参数:

  • query_execution_id (str) – 要检查状态的 query_execution_id

  • max_retries (int | None) – 在返回当前状态之前轮询查询状态的次数，默认为 None

  • sleep_time (int) – 两次连续检查 Athena 查询状态调用的间隔时间（秒），默认为 10

  • aws_conn_id – 用于 AWS 凭据的 Airflow 连接。如果此值为 None 或为空，则使用默认的 boto3 行为。如果在分布式环境中运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（且必须在每个工作节点上维护）。

  • 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 = ('QUEUED', 'RUNNING')[source]
FAILURE_STATES = ('FAILED', 'CANCELLED')[source]
SUCCESS_STATES = ('SUCCEEDED',)[source]
aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
ui_color = '#66c3ff'[source]
query_execution_id[source]
sleep_time = 10[source]
max_retries = None[source]
poke(context)[source]

派生此类的子类时重写此方法。

此条目是否有帮助？