spreadflow_format_bson package

Module contents

BSON message interchange format for SpreadFlow metadata extraction and processing engine.

class spreadflow_format_bson.MessageBuilder

Bases: object

Message builder for the BSON stream format.

message(msg)

class spreadflow_format_bson.MessageParser(buffer_max_len=32768)

Bases: object

BSON message parser.

Parameters:buffer_max_len (int) – The maximum number of bytes buffered while parsing a stream of incoming messages. Defaults to 32768.

MAX_LENGTH = 32768

messages()

Iterate over all available messages.

Yields:object – The next decoded message.

push(data)

Push data onto the message parser buffer.

Parameters:

• data (bytes) – Data as received from the network. Partial messages
• allowed. (are) –

Raises:

RuntimeError – If the buffer is full.