Python中文
首页
教程
问答
标签
搜索
登录
注册
如何产生音频(.wav)卡夫卡在一个消息
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>为了使用大数据技术应用实时语音分析,我在开始时尝试使用卡夫卡。因此,首先我使用wavioapi将.wav文件转换为字节,然后将包含[data(nparray的类型)、rate(integer)和sampwidth(integer)]的消息发送给kafka,之后这些消息将被消费者使用,消费者将再次将其转换为.wav文件。你知道吗</p> <p>问题是我如何在一条消息中向kafka发送和接收这些[数据、速率、sampwidth](每条消息代表.wav文件)?你知道吗</p> <h2>对于生产商:</h2> <pre class="lang-py prettyprint-override"><code> 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") </code></pre> <h2>对于消费者:</h2> <pre><code> for message in consumer: msg = message # I want somthing like this file = bytes2wav("name", msg.data, msg.rate, msg.sampwidth ) </code></pre>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>如果需要,可以将其作为json(或任何其他序列化)发送,创建一个类似json的</p> <p><code>{'data' : data, 'rate': rate, 'sampwidth': sampwidth}</code></p> <p>你可以在消费者中反序列化它</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
我想从用户inpu创建一个类的实例
7 回答
我想从用户导入值,为此
6 回答
我想从用户那里得到一个整数输入,然后让for循环遍历该数字,然后调用一个函数多次
7 回答
我想从用户那里收到一个列表,并在其中执行一些步骤,然后在步骤完成后将其打印回来,但它没有按照我想要的方式工作
7 回答
我想从用户那里获取输入,并将值传递给(average=dict[x]/6),然后在那里获取resu
6 回答
我想从第一个列表中展示第一个词,然后从第二个列表中展示十个词,以此类推- Python
3 回答
我想从第一个空lin开始解析文本文件
9 回答
我想从简历、简历中提取特定部分
3 回答
我想从给定字典(python)的字符串中删除\u00a9、\u201d和类似的字符。
4 回答
我想从给定的网站Lin下载许多文件扩展名相同的Wget或Python文件
8 回答
我想从网上搜集一些关于抵押贷款的数据
4 回答
我想从网站上删除电子邮件地址
5 回答
我想从网站上读取数据该网站包含可下载的文件,然后我想用python脚本把它发送给oracle如何?
10 回答
我想从网站中提取数据,然后将其显示在我的网页上
6 回答
我想从网页上提取统计数据。
4 回答
我想从网页上解析首都城市,并在用户输入国家时在终端上打印它们
3 回答
我想从色彩图中删除前n个颜色,而不丢失原始颜色数
3 回答
我想从课堂上打印字典里的键
9 回答
我想从费用表中获取学生上次支付的费用,其中学生id=id
5 回答
我想从较低的顺序对多重列表进行排序,但我无法在一行中生成结果
7 回答