| :mod:`airflow.contrib.sensors.ftp_sensor` |
| ========================================= |
| |
| .. py:module:: airflow.contrib.sensors.ftp_sensor |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: FTPSensor(path, ftp_conn_id='ftp_default', fail_on_transient_errors=True, *args, **kwargs) |
| |
| Bases: :class:`airflow.sensors.base_sensor_operator.BaseSensorOperator` |
| |
| Waits for a file or directory to be present on FTP. |
| |
| .. attribute:: template_fields |
| :annotation: = ['path'] |
| |
| Errors that are transient in nature, and where action can be retried |
| |
| |
| .. attribute:: transient_errors |
| :annotation: = [421, 425, 426, 434, 450, 451, 452] |
| |
| |
| |
| .. attribute:: error_code_pattern |
| |
| |
| |
| |
| |
| .. method:: _create_hook(self) |
| |
| Return connection hook. |
| |
| |
| |
| |
| .. method:: _get_error_code(self, e) |
| |
| Extract error code from ftp exception |
| |
| |
| |
| |
| .. method:: poke(self, context) |
| |
| |
| |
| |
| .. py:class:: FTPSSensor |
| |
| Bases: :class:`airflow.contrib.sensors.ftp_sensor.FTPSensor` |
| |
| Waits for a file or directory to be present on FTP over SSL. |
| |
| |
| .. method:: _create_hook(self) |
| |
| Return connection hook. |
| |
| |
| |
| |
