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)[源代码]

基类: threading.Thread

以特定间隔获取 Cloudwatch 日志事件，并将日志事件发送到 logger.info。

run()[源代码]

表示线程活动的的方法。

您可以在子类中覆盖此方法。标准的 run() 方法会调用传递给对象构造函数的、作为目标参数的可调用对象（如果有），并使用从 args 和 kwargs 参数中获取的顺序参数和关键字参数。

static event_to_str(event)[源代码]
get_last_log_messages(number_messages)[源代码]

在单个请求中获取最后日志消息。

注意：存在一些限制：- 如果日志太旧，则响应将为空 - 我们可检索的最大消息数受 cloudwatch 限制（10,000）约束。

get_last_log_message()[源代码]
is_stopped()[源代码]
stop()[源代码]

此条目是否有帮助？