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,则将其用作工作目录。否则,创建一个临时目录。

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

参数
返回

namedtuple,包含 exit_codeoutput,即 stderr 或 stdout 的最后一行

返回类型

SubprocessResult

send_sigterm()[源代码]

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

此条目是否有帮助?