python - 如何在 Airflow 中通过 SSH 并运行 PythonOperator

Question

有没有办法通过 ssh 连接到服务器并使用 Airflow 运行 PythonOperator ？我正在寻找类似于 SSHExecuteOperator 的东西，但不是执行 bash 命令，而是执行 python 可调用。

Answer 1

其 ssh 隐私问题

1. 转到您的主机 ssh 服务器并运行 ssh-keygen -t rsa 并一直按 Enter
2. 您将获得 2 个 rsa 文件。将该文件复制到airflow env 并复制其完整路径

3. 只需从 Airflow 用户界面将以下内容添加到您的连接

    {"key_file": "/usr/local/airflow/.ssh/id_rsa.pub", "no_host_key_check": true}
   

   重新编译DAG并运行