airflow.providers.redis.log.redis_task_handler

模組內容

類別

RedisTaskHandler

RedisTaskHandler 是一個 Python 記錄處理器，用於處理和讀取任務實例日誌。
class airflow.providers.redis.log.redis_task_handler.RedisTaskHandler(base_log_folder, max_lines=10000, ttl_seconds=60 * 60 * 24 * 28, conn_id=None)[原始碼]

基底類別： airflow.utils.log.file_task_handler.FileTaskHandler, airflow.utils.log.logging_mixin.LoggingMixin

RedisTaskHandler 是一個 Python 記錄處理器，用於處理和讀取任務實例日誌。

它擴展了 airflow FileTaskHandler，並上傳和讀取 Redis。

參數

  • base_log_folder (str) – 本地儲存日誌的基礎資料夾

  • max_lines (int) – 要儲存的最大日誌行數。如果省略，則預設為 10000。

  • ttl_seconds (int) – 儲存日誌的最大秒數。如果省略，則相當於 28 天。

  • conn_id (str | None) – 用於 Redis hook 的 Airflow 連線 ID。如果省略或為 None，則使用 logging.remote_log_conn_id 選項中指定的 ID。

trigger_should_wrap = True[原始碼]
conn()[原始碼]
set_context(ti, **kwargs)[原始碼]

為 airflow 任務處理器提供 task_instance 上下文。

一般來說，回傳 None。但是如果 attr maintain_propagate 已設定為 propagate，則回傳 sentinel MAINTAIN_PROPAGATE。這具有覆寫預設行為的效果，無論何時呼叫 set_context，都將 propagate 設定為 False。在撰寫本文時，此功能僅在單元測試中使用。

參數

  • ti (airflow.models.TaskInstance) – 任務實例物件

  • identifier – 如果設定，則將後綴添加到日誌檔案。用於從任務或觸發器執行以外的上下文將異常訊息中繼到任務日誌時使用

此條目是否有幫助？