• Home
• Index

Index

_

__aenter__() (airflow.providers.sftp.pools.sftp.SFTPClientPool method)

__aexit__() (airflow.providers.sftp.pools.sftp.SFTPClientPool method) __version__ (in module airflow.providers.sftp)

A

acquire() (airflow.providers.sftp.pools.sftp.SFTPClientPool method) airflow.providers.sftp module airflow.providers.sftp.assets module airflow.providers.sftp.assets.sftp module airflow.providers.sftp.decorators module airflow.providers.sftp.decorators.sensors module airflow.providers.sftp.decorators.sensors.sftp module airflow.providers.sftp.exceptions module airflow.providers.sftp.fs module airflow.providers.sftp.fs.sftp module airflow.providers.sftp.get_provider_info module airflow.providers.sftp.hooks module

airflow.providers.sftp.hooks.sftp module airflow.providers.sftp.operators module airflow.providers.sftp.operators.sftp module airflow.providers.sftp.pools module airflow.providers.sftp.pools.sftp module airflow.providers.sftp.sensors module airflow.providers.sftp.sensors.sftp module airflow.providers.sftp.triggers module airflow.providers.sftp.triggers.sftp module airflow.providers.sftp.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.sftp.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.sftp.version_compat)

C

CHUNK_SIZE (in module airflow.providers.sftp.hooks.sftp) close() (airflow.providers.sftp.pools.sftp.SFTPClientPool method) close_conn() (airflow.providers.sftp.hooks.sftp.SFTPHook method) concurrency (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) confirm (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) conn (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) conn_name_attr (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute)

conn_type (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) ConnectionNotOpenedException convert_asset_to_openlineage() (in module airflow.providers.sftp.assets.sftp) create_asset() (in module airflow.providers.sftp.assets.sftp) create_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method) create_intermediate_dirs (airflow.providers.sftp.operators.sftp.SFTPOperator attribute)

D

default_conn_name (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) default_known_hosts (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) deferrable (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute)

DELETE (airflow.providers.sftp.operators.sftp.SFTPOperation attribute) delete_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method) delete_file() (airflow.providers.sftp.hooks.sftp.SFTPHook method) describe_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method)

E

execute() (airflow.providers.sftp.operators.sftp.SFTPOperator method) (airflow.providers.sftp.sensors.sftp.SFTPSensor method)

execute_complete() (airflow.providers.sftp.sensors.sftp.SFTPSensor method)

F

file_pattern (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) (airflow.providers.sftp.triggers.sftp.SFTPTrigger attribute)

FULL_FILE_PATH (in module tests.system.sftp.example_sftp_sensor)

G

GET (airflow.providers.sftp.operators.sftp.SFTPOperation attribute) get_conn() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_conn_count() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_file_by_pattern() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_files_and_attrs_by_pattern() (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method) get_files_by_pattern() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_fs() (in module airflow.providers.sftp.fs.sftp)

get_managed_conn() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_mod_time() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method) get_openlineage_facets_on_start() (airflow.providers.sftp.operators.sftp.SFTPOperator method) get_provider_info() (in module airflow.providers.sftp.get_provider_info) get_sftp_client() (airflow.providers.sftp.pools.sftp.SFTPClientPool method) get_tree_map() (airflow.providers.sftp.hooks.sftp.SFTPHook method) get_ui_field_behaviour() (airflow.providers.sftp.hooks.sftp.SFTPHook class method)

H

handle_connection_management() (in module airflow.providers.sftp.hooks.sftp) hook (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute)

hook_name (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) host (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute)

I

isdir() (airflow.providers.sftp.hooks.sftp.SFTPHook method)

isfile() (airflow.providers.sftp.hooks.sftp.SFTPHook method)

K

key_file (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute)

known_hosts (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute)

L

list_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method)

list_directory_with_attr() (airflow.providers.sftp.hooks.sftp.SFTPHook method) local_filepath (airflow.providers.sftp.operators.sftp.SFTPOperator attribute)

M

mkdir() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method) module airflow.providers.sftp airflow.providers.sftp.assets airflow.providers.sftp.assets.sftp airflow.providers.sftp.decorators airflow.providers.sftp.decorators.sensors airflow.providers.sftp.decorators.sensors.sftp airflow.providers.sftp.exceptions airflow.providers.sftp.fs airflow.providers.sftp.fs.sftp airflow.providers.sftp.get_provider_info airflow.providers.sftp.hooks airflow.providers.sftp.hooks.sftp airflow.providers.sftp.operators airflow.providers.sftp.operators.sftp airflow.providers.sftp.pools airflow.providers.sftp.pools.sftp airflow.providers.sftp.sensors airflow.providers.sftp.sensors.sftp airflow.providers.sftp.triggers airflow.providers.sftp.triggers.sftp airflow.providers.sftp.version_compat tests.system.sftp tests.system.sftp.example_sftp_sensor

N

newer_than (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) (airflow.providers.sftp.triggers.sftp.SFTPTrigger attribute)

O

op_args (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute)

op_kwargs (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) operation (airflow.providers.sftp.operators.sftp.SFTPOperator attribute)

P

passphrase (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) password (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) path (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) (airflow.providers.sftp.triggers.sftp.SFTPTrigger attribute) path_exists() (airflow.providers.sftp.hooks.sftp.SFTPHook method) poke() (airflow.providers.sftp.sensors.sftp.SFTPSensor method)

poke_interval (airflow.providers.sftp.triggers.sftp.SFTPTrigger attribute) port (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) prefetch (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) private_key (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) PUT (airflow.providers.sftp.operators.sftp.SFTPOperation attribute) python_callable (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute)

R

read_directory() (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method) release() (airflow.providers.sftp.pools.sftp.SFTPClientPool method) remote_filepath (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) remote_host (airflow.providers.sftp.operators.sftp.SFTPOperator attribute)

retrieve_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method) retrieve_directory_concurrently() (airflow.providers.sftp.hooks.sftp.SFTPHook method) retrieve_file() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method) run() (airflow.providers.sftp.triggers.sftp.SFTPTrigger method)

S

sanitize_uri() (in module airflow.providers.sftp.assets.sftp) schemes (in module airflow.providers.sftp.fs.sftp) serialize() (airflow.providers.sftp.triggers.sftp.SFTPTrigger method) sftp_conn_id (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute) (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) (airflow.providers.sftp.triggers.sftp.SFTPTrigger attribute) SFTP_DEFAULT_CONNECTION (in module tests.system.sftp.example_sftp_sensor) SFTP_DIRECTORY (in module tests.system.sftp.example_sftp_sensor) sftp_hook (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) sftp_sensor_decorator() (in module tests.system.sftp.example_sftp_sensor) sftp_sensor_task() (in module airflow.providers.sftp.decorators.sensors.sftp) SFTPClientPool (class in airflow.providers.sftp.pools.sftp)

SFTPHook (class in airflow.providers.sftp.hooks.sftp) SFTPHookAsync (class in airflow.providers.sftp.hooks.sftp) SFTPOperation (class in airflow.providers.sftp.operators.sftp) SFTPOperator (class in airflow.providers.sftp.operators.sftp) SFTPSensor (class in airflow.providers.sftp.sensors.sftp) SFTPTrigger (class in airflow.providers.sftp.triggers.sftp) sleep_function() (in module tests.system.sftp.example_sftp_sensor) ssh_conn_id (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) store_directory() (airflow.providers.sftp.hooks.sftp.SFTPHook method) store_directory_concurrently() (airflow.providers.sftp.hooks.sftp.SFTPHook method) store_file() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method)

T

template_fields (airflow.providers.sftp.operators.sftp.SFTPOperator attribute) (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute) test_connection() (airflow.providers.sftp.hooks.sftp.SFTPHook method) test_run (in module tests.system.sftp.example_sftp_sensor)

tests.system.sftp module tests.system.sftp.example_sftp_sensor module

U

use_managed_conn (airflow.providers.sftp.hooks.sftp.SFTPHook attribute) (airflow.providers.sftp.sensors.sftp.SFTPSensor attribute)

username (airflow.providers.sftp.hooks.sftp.SFTPHookAsync attribute)

W

walktree() (airflow.providers.sftp.hooks.sftp.SFTPHook method) (airflow.providers.sftp.hooks.sftp.SFTPHookAsync method)

PreviousNext

Was this entry helpful?