streaming

0热度

2回答

我正在使用MediaStreamRecorder，它跟在MediaRecorder API之后用于录制跨浏览器的音频和视频流。我面临的问题是，只要浏览器窗口最小化，MediaStreamRecorder就会停止触发其ondataavailable事件。一旦你最小化它停止触发ondataavailable事件，即使我回到相同的窗口，也不会触发，除非或直到我停止录制并重新启动它。它不会在浏览器控制

0热度

2回答

减少HLS流式传输的延迟FFMPEG

我使用hls流式传输通过ffmpeg。在数据流开始延迟存在几秒钟。当我想从一个4k的视频流中存在非常延迟的时候。我能做什么？

0热度

1回答

Django 1.11通过块下载文件块

在我的情况下，我有Django 1.11服务器充当代理。当您从浏览器中点击“下载”时，它会向django代理发送请求，从其他服务器下载文件并对其进行处理，然后将其发送到浏览器以允许用户下载。我的代理通过块下载并处理文件块。如何在浏览器准备就绪时向浏览器发送块，以便用户最终下载单个文件？在实践中，我必须让你下载一个尚未准备好的文件，比如流。 def my_download(self, res)

0热度

1回答

使用PHP从服务器流式传输视频

我需要将Web服务器上选定的视频文件传输到客户端。我正在使用PHP脚本根据请求流式传输这些文件，但是我遇到了一个问题，如果我在本地网络上，它可以正常工作，但如果我是远程的，它会结束。例如。它似乎加载流，停止，加载更多，停止等，直到有足够的媒体可用于播放。我对这个东西很陌生，所以我需要一些关于如何解决这个问题的建议。带宽不应该是一个问题，所以我不知道发生了什么。我已经尝试了几个PHP的飘带，但所有的

0热度

1回答

streamify JSON对象并将其作为料流[的NodeJS]

我使用request-promise NPM LIB用于使从应用程序的NodeJS多requestes到Java泽西2.0 API后端。由于request使用form-data LIB拨打电话，我把它只能发送字符串，缓冲区和溪流。在Java后端侧，我期待POJO对象为@FormDataParam S： @GET @ApiOperation( value = "Gets party m

1热度

1回答

未指定Spark-shell路径例外

我在Linux上使用2.1版的spark shell。 ./bin/spark-shell --packages org.apache.spark:spark-sql-kafka-0-10_2.11:2.1.0 星火壳以及启动没有任何问题。 val ds1 = spark.readStream.option("kafka.bootstrap.servers", "xx.xx.xxx.xxx:909

1热度

1回答

斯卡拉阿卡-HTTP - 一个预建的JSON对象完整的GET请求并流呢

我想通过返回预建JsonArray完成一个GET请求，并找到一种方法来流呢。我可以很容易地完成请求没有任何错误，并返回JSON，如果我转换JsonArray为字符串，像这样： get { path("getJsonData") { parameterMap { params => complete(HttpEntity(ContentTypes.`app

0热度

1回答

从卡夫卡发送CSV到Spark Streaming

我想从卡夫卡发送一个csv文件到火花流应用程序，我不知道该怎么做。我在这里阅读了很多文章，但没有人帮助我。我希望我的卡夫卡制作者发送csv并稍后在应用程序（消费者）中进行拆分，但这并不重要。我试图创建一个RDD并发送它。这适用于正常的字符串消息，但它不适用于csv。这是我的制片人： message =sc.textFile("/home/guest/host/Seeds.csv") pr

0热度

1回答

Solr 6流媒体评估器错误 - 发现未知的操作数

我正在尝试使用solr流与流evalutors（6.5版solr）。我遇到solr streaming错误。请让我知道我做错了什么。 select( search(loc-1215, q=*:*, fq="LOCATION_POINTS:[100 TO 300]", fl="id,LOCATION_POINTS", sort="id asc", qt="/export", partitionKey

1热度

1回答

卡夫卡流火花不减少计数

我正在尝试从kafka到火花流的基本示例。我很新火花并没有什么经验。我的程序如下（在Apache的火花的例子复制）： if (args.length < 4) { System.err.println("Usage: JavaKafkaWordCount <zkQuorum> <group> <topics> <numThreads>"); System.exit(1);