airflow.providers.amazon.aws.utils.task_log_fetcher¶

類¶

AwsTaskLogFetcher

以特定間隔獲取 Cloudwatch 日誌事件，並將日誌事件傳送到 logger.info。

模組內容¶

class airflow.providers.amazon.aws.utils.task_log_fetcher.AwsTaskLogFetcher(*, log_group, log_stream_name, fetch_interval, logger, aws_conn_id='aws_default', region_name=None)[source]¶

基類: threading.Thread

以特定間隔獲取 Cloudwatch 日誌事件，並將日誌事件傳送到 logger.info。

fetch_interval[source]¶

logger[source]¶

log_group[source]¶

log_stream_name[source]¶

hook[source]¶

run()[source]¶

表示執行緒活動的方法。

您可以在子類中重寫此方法。標準的 run() 方法會呼叫傳遞給物件構造器的可呼叫物件（作為 target 引數，如果存在），使用分別來自 args 和 kwargs 引數的順序引數和關鍵字引數。

static event_to_str(event)[source]¶

get_last_log_messages(number_messages)[source]¶

在一次請求中獲取最新的日誌訊息。

注意：存在一些限制： - 如果日誌太舊，響應將為空 - 可檢索的最大訊息數量受 cloudwatch 限制（10,000）。

get_last_log_message()[source]¶

is_stopped()[source]¶

stop()[source]¶