morpheus.loaders.sql_loader#
Functions
|
SQL loader to fetch data from a SQL database and store it in a DataFrame. |
- 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.