bytewax.serde#

Serialization for recovery and transport.

Classes#

class Serde#
Bases:

A serialization format.

This must support serializing arbitray Python objects and reconstituting them exactly. This means using things like json.dumps and json.loads directly will not work, as they do not support things like datetimes, integer keys, etc.

Even if all of your dataflow’s state is serializeable by a format, Bytewax generates Python objects to store internal data, and they must round-trip correctly or there will be errors.

abstract static ser(obj: Any) str#

Serialize the given object.

abstract static de(s: str) Any#

Deserialize the given object.

class JsonPickleSerde#
Bases:

Serialize objects using jsonpickle.

See jsonpickle for more info.

static ser(obj: Any) str#

See ABC docstring.

static de(s: str) Any#

See ABC docstring.

Join our community Slack channel

Need some help? Join our community!

If you have any trouble with the process or have ideas about how to improve this document, come talk to us in the #questions-answered Slack channel!

Join now