我从一个Kafka制作人那里发了一个numpy矩阵,效果非常好:
async def kafka_send(kafka_producer, data, topic):
test = np.array([[1, 2], [3, 4]])
x_enc = msgpack.packb(test, default=m.encode)
encoded = base64.encodebytes(x_enc)
await kafka_producer.send(topic, encoded)
另一方面,如果我尝试将此代码从转换后的图像发送到numpy,它不会发送任何内容:
image = Image.open(io.BytesIO(post_data))
arr = np.asarray(image)
有人有这个吗?
暂无答案!
目前还没有任何答案,快来回答吧!