airflow.hooks.subprocess

模块内容

类

SubprocessHook

使用 subprocess 模块运行进程的钩子。

函数

working_directory([cwd])

用于处理（临时）工作目录的上下文管理器。

属性

SubprocessResult

airflow.hooks.subprocess.SubprocessResult[源代码]
airflow.hooks.subprocess.working_directory(cwd=None)[源代码]

用于处理（临时）工作目录的上下文管理器。

如果提供了 cwd，则使用给定的 cwd 作为工作目录。否则，创建一个临时目录。

class airflow.hooks.subprocess.SubprocessHook(**kwargs)[源代码]

基类：airflow.hooks.base.BaseHook

使用 subprocess 模块运行进程的钩子。

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_ 前缀传递给子进程。 有关详细信息，请参阅 错误跟踪。

  • output_encoding (str) – 用于解码 stdout 的编码

  • cwd (str | None) – 在其中运行命令的工作目录。如果为 None（默认值），则该命令在临时目录中运行。

返回

namedtuple，包含 exit_code 和 output，即 stderr 或 stdout 的最后一行

返回类型

SubprocessResult

send_sigterm()[源代码]

如果存在 self.sub_process，则向其发送 SIGTERM 信号。

这个条目有帮助吗？