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.org.cn/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/errors.html。
output_encoding (str) – 用于解码标准输出的编码
cwd (str | None) – 运行命令的工作目录。如果为 None（默认），则在临时目录中运行命令。

返回:

包含 exit_code 和 output 的 namedtuple，output 是标准错误或标准输出的最后一行

返回类型:

SubprocessResult