airflow.providers.amazon.aws.hooks.logs

模块内容

类

AwsLogsHook

与 Amazon CloudWatch Logs 交互。

属性

NUM_CONSECUTIVE_EMPTY_RESPONSE_EXIT_THRESHOLD

airflow.providers.amazon.aws.hooks.logs.NUM_CONSECUTIVE_EMPTY_RESPONSE_EXIT_THRESHOLD = 3[源代码]
class airflow.providers.amazon.aws.hooks.logs.AwsLogsHook(*args, **kwargs)[源代码]

基类： airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon CloudWatch Logs 交互。

提供对 boto3.client("logs") 的简单封装。

可以指定额外的参数（例如 aws_conn_id），它们会传递给底层的 AwsBaseHook。

另请参阅

class ContinuationToken[源代码]

只是一个 str token 的包装器，允许调用者更新它。

get_log_events(log_group, log_stream_name, start_time=0, skip=0, start_from_head=None, continuation_token=None, end_time=None)[源代码]

返回单个流中日志项的生成器；生成当前时刻所有可用的项。

另请参阅

参数

  • log_group (str) – 日志组的名称。

  • log_stream_name (str) – 特定流的名称。

  • start_time (int) – 开始读取日志的时间戳值，以毫秒为单位（默认值：0）。

  • skip (int) – 开始时要跳过的日志条目数（默认值：0）。这适用于同一时间戳有多个条目的情况。

  • continuation_token (ContinuationToken | None) – 一个指示从何处读取日志的令牌。当此方法读取新日志时，将更新该令牌，以便在后续调用中重用。

  • end_time (int | None) – 停止读取日志的时间戳值，以毫秒为单位（默认值：None）。如果提供 None，则读取直到日志流的末尾。

返回

具有以下键值对的 CloudWatch 日志事件
“timestamp”（int）：事件的时间（以毫秒为单位）。
“message”（str）：日志事件数据。
“ingestionTime”（int）：事件被摄取的时间（以毫秒为单位）。

返回类型

collections.abc.Generator

async describe_log_streams_async(log_group, stream_prefix, order_by, count)[源代码]

异步函数，用于获取指定日志组的日志流列表。

您可以列出所有日志流或按前缀过滤结果。您还可以控制结果的排序方式。

参数

  • log_group (str) – 日志组的名称。

  • stream_prefix (str) – 要匹配的前缀。

  • order_by (str) – 如果该值为 LogStreamName ，则结果按日志流名称排序。如果该值为 LastEventTime ，则结果按事件时间排序。默认值为 LogStreamName。

  • count (int) – 返回的最大项目数

async get_log_events_async(log_group, log_stream_name, start_time=0, skip=0, start_from_head=True)[源代码]

生成单个日志流中所有可用的项。

参数

  • log_group (str) – 日志组的名称。

  • log_stream_name (str) – 特定流的名称。

  • start_time (int) – 开始读取日志的时间戳值（默认值：0）。

  • skip (int) – 开始时要跳过的日志条目数（默认值：0）。这适用于同一时间戳有多个条目的情况。

  • start_from_head (bool) – 是否从日志的开头 (True) 或日志的末尾 (False) 开始。

此条目是否有帮助？