airflow.hooks.subprocess

模組內容

類別

SubprocessHook

用於使用 subprocess 模組執行程序的 Hook。

函數

working_directory([cwd])

用於處理（臨時）工作目錄的上下文管理器。

屬性

SubprocessResult

airflow.hooks.subprocess.SubprocessResult[source]
airflow.hooks.subprocess.working_directory(cwd=None)[source]

用於處理（臨時）工作目錄的上下文管理器。

如果提供 cwd，則使用給定的 cwd 作為工作目錄。 否則，建立一個臨時目錄。

class airflow.hooks.subprocess.SubprocessHook(**kwargs)[source]

繼承自： airflow.hooks.base.BaseHook

用於使用 subprocess 模組執行程序的 Hook。

run_command(command, env=None, output_encoding='utf-8', cwd=None)[source]

執行命令。

如果 cwd 為 None，則在稍後會清除的臨時目錄中執行命令。 如果未提供 env，則會傳遞 os.environ

參數

  • command (list[str]) – 要執行的命令

  • env (dict[str, str] | None) – 包含環境變數的可選字典，這些變數將提供給將執行 command 的 shell 環境。 如果省略，將使用 os.environ。 請注意，如果您已配置 Sentry，則來自環境的原始變數也將以 SUBPROCESS_ 前綴傳遞到子程序。 有關詳細信息，請參閱錯誤追蹤。

  • output_encoding (str) – 用於解碼 stdout 的編碼

  • cwd (str | None) – 在其中執行命令的工作目錄。 如果為 None（預設值），則命令在臨時目錄中執行。

回傳

namedtuple 包含 exit_code 和 output，這是來自 stderr 或 stdout 的最後一行

回傳類型

SubprocessResult

send_sigterm()[source]

如果存在 self.sub_process，則向其發送 SIGTERM 信號。

這個條目對您有幫助嗎？