我正在使用S3fs从s3桶中读取pdf文本。readFile,我想得到的结果,转换成字符串,并立即打开一个spawn child_process调用pdftotext,传递字符串:
S3Fs.readFile('./my-pdf-in-s3-bucket', {encoding: 'binary'}, (error, result) => {
mychild = child_process.spawn('pdftotext', [
result.Body
]);
});
这会导致spawn进程中断,因为字符串太长,我不想将文件保存在磁盘中只是为了再次读取它。
有可能吗?
谢谢!
pdftotext应该允许从标准输入读取并写入标准输出(至少它在v0.41.0中对我有效),所以您可以这样做:
S3Fs.readFile('./my-pdf-in-s3-bucket', (err, result) => {
if (err) throw err; // Handle better
var cp = child_process.spawn('pdftotext', [ '-', '-' ]);
cp.stdout.pipe(process.stdout);
cp.on('close', (code, signal) => {
console.log(`pdftotext finished with status ${code}`);
});
cp.stdin.end(result);
});
或者更好的是,您可以将文件流式传输到子进程,而不是首先将其全部内容缓冲在内存中:
var cp = child_process.spawn('pdftotext', [ '-', '-' ]);
var rs = S3Fs.createReadStream('./my-pdf-in-s3-bucket');
rs.on('error', (err) => {
cp.kill();
});
cp.stdout.pipe(process.stdout);
cp.on('close', (code, signal) => {
console.log(`pdftotext finished with status ${code}`);
});
rs.pipe(cp.stdin);