dataframe_connector module

Connectors of type “Dataframe” either accept input or they output to a Pandas DataFrame. These connectors are used in chaining multiple connectors together to perform complex operations.

class dataframe_connector.DataFrameToDataFrameConnector(input_handler: libs.handler.dataframe_handler.DataFrameHandler, output_handler: libs.handler.postgres_handler.PostgresHandler, log_handler: libs.log_handler.log_handler.LogHandler, write_logs: bool = True)

Bases: libs.connector.generic_connector.GenericConnecter

read()

Calls the Handler’s “execute” method and loads it into a dataframe.

write()

class dataframe_connector.DataFrameToPostgresConnector(input_handler: libs.handler.dataframe_handler.DataFrameHandler, output_handler: libs.handler.postgres_handler.PostgresHandler, log_handler: libs.log_handler.log_handler.LogHandler, write_logs: bool = True)

Bases: libs.connector.generic_connector.GenericConnecter

read()

Calls the Handler’s “execute” method and loads it into a dataframe.