如何用python发送Kafka制作人的图像?

55ooxyrt  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(208)

我从一个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)

有人有这个吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题