message_service

Interface classes and methods for the message service.

Provides functionality to wrap generated GRPC code and python-friendly versions of GRPC classes and methods.

Module

Functions

def msgpackext_decode(code: int, obj: Any) ‑> Any:

Extension to deserialise DataFrame and numpy using arrow.

Arguments

• code: An integer specifying whether the object is a numpy array (code=1) or Dataframe (code=2).
• obj: An encoded object, likely a dictionary.

Returns The decoded form of the object.

def msgpackext_encode(obj: Any) ‑> Any:

Serialises extension objects for DataFrames or np.ndarray using pyarrow.

Arguments

• obj: An object to be serialized

Returns A msgpack compatible extension form of the object.

---