如何在一个消息中为Kafka生成音频（.wav）

Question

为了应用实时语音分析使用大数据技术，我尝试在一开始使用Kafka。因此，首先我使用WAVIO API将.wav文件转换为字节，然后将包含[data（nparray的类型）、rate（整数）和sampwidth（整数）]的消息发送给kafka，然后消费者将使用这些消息，消费者将再次将它们转换为.wav文件。

问题是我如何在一条消息（每条消息代表.wav文件）中发送和接收这些[data,rate,sampwidth]到kafka和从kafka接收这些[data,rate,sampwidth]？

    producer = KafkaProducer(bootstrap_servers='localhost:9092')
    x = wav2bytes("bush_read") # return tuple containing(data, rate, sampwidth)
    #here I'm sending 3 messages
    producer.send("TestTopic", key=b'data', value=b'%s' % (x[0])) # data -> nparray
    producer.send("TestTopic", key=b'rate', value=b'%d' % (x[1]))   # rate -> int
    producer.send("TestTopic", key=b'sampwidth', value=b'%d' % (x[2]))  #sampwidth -> int
    send("TestTopic","bush_read")

    for message in consumer:
        msg = message     # I want somthing like this
        file = bytes2wav("name", msg.data, msg.rate, msg.sampwidth )

Answer 1

如果需要，您可以将其作为json（或任何其他序列化）发送，创建一个json，如

{“data”：data,“rate”：rate,“sampwidth”：sampwidth}

您可以在消费者中反序列化它