Airflow 如何从 on_failure_callback 自定义函数运行 bash 脚本

Question

我想创建一个将在_failure_callback上释放的函数。 它必须在安装 Airflow 的服务器上启动一个脚本。 有什么技巧可以做吗？

Answer 1

由于我对您现有的准则一无所知（我猜没有），我只能给您一般性建议：

• paramiko SSH 客户端可以通过 SSH 进行连接
• exec_command：在远程计算机/服务器上运行内容
• 通过错误处理调用方法。因此，如果东西坏了，抓住它并运行你的方法。

如果适合您的情况，请考虑重试