Index

_

__init__() (CronJob method) (MicrosoftSQLServerConnection method) (MongoDB method) (MongoDBAsync method) (MongoDBChangeStream method) (MSSQLChangeTrigger method) (SQLiteConnection method)

A

auth_source (MongoDB attribute) (MongoDBAsync attribute)

C

collection (MongoDBChangeStream property) connect() (Connection method) (MicrosoftSQLServerConnection method) (MongoDB method) (MongoDBAsync method) (SQLiteConnection method)

Connection (class in dataflow.connection) CronJob (class in dataflow.triggers.cronjob) cronjob() (in module dataflow.triggers.cronjob)

D

database (MicrosoftSQLServerConnection attribute) (MongoDB attribute) (MongoDBAsync attribute) (MSSQLChangeTrigger property) database_path (SQLiteConnection attribute) dataflow.connection module

delete() (MongoDB method) (MongoDBAsync method) (SQLiteConnection method) disconnect() (Connection method) (MicrosoftSQLServerConnection method) (MongoDB method) (MongoDBAsync method) (SQLiteConnection method)

E

ensure_connected() (SQLiteConnection method) execute() (MicrosoftSQLServerConnection method) (SQLiteConnection method)

execute_many() (MicrosoftSQLServerConnection method)

F

fetch() (MicrosoftSQLServerConnection method) (MongoDB method) (MongoDBAsync method) (SQLiteConnection method)

G

get_collection() (MongoDBAsync method)

H

host (MicrosoftSQLServerConnection attribute) (MongoDB attribute)

hostname (MongoDBAsync attribute)

I

insert() (MongoDB method) (MongoDBAsync method) (SQLiteConnection method)

is_running (CronJob property) (MongoDBChangeStream property) (MSSQLChangeTrigger property) (Trigger property)

M

MicrosoftSQLServerConnection (class in dataflow.connection) model_config (Connection attribute) (MicrosoftSQLServerConnection attribute) (MongoDB attribute) (MongoDBAsync attribute) (SQLiteConnection attribute) model_post_init() (MongoDB method) (MongoDBAsync method)

module dataflow.connection MongoDB (class in dataflow.connection) mongodb_change_stream() (in module dataflow.triggers.mongo_db_listener) MongoDBAsync (class in dataflow.connection) MongoDBChangeStream (class in dataflow.triggers.mongo_db_listener) mssql_change_trigger() (in module dataflow.triggers.mssql_change_trigger) MSSQLChangeTrigger (class in dataflow.triggers.mssql_change_trigger)

N

name (CronJob property) (MongoDBChangeStream property) (MSSQLChangeTrigger property) (Trigger property)

O

operations (MongoDBChangeStream property) (MSSQLChangeTrigger property)

P

password (MicrosoftSQLServerConnection attribute) (MongoDB attribute) (MongoDBAsync attribute)

port (MicrosoftSQLServerConnection attribute) (MongoDB attribute) (MongoDBAsync attribute)

S

schedule (CronJob property) schema (MSSQLChangeTrigger property) SQLiteConnection (class in dataflow.connection) start() (CronJob method) (MongoDBChangeStream method) (MSSQLChangeTrigger method) (Trigger method)

stop() (CronJob method) (MongoDBChangeStream method) (MSSQLChangeTrigger method) (Trigger method)

T

table (MSSQLChangeTrigger property) tls (MongoDB attribute) (MongoDBAsync attribute)

Trigger (class in dataflow.triggers.base)

U

upsert() (MongoDB method) (MongoDBAsync method) (SQLiteConnection method)

username (MicrosoftSQLServerConnection attribute) (MongoDB attribute) (MongoDBAsync attribute)

V

validate_database_path() (SQLiteConnection class method) validate_port() (MicrosoftSQLServerConnection class method) (MongoDB class method) (MongoDBAsync class method)