morpheus.loaders.sql_loader

Functions

sql_loader(control_message, task)[source]

SQL loader to fetch data from a SQL database and store it in a DataFrame.

Parameters

control_messageControlMessage

The control message containing metadata and a payload.

taskDict[str, Any]

The task configuration containing SQL config and queries.

Returns

ControlMessage

Control message with the final DataFrame in the payload.