| |
| import pickle |
| from abc import ABC, abstractmethod |
| from typing import Any |
|
|
| import orjson |
|
|
|
|
| class AbstractSerializer(ABC): |
| @abstractmethod |
| def serialize(self, obj: Any) -> Any: |
| """Support for serializing objects stored in Redis.""" |
|
|
| @abstractmethod |
| def deserialize(self, obj: Any) -> Any: |
| """Support for deserializing objects stored in Redis.""" |
|
|
|
|
| class PickleSerializer(AbstractSerializer): |
| """Serialize values using pickle.""" |
|
|
| def serialize(self, obj: Any) -> bytes: |
| return pickle.dumps(obj) |
|
|
| def deserialize(self, obj: bytes) -> Any: |
| """Deserialize values using pickle.""" |
| return pickle.loads(obj) |
|
|
|
|
| class JSONSerializer(AbstractSerializer): |
| """Serialize values using JSON.""" |
|
|
| def serialize(self, obj: Any) -> bytes: |
| return orjson.dumps(obj) |
|
|
| def deserialize(self, obj: str) -> Any: |
| """Deserialize values using JSON.""" |
| return orjson.loads(obj) |
|
|
