Functions
sql_loader(control_message, task) |
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_message
- task
The control message containing metadata and a payload.
The task configuration containing SQL config and queries.
- Returns
- ControlMessage
Control message with the final DataFrame in the payload.