streaming

    0熱度

    1回答

    我目前正在處理一個代碼,以流twitter的帖子,並將它們保存到json文件。同時,textblob決定推文的情緒。 目前爲止所有工作都正常,但並未將所有輸出保存到文件中。它目前保存推文,但不保存textblob計算的情感分數。這是在Python我的第一天編碼和我欣賞的幫助每一位:) import textblob as textblob from tweepy import Stream f

    0熱度

    1回答

    我們最近遇到了一個問題,卡夫卡經紀人遇到了阻止IO的內核問題(但是我能夠心跳回到zookeeper)。這樣做的結果是卡夫卡經紀人留在ISR集,但實際上無法完成任何任務。 的問題是: 1)是否有什麼卡夫卡檢查它發出心跳之前,還是僅僅是弱智化發射心跳(我看https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Pro

    1熱度

    1回答

    使用REST和RESTEasy和Swagger,有什麼方法可以通過GET端點將數據流回調用方?我已經看到了一些可以返回整個流的例子,但是我沒有看到任何可以實際回傳數據的例子。我也看過這個例子(接下來從這個鏈接Return File From Resteasy Server),但是,這個例子看起來像它正在返回一個流,並希望調用方利用流?這是一個正確的假設嗎?: @GET @Produces(Med

    0熱度

    1回答

    我正在爲這段安靜的時間而苦苦掙扎,我決定需要幫助。 這裏描述的基本思路:Link 我想在錄製時將MediaRecorder的輸出直接流式傳輸到我的服務器套接字上。 (在這個特定的情況下,我想看看這是不可能的,只需通過HTTP-POST使用任何流協議。) 我目前的方法的錯誤是:E/MediaRecorder:啓動失敗:-2147483648 - RuntimeException 之前,我曾指點我到這

    7熱度

    1回答

    我有兩個要合併的數據流。問題是一個數據流的頻率比另一個高得多,並且有時候一個數據流根本沒有接收到事件。是否有可能使用來自一個流的最後一個事件並將其與每個即將到來的事件的另一個流加入? 我發現的唯一解決方案是使用連接函數,但您必須指定一個公共窗口,您可以在其中應用連接函數。這是未達到的窗口,當一個流沒有收到任何事件。 是否有可能將連接函數應用於來自任何一個流或另一個流的每個事件,並維護上次使用事件的

    0熱度

    1回答

    我正在使用我在互聯網上找到的不同代碼與AR Drone 2.0進行視頻流式傳輸。 我試圖ffplay tcp://192.168.1.1:5555來自AR Drone 2.0的視頻流;然而,延遲太高。 我的第二次嘗試下列要求: var arDrone = require('ar-drone'); var http = require('http'); console.log('Connect

    1熱度

    1回答

    我正在尋找一個標準的Python 2.7包提供一個HTTP服務器,同時執行流連接在同一個端口號。 嘿你是主持人那裏,請停止標記我的問題作爲想要以非流式方式提供服務的問題的副本,例如:Multithreaded web server in python。不,我不想要諸如ThreadingMixIn這樣的黑客,它只收集響應並將其作爲一個單元返回。 換句話說,我正在尋找標準的方式去做下面的例子程序 -

    0熱度

    1回答

    我想在WebView中播放直播電視。 WebView在頁面中顯示黑屏直播流區域,但不會加載和播放流。 wv.setWebChromeClient(new WebChromeClient());(mainactivity) 和 安卓硬件加速= 「真」(manifest.xml文件)不工作 wv = (WebView) findViewById(R.id.wv); wv.setWebChromeCl

    0熱度

    1回答

    我目前正在設置一個HLS流服務器,我需要用客戶端進行測試。我正在使用VLC。 我的目標是知道客戶端加載視頻需要多長時間。 我的第一個想法是在VLC上啓動視頻並用經典時鐘對其進行計時,但我需要更準確的信息。 是否有可能通過Vlc命令行獲取這類信息? 謝謝

    0熱度

    1回答

    我有一個應用程序,其中多個用戶可以發送REST操作來修改共享對象的狀態。 修改對象時,會發生多個操作(數據庫,審計,日誌記錄...)。 並非所有操作都是有效的,例如,您不能在刪除對象後修改它。 使用卡夫卡我在想下面的架構: 休息操作排隊卡夫卡話題。 對同一對象的操作將進入同一分區。因此,所有的對象的操作將在序列和由消費者 消費者聽分區處理,使用內存數據庫 確認操作如果操作是有效的,那麼被髮送到一個