如何在nameko rpc中传递二进制数据？

Question

json似乎是nameko rpc中序列化数据的默认方式。如果我调用rpc.my_service.send(b'\x01\')，它将引发异常kombu.exceptions.EncodeError: Object of type 'bytes' is not JSON serializable

有没有办法在nameko rpc中发送二进制数据？例如，pickle。请给我举个简短的例子好吗？提前谢谢你。

Answer 1

您可以通过在配置文件中指定pickle来使用它进行序列化。简单地说：

# config.yaml
serializer: pickle

和

nameko run my_service --config config.yaml

如果您需要更高级的功能，您可以构建自己的序列化程序，并再次配置服务以通过您的配置文件使用它：

# config.yaml
serializer: my_serializer
SERIALIZERS:
    my_serializer:
        encoder: 'path.to.encode.function'
        decoder: 'path.to.decode.function'
        content_type: 'application/x-my-serializer'

encode和decode函数只是接受一个值并返回一个转换后的版本。