airflow_ssh_operator_remote_command_execution_dag.py

1import datetime
2
3from airflow import DAG
4from airflow.providers.ssh.operators.ssh import SSHOperator
5
6with DAG(
7    dag_id="ssh_operator_dag",
8    start_date=datetime.datetime(2021, 1, 1),
9    schedule="@daily",
10    catchup=False,
11) as dag:
12
13    # [START howto_operator_ssh]
14    ssh_task = SSHOperator(
15        task_id="ssh_task",
16        ssh_conn_id="ssh_default",
17        command="echo 'Hello World from remote host'",
18    )
19    # [END howto_operator_ssh]