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