node-streams

0熱度

1回答

因此，我創建了一個讀取流，首先連接到SFTP並開始從文件讀取。在任何時候，我的代碼都可以重新設置readstream並執行其他操作。例如，我可能會使用它來獲取CSV的前幾行並停止閱讀。問題是，我不知道如何在我的readStream構造函數中偵聽unpipe事件，以便我可以正確關閉SFTP連接。我在寫入流中使用flush方法，是否有類似於讀取流的方法？這裏是我的readStream構造的簡化部分

6熱度

2回答

如何使用對象列表作爲吞嚥源流

我知道，吞嚥需要乙烯源流才能正常工作，但有沒有簡單的方法來使用已經存在的乙烯基文件或json對象，而不是衆所周知的gulp.src只需要球體？

1熱度

1回答

如何從一個流中讀取並一次寫入多個？

假設我有一個readable流，例如， request(URL)。我想通過fs.createWriteStream()將它的回覆寫在磁盤上，並在請求中填入管道。但同時我想通過crypto.createHash()流來計算下載數據的校驗和。 readable -+-> calc checksum | +-> write to disk 而且我想要在飛行中完成，而不是在

0熱度

1回答

節點流：等待，直到數據可用

我有3個流（A，B，C），它們被傳送到另一個（A-> B-> C）。當我啓動我的程序B的_read get立即被調用，因爲它是通過管道傳輸給C的。但是，B流中沒有數據，而A作爲數據異步獲取。一旦B接收到傳遞給B的_write方法的數據，它就會轉換數據併發出一個'可讀的'事件（我手動啓動 - 這是這樣做的方式嗎？）。然而沒有任何反應，B中的數據沒有被任何人使用（因此B的_read未被調用）。我可

2熱度

1回答

Node.js流/管道錯誤處理（更改錯誤響應狀態）

我在我的Cassandra數據庫中有數百萬行，我想在一個zip文件中將數據流傳輸到客戶端（不希望在記憶）。我使用Cassandra-Node驅動程序中的stream（）函數，通過管道傳輸到一個Transformer，該Transformer從我關心的每一行中提取一個字段並追加一個換行符，並通過管道將哪些管道歸檔到Express Response對象。這似乎工作正常，但我不知道如何正確處理流中的錯誤

2熱度

1回答

Node.js流轉換是否保持塊的順序？

我看到的是，Node.js的流API在變換流使用異步功能，當他們到達改造大塊： https://nodejs.org/api/stream.html#stream_transform_transform_chunk_encoding_callback 是否變換流發送的塊以相同的順序，他們到達？因爲使用異步函數，這不是明確的情況。

0熱度

1回答

運行一個進程並將stdin/strout重定向到特定文件

我需要運行一個子進程，然後它將在後臺運行;同時，我想操縱它的輸出（添加時間戳等）並將其重定向到特定文件。目前，我這樣做： try { var out = fs.createWriteStream(`${this.logdir}/${lp}-out.log`, { flags: 'a', defaultEncoding: 'utf8' }); var err = fs.crea

0熱度

1回答

如何通過帆線水線模型將數據流式傳輸到帆式插座？

我下面的Sails documentation // Start the stream. Pipe it to sockets. User.stream({name:'Walter'}).pipe(req.socket.emit); 給出的簡單的例子，我打這個錯誤 TypeError: dest.on is not a function at Stream.pipe 任何想法可

1熱度

1回答

從卡桑德拉流數據到文件考慮背壓

我有節點應用程序收集投票提交併將它們存儲在卡桑德拉。選票存儲爲base64編碼的加密字符串。該API有一個名爲/export的端點，它應該獲得所有這些投票字符串（可能> 100萬），將它們轉換爲二進制，並將它們一個接一個地追加到votes.egd文件中。該文件應該被壓縮併發送到客戶端。我的想法是流從卡桑德拉行，轉換每個投票字符串爲二進制，並寫入WriteStream。我想將此功能包裝在Promi

0熱度

2回答

獲取ReadStream的哈希值和流的輸出數據

我有一個ReadStream，我想多次讀取。 readStream是使用fs.createReadStream創建的。我用它來得到它的md5哈希第一次，我與模塊hasha，功能fromStream，而我使用它與FormData上傳文件到虛擬主機的第二次這樣做。如何使用這一個ReadStream來完成這兩件事？ readStream = fs.createReadStream("/tmp/tes