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