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

模块内容¶

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

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

基类： 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) – 在两次连续调用以检查雅典娜的查询状态之间等待的时间（秒），默认为 10
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此值为 None 或为空，则使用默认的 boto3 行为。如果在分布式方式下运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。
region_name – AWS 区域名称。如果未指定，则使用默认的 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

poke(context)[源代码]¶

在派生此类时重写。