airflow.providers.standard.hooks.subprocess
¶
模块内容¶
类¶
使用 |
函数¶
|
用于处理(临时)工作目录的上下文管理器。 |
属性¶
- 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
- 参数
env (dict[str, str] | None) – 可选字典,包含要提供给执行
command
的 shell 环境的环境变量。如果省略,将使用os.environ
。请注意,如果您配置了 Sentry,则原始环境变量也会使用SUBPROCESS_
前缀传递给子进程。请参阅:https://airflow.apache.org/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