Skip to main content

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​

msgpackext_decode​

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.

msgpackext_encode​

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.