stream

    0熱度

    1回答

    我有一個用作事件記錄器的Spring Boot應用程序。每個客戶端通過REST api發送不同的事件,然後保存在數據庫中。但除了簡單事件之外,我還需要客戶將其執行日誌發送到Spring Boot。 現在,在客戶端執行完成後上傳日誌很容易,並且有很多示例。我需要的是在客戶端正在執行時逐行傳輸日誌,而不是等到客戶端完成。 我花了很長時間搜索一個可能的答案,我找不到任何符合我需要的東西。任何建議如何使用

    2熱度

    2回答

    我想流的數據收集到多個文件與下面的代碼: for (var key in data) { // skip if collection length is 0 if (data[key].length > 0) { // Use the key and jobId to open file for appending let filePath = folder

    0熱度

    1回答

    我需要用Swagger使用NodeJS編寫上傳代碼。要求是創建兩個調整大小的文件並將它們發送到AWS S3。我可以這樣做: 將傳入的文件保存在磁盤上。 打開原始文件,調整大小(版本1)並將其保存在磁盤上。 再次打開原始文件,調整其大小(版本2)並將其保存在 磁盤上。 從VERSION1創建流1 從版本2 創建流2發送兩個流,以S3 刪除殘留文件 我所尋求的是建立從輸入流調整大小的文件飛行並將它們發

    1熱度

    1回答

    我正在製作一個應用程序,記錄用戶在說什麼,並將其保存到文件中。爲了從麥克風獲得聲音,我正在使用node-microphone包。我的應用程序目前能夠從麥克風獲得聲音。但是,當我嘗試將流寫入音頻文件並播放它時,出現以下錯誤。 Windows Media Player無法播放該文件。播放器可能不支持文件類型 ,或者可能不支持用於壓縮文件的編解碼器 。 有誰知道如何將音頻寫入節點中的文件? var fs

    7熱度

    1回答

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

    2熱度

    1回答

    我想要一個find函數用於大小有界類型的流,類似於列表和查找函數。 total find : MaxBound a => (a -> Bool) -> Stream a -> Maybe a 的挑戰是它,使其: 是總 消耗不超過 恆定 log_2Ñ空間,其中N是編碼最大a所需的比特的數量。 時間不超過一分鐘,以檢查在編譯時 沒有徵收成本運行 通常對於流的總能找得到實現聽起來荒謬。流是無限的,

    2熱度

    1回答

    我正在接收和使用原始正文的http post請求,並且正在嘗試將http正文讀入String中。 我使用dotnet web命令生成的基本Hello World網絡項目。按照documentation: In the .NET Framework 4 and earlier versions, you have to use methods such as BeginRead and EndRea

    0熱度

    1回答

    使用滑塊旋轉的Facebook饋送時出現錯誤。當我在本地使用它時,它完美地工作,但當我在普通的URL中啓動它時,出現此錯誤:Revolution Slider Error: Failed to load Stream。 我是否必須改變我的.htaccess或php.ini中的內容? 感謝

    0熱度

    1回答

    我正在嘗試使用python將來自Raspberry Pi的視頻流傳輸到我的機器。因此,我需要將套接字連接到服務器。 (流視頻直接在192.168.0.6:8081從RPI執行這些之前) 在我的電腦上我執行此代碼: import numpy as np import cv2 import socket class VideoStreamingTest(object): def

    1熱度

    1回答

    我需要創建base64字符串,我需要發送到第三方API。我有流和緩衝區。表單流我能夠創建一個圖像,所以沒有辦法破壞流。這裏有兩個變量: var newJpeg = new Buffer(newData, "binary"); var fs = require('fs'); let Duplex = require('stream').Duplex; let _updatedFileStr