airflow.providers.alibaba.cloud.log.oss_task_handler

模組內容

類別

OSSTaskHandler

OSSTaskHandler 是一個 Python 日誌處理器，用於處理和讀取任務實例日誌。
class airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler(base_log_folder, oss_log_folder, **kwargs)[原始碼]

基底： airflow.utils.log.file_task_handler.FileTaskHandler、 airflow.utils.log.logging_mixin.LoggingMixin

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

擴展 airflow FileTaskHandler 並上傳至和從 OSS 遠端儲存讀取。

hook()[原始碼]
set_context(ti)[原始碼]

設定處理器的上下文。

close()[原始碼]

關閉並將本機日誌檔案上傳到遠端儲存 OSS。

oss_log_exists(remote_log_location)[原始碼]

檢查 remote_log_location 是否存在於遠端儲存中。

參數

remote_log_location – 遠端儲存中的日誌位置

回傳

如果位置存在則為 True，否則為 False

oss_read(remote_log_location, return_error=False)[原始碼]

傳回 remote_log_location 的日誌，如果找不到日誌或發生錯誤，則傳回 ''。

參數

  • remote_log_location – 遠端儲存中的日誌位置

  • return_error – 如果為 True，則在發生錯誤時傳回字串錯誤訊息。否則，在發生錯誤時傳回 ''。

oss_write(log, remote_log_location, append=True)[原始碼]

將日誌寫入 remote_log_location 並傳回 True；如果發生錯誤，則靜默失敗並傳回 False。

參數

  • log – 要寫入 remote_log_location 的日誌

  • remote_log_location – 遠端儲存中的日誌位置

  • append – 如果為 False，則會覆寫任何現有的日誌檔案。如果為 True，則新日誌會附加到任何現有的日誌。

回傳

日誌是否成功寫入遠端位置。

回傳類型

bool

這個條目有幫助嗎？