Как я могу отправить изображение от производителя kafka на python? - PullRequest
0 голосов
/ 05 апреля 2019

Я отправляю пустую матрицу от производителя kafka, и она отлично работает:

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)

У кого-нибудь есть это?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...