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]¶