airflow.providers.standard.hooks.subprocess¶

類¶

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

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

class airflow.providers.standard.hooks.subprocess.SubprocessResult[source]¶

基類: tuple

airflow.providers.standard.hooks.subprocess.working_directory(cwd=None)[source]¶

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

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

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

使用 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_ 字首傳遞給子程序。詳情請參閱: https://airflow.apache.tw/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/errors.html。
output_encoding (str) – 用於解碼標準輸出的編碼
cwd (str | None) – 執行命令的工作目錄。如果為 None（預設），則在臨時目錄中執行命令。

返回:

包含 exit_code 和 output 的 namedtuple，output 是標準錯誤或標準輸出的最後一行

返回型別:

SubprocessResult