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

類¶

輪詢查詢的狀態直到其達到最終狀態；如果查詢失敗，則此感測器失敗。

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

輪詢查詢的狀態直到其達到最終狀態；如果查詢失敗，則此感測器失敗。

另請參閱

有關如何使用此感測器的更多資訊，請參閱指南：等待 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

poke(context)[source]¶

派生此類的子類時重寫此方法。