fs.readstream 读取对象，然后通过管道传输到可写文件？

Question

目前我有一个模块可以拉取这样的 sql 结果：

[{ID: 'test', NAME: 'stack'},{ID: 'test2', NAME: 'stack'}]

我只想将其直接写入文件，以便稍后将其作为对象读取，但我想通过流写入它，因为某些对象确实非常巨大，并且将它们保存在内存中不再起作用。

我正在使用 mssql https://www.npmjs.org/package/mssql

我被困在这里：

    request.on('recordset', function(result) {
        console.log(result);
    });

如何将其流式传输到可写流？我看到了对象模式的选项，但我似乎不知道如何设置它？

    request.on('recordset', function(result) {
        var readable = fs.createReadStream(result),
            writable = fs.createWriteStream("loadedreports/bot"+x[6]);
        readable.pipe(writable);
    });

这只是错误，因为 createReadStream 必须是文件路径...

我是在正确的轨道上还是我需要做其他事情？

Answer 1

您几乎走在了正确的轨道上：您只是不需要可读流，因为您的数据已经以块的形式到达。

然后，您可以在实际'recordset'-Event 之外创建可写流，否则每次获得新块时都会创建一个新流（这不是您想要的）。

试试这样：

 var writable = fs.createWriteStream("loadedreports/bot"+x[6]);
 request.on('recordset', function(result) {
    writable.write(result);
 });

编辑

如果记录集已经太大，使用row-Event:

   request.on('row', function(row) {
   // Same here
   });