我们可以在 Python 中向 kafka 发送一个 class 实例吗?
Can we send a class instance to kafka in Python?
我想发送一个 class 实例给 kafka 代理。
A1 = Axestrack('1087999','2018-05-24')
这里的 Axestrack 是 python class 而 A1 是 class Axestrack 的实例。
现在如何将此实例发送到 kafka 代理?
您可以将其作为 CSV、JSON、Avro 发送,或者自己对 bytes
对象进行编码。
只要您可以配置反序列化器将其读回,发送什么格式并不重要。
没有"built-in" Python-Kafka序列化器(可能pickle
除外)
我想发送一个 class 实例给 kafka 代理。
A1 = Axestrack('1087999','2018-05-24')
这里的 Axestrack 是 python class 而 A1 是 class Axestrack 的实例。
现在如何将此实例发送到 kafka 代理?
您可以将其作为 CSV、JSON、Avro 发送,或者自己对 bytes
对象进行编码。
只要您可以配置反序列化器将其读回,发送什么格式并不重要。
没有"built-in" Python-Kafka序列化器(可能pickle
除外)