airflow.providers.amazon.aws.hooks.logs

屬性

NUM_CONSECUTIVE_EMPTY_RESPONSE_EXIT_THRESHOLD

類

AwsLogsHook

與 Amazon CloudWatch Logs 互動。

模組內容

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

基類: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 Amazon CloudWatch Logs 互動。

提供圍繞 boto3.client("logs") 的輕量級包裝器。

可以指定附加引數（例如 aws_conn_id），這些引數會傳遞到底層 AwsBaseHook。

另請參閱

class ContinuationToken[source]

只是一個圍繞 str token 的包裝器，允許呼叫者更新它。

value: str | None = None[source]
get_log_events(log_group, log_stream_name, start_time=0, skip=0, start_from_head=None, continuation_token=None, end_time=None)[source]

返回單個流中日誌項的生成器；生成當前時刻所有可用的項。

另請參閱

引數:

  • log_group (str) – 日誌組的名稱。

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

  • start_time (int) – 開始讀取日誌的時間戳值（毫秒）（預設值: 0）。

  • skip (int) – 開始時跳過的日誌條目數（預設值: 0）。這用於同一時間戳有多個條目的情況。

  • continuation_token (ContinuationToken | None) – 指示從何處讀取日誌的 token。此方法讀取新日誌時會更新此 token，以便在後續呼叫中重用。

  • 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)[source]

非同步函式，用於獲取指定日誌組的日誌流列表。

您可以列出所有日誌流或按字首過濾結果。您還可以控制結果的排序方式。

引數:

  • 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)[source]

生成單個日誌流中的所有可用項。

引數:

  • log_group (str) – 日誌組的名稱。

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

  • start_time (int) – 開始讀取日誌的時間戳值（預設值: 0）。

  • skip (int) – 開始時跳過的日誌條目數（預設值: 0）。這用於同一時間戳有多個條目的情況。

  • start_from_head (bool) – 是否從日誌的開頭 (True) 開始讀取或從日誌的末尾 (False) 開始讀取。

此條目有幫助嗎？