我正在尝试使用虚拟数据创建一个文件。由于文件很大,有32 ^ 5个数据点,我使用的是写入流。但我看不到任何数据被写入文件。这可能是什么原因?
const faker = require('faker');
const fs = require('fs');
const os = require('os');
const MAX_DATA_POINTS = Math.pow(32, 5)
const stream = fs.createWriteStream('sample-data.csv', { flags : 'a' });
for(let i = 0; i < MAX_DATA_POINTS; i++) {
console.log(i)
stream.write(`${faker.name.findName()}, ${i} ${os.EOL}`);
}
console.log(`Written ${MAX_DATA_POINTS} .. `);
如果流希望调用代码在继续写入附加数据之前等待排出事件发出,则write
方法返回false
,否则返回true。流很可能没有耗尽,并且调用write()
只是缓冲块并返回false。
您需要等到所有缓冲的块都耗尽(接受操作系统交付)。当发生这种情况时,将发出排水事件。
注意:建议write()返回false后,在发出'drain'事件之前不再写入块。
您可以按照我给出的方式修改dummy-csv文件创建者代码。
const faker = require('faker');
const fs = require('fs');
const os = require('os');
const MAX_DATA_POINTS = Math.pow(32, 5);
let c = 0;
const stream = fs.createWriteStream('sample-data.csv', { flags : 'a' });
function write() {
let ok = true;
do {
c++;
ok = stream.write(`${faker.name.findName()}, ${c} ${os.EOL}`);
} while (c < MAX_DATA_POINTS && ok);
if(c < MAX_DATA_POINTS) {
stream.once('drain', write)
}
}
write()