`airflow.providers.standard.hooks.subprocess`¶

模組內容¶

類別¶

SubprocessHook

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

函式¶

working_directory([cwd])

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

屬性¶

SubprocessResult

airflow.providers.standard.hooks.subprocess.SubprocessResult[原始碼]¶

airflow.providers.standard.hooks.subprocess.working_directory(cwd=None)[原始碼]¶

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

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

class airflow.providers.standard.hooks.subprocess.SubprocessHook(**kwargs)[原始碼]¶

繼承自： airflow.hooks.base.BaseHook

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

run_command(command, env=None, output_encoding='utf-8', cwd=None)[原始碼]¶

執行命令。

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

參數

command (list[str]) – 要執行的命令
env (dict[str, str] | None) – 包含環境變數的可選字典，這些變數將提供給執行 command 的 shell 環境。如果省略，將使用 os.environ。請注意，如果您已設定 Sentry，則來自環境的原始變數也將以 SUBPROCESS_ 前綴傳遞到子進程。詳情請參閱：https://airflow.dev.org.tw/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/errors.html。
output_encoding (str) – 用於解碼 stdout 的編碼
cwd (str | None) – 在其中執行命令的工作目錄。如果為 None（預設值），則命令在臨時目錄中執行。

返回值

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

返回類型

SubprocessResult

send_sigterm()[原始碼]¶: 如果存在 self.sub_process，則向其發送 SIGTERM 信號。

這個條目是否有幫助？