streaming

0热度

1回答

我有从笔记本电脑麦克风音频数据流到谷歌语音识别码，但我想从其他来源流音频代码。从这个来源我可以得到原始数据的缓冲区，而这个缓冲区是我想流到谷歌。可以有人帮助我或给一些有用的建议吗？我试图自己搜索和解决这个问题，但我找不到。这里是代码： from __future__ import division import contextlib import functools import re

0热度

1回答

如何从本地目录读取，kmeans流pyspark

我需要帮助从本地目录读取与pyspark运行kmeans流。有没有很好的答案在这个题目上的计算器这里是我的代码 if __name__ == "__main__": ssc = StreamingContext(sc, 1) training_data_raw, training_data_df = prepare_data(TRAINING_DATA_SET)

3热度

1回答

Go - 解码JSON，因为它仍然通过网络/ http进行流式传输

在过去，我使用go以如下所示的方式解码来自API端点的JSON。 client := &http.Client{} req, err := http.NewRequest("GET", "https://some/api/endpoint", nil) res, err := client.Do(req) defer res.Body.Close() buf, _ := ioutil.

0热度

1回答

阿卡流滑动窗口来控制减少发射由SourceQueue下沉

更新：我把我的问题在test project来解释我的意思详细 ============== ================================================== ===== 我有一个Akka源contiune从数据库表中读取，groupby一些关键然后减少它。但是，在我应用reduce函数后，似乎数据永远不会发送到sink，因为上游始终有数据到来，所以它会保持减少

0热度

1回答

流Json - PushStreamContent与大对象

我需要流大对象。我无法弄清楚如何分块发送。发布的代码工作，但是，stream.Flush（）只被调用一次。所以，基本上我是缓冲对象 - 不好。我如何拨打stream.Flush（）多次？如果我有一个集合，我可以在一个循环中流/冲洗。那么如何用大对象来做到这一点？服务器代码： public async Task<HttpResponseMessage> ConvertToTiffAsync([Fr

0热度

1回答

使用Golang将CSV转换为JSON - 在Web浏览器中打印时会跳过一些数据

我已经使用Golang读取了一个excel csv文件，并希望将它们作为JSON数据打印到Web浏览器中，但是每次打印时Web浏览器中的JSON数据会跳过一些数据。我已经加倍检查这些数据是否在csv文件中，但没有在网页浏览器中打印。任何帮助你可以建议我？由于事先 package main import ( "encoding/csv" "encoding/json" "fmt" "git

0热度

1回答

火花，卡桑德拉，流媒体，蟒蛇，错误，数据库，卡夫卡

即时试图将我的流数据从火花保存到卡桑德拉，火花接到卡夫卡，它的工作正常，但保存到卡桑德拉，使我变得疯狂。即时通讯使用火花2.0.2，卡夫卡0.10和2.23卡桑德拉，这是submiting如何IM引发 spark-submit --verbose --packages org.apache.spark:spark-streaming-kafka-0-8_2.11:2.0.0 --jars /tm

0热度

1回答

HEIF媒体可以流式传输吗？

HEIF（https://en.m.wikipedia.org/wiki/High_Efficiency_Image_File_Format）看起来像是一个很好的容器来替代很多图像格式。它可以使用HEVC进行视频。但是，就像视频格式一样，它可以流式传输还是逐步下载？例如，是否可以首先下载封面图像或缩略图，并在等待更大分辨率的图像时通过一个文件下载并显示给用户？

0热度

2回答

ffmpeg VBR - > CBR转换和MPEG-2 TS视频流的流式传输

我正尝试使用ffmpeg将源VBR SPTS MPEG-2 TS文件转换为CBR。我使用的代码如下： #!/bin/bash pkill ffmpeg ffmpeg \ -re -i source.ts -c copy \ -muxrate 18000K \ -f mpegts \ udp://destination_ip:1234?pkt_

-1热度

1回答

阅读现有的Avro文件并发送到Kafka

我有一个现有的Avro文件与模式。我需要将文件发送给Producer。以下是我写的代码。 public class ProducerDataSample { public static void main(String[] args) { String topic = "my-topic"; Schema.Parser parser = new Schem