在Airflow上通过ssh_conn_id连接SSHHook需要进行以下步骤:
下面是一个示例的DAG代码片段:
from airflow import DAG
from airflow.operators.ssh_operator import SSHOperator
from airflow.hooks.SSH_hook import SSHHook
from datetime import datetime
default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1),
}
dag = DAG('ssh_example', default_args=default_args)
ssh_hook = SSHHook(ssh_conn_id='my_ssh_connection')
task1 = SSHOperator(
task_id='task1',
ssh_hook=ssh_hook,
command='echo Hello World!',
dag=dag
)
task2 = SSHOperator(
task_id='task2',
ssh_hook=ssh_hook,
command='ls -l',
dag=dag
)
task1 >> task2
在上述代码中,我们创建了一个名为"my_ssh_connection"的SSH连接,并使用SSHOperator来执行两个SSH任务。通过ssh_conn_id参数,我们指定了要使用的SSH连接。
关于SSH连接的详细信息、用法和相关的腾讯云产品介绍,你可以在腾讯云官方文档中找到。以下是相关链接:
请注意,以上链接仅供参考,具体的产品选择和推荐应根据实际需求和情况进行。
领取专属 10元无门槛券
手把手带您无忧上云