For MQTT data streaming the same JSON format as for bulk data recording is used (see section Data output format). By default, these JSON documents are sent uncompressed and are therefore not embedded in a zip archive. Hence, the raw payload of a single MQTT message represents a UTF-8 encoded JSON string which can be directly deserialized into a data object or dumped to the local file storage of the data consumer (e.g. a data lake service). The Python code snipped depicted below shows a minimalistic MQTT client implementation and demonstrates how to handle incoming messages.
The system can be configured to send zip-compressed messages (see section Configuring MQTT data streaming). In this case the incoming data object must be treated as an array of bytes representing a serialized zip-archive.