src.dienstleister_services.data_processing.data_processing_service.py

DataProcessingService

class DataProcessingService(broker_connection: BrokerConnection | None = None, **kwargs)

Bases: FastIoTService

A Data Processing Service

Variables:

_preprocessor – Holds the steps of the processing Pipeline

async get_labeled_dataset(_: str, msg: Thing) → Thing

Request a labeled dataset from the broker and returns a corresponding processed dataset

Parameters:

• _ (str) – The topic of the message. This is not used in this method.

• msg (Thing) – Actual message

Returns:

Thing to signal reception

Return type:

Thing