:mod:`airflow.contrib.operators.ssh_operator`
=============================================

.. py:module:: airflow.contrib.operators.ssh_operator







Module Contents
---------------






.. py:class:: SSHOperator(ssh_hook=None, ssh_conn_id=None, remote_host=None, command=None, timeout=10, do_xcom_push=False, *args, **kwargs)

   Bases::class:`airflow.models.BaseOperator`

   

   SSHOperator to execute commands on given remote host using the ssh_hook.

   :param ssh_hook: predefined ssh_hook to use for remote execution.
       Either `ssh_hook` or `ssh_conn_id` needs to be provided.
   :type ssh_hook: airflow.contrib.hooks.ssh_hook.SSHHook
   :param ssh_conn_id: connection id from airflow Connections.
       `ssh_conn_id` will be ignored if `ssh_hook` is provided.
   :type ssh_conn_id: str
   :param remote_host: remote host to connect (templated)
       Nullable. If provided, it will replace the `remote_host` which was
       defined in `ssh_hook` or predefined in the connection of `ssh_conn_id`.
   :type remote_host: str
   :param command: command to execute on remote host. (templated)
   :type command: str
   :param timeout: timeout (in seconds) for executing the command.
   :type timeout: int
   :param do_xcom_push: return the stdout which also get set in xcom by airflow platform
   :type do_xcom_push: bool


   

   

   .. attribute:: template_fields
      :annotation: = ['command', 'remote_host'] 

      



   

   

   .. attribute:: template_ext
      :annotation: = ['.sh'] 

      



   

   

   

   .. method:: execute(self, context)

      



   

   .. method:: tunnel(self)