ingest_stream module

ingest_stream.get_data()[source]

Retrieves new data from the Flask server.

Returns:

DataFrame containing the new data from the server.

Return type:

df (pandas.DataFrame)

ingest_stream.process_stream(new_data)[source]

Processes the new data received from the stream.

Parameters:

new_data (pandas.DataFrame) – DataFrame containing the new data.

Returns:

None