ES8 비동기/대기를 스트림과 함께 사용하는 방법은 무엇입니까?
https://stackoverflow.com/a/18658613/779159 에서는 기본 제공 암호화 라이브러리 및 스트림을 사용하여 파일의 md5를 계산하는 방법에 대한 예를 보여 줍니다.
var fs = require('fs');
var crypto = require('crypto');
// the file you want to get the hash
var fd = fs.createReadStream('/some/file/name.txt');
var hash = crypto.createHash('sha1');
hash.setEncoding('hex');
fd.on('end', function() {
hash.end();
console.log(hash.read()); // the desired sha1sum
});
// read all file and pipe it (write it) to the hash object
fd.pipe(hash);
그러나 위와 같이 콜백을 사용하는 대신 스트림을 사용하는 효율성을 유지하면서 ES8 비동기/대기를 사용하도록 변환할 수 있습니까?
그await키워드는 스트림이 아닌 약속에서만 작동합니다.독자적인 구문을 얻을 수 있는 추가 스트림과 같은 데이터 유형을 만들 수 있는 아이디어가 있지만, 이는 매우 실험적이며 자세한 내용은 설명하지 않겠습니다.
어쨌든, 당신의 콜백은 스트림의 종료만을 기다리고 있는데, 이것은 약속에 완벽하게 들어맞는 것입니다.스트림을 포장하면 됩니다.
var fd = fs.createReadStream('/some/file/name.txt');
var hash = crypto.createHash('sha1');
hash.setEncoding('hex');
// read all file and pipe it (write it) to the hash object
fd.pipe(hash);
var end = new Promise(function(resolve, reject) {
hash.on('end', () => resolve(hash.read()));
fd.on('error', reject); // or something like that. might need to close `hash`
});
최신 버전의 nodejs(스트림/프로미스 모듈에서)에서도 이를 수행할 수 있는 도우미 기능이 기능은 다음과 같습니다.
import { pipeline } from 'node:stream/promises';
const fd = fs.createReadStream('/some/file/name.txt');
const hash = crypto.createHash('sha1');
hash.setEncoding('hex');
// read all file and pipe it (write it) to the hash object
const end = pipeline(fd, hash);
이제 그 약속을 기다릴 수 있습니다.
(async function() {
let sha1sum = await end;
console.log(sha1sum);
}());
노드 버전 >= v10.0.0을 사용하는 경우 stream.syslog 및 util.sysify를 사용할 수 있습니다.
const fs = require('fs');
const crypto = require('crypto');
const util = require('util');
const stream = require('stream');
const pipeline = util.promisify(stream.pipeline);
const hash = crypto.createHash('sha1');
hash.setEncoding('hex');
async function run() {
await pipeline(
fs.createReadStream('/some/file/name.txt'),
hash
);
console.log('Pipeline succeeded');
}
run().catch(console.error);
이제 노드 V15에 스트림/프로미스의 프로미스파이 파이프라인이 있습니다.이것이 가장 깨끗하고 공식적인 방법입니다.
const { pipeline } = require('stream/promises');
async function run() {
await pipeline(
fs.createReadStream('archive.tar'),
zlib.createGzip(),
fs.createWriteStream('archive.tar.gz')
);
console.log('Pipeline succeeded.');
}
run().catch(console.error);
우리 모두는 여기서 얼마나 많은 일을 하는지 감사해야 합니다.
- 모든 스트림에서 오류를 캡처합니다.
- 오류가 발생하면 완료되지 않은 스트림을 파괴합니다.
- 쓰기 가능한 마지막 스트림이 완료된 경우에만 반환됩니다.
이 파이프는 가장 강력한 기능 노드 중 하나입니다.JS가.완전히 비동기화하는 것은 쉽지 않습니다.이제 우리는 있습니다.
2021 업데이트:
노드 설명서의 새 예:
async function print(readable) {
readable.setEncoding('utf8');
let data = '';
for await (const chunk of readable) {
data += chunk;
}
console.log(data);
}
https://nodejs.org/api/stream.html#stream_readable_symbol_asynciterator 을 참조하십시오.
다음과 같은 것이 작동합니다.
for (var res of fetchResponses){ //node-fetch package responses
const dest = fs.createWriteStream(filePath,{flags:'a'});
totalBytes += Number(res.headers.get('content-length'));
await new Promise((resolve, reject) => {
res.body.pipe(dest);
res.body.on("error", (err) => {
reject(err);
});
dest.on("finish", function() {
resolve();
});
});
}
누군가에게 도움이 될 것이라고 믿습니다.
async function readFile(filename) {
let records = []
return new Promise(resolve => {
fs.createReadStream(filename)
.on("data", (data) => {
records.push(data);
})
.on("end", () => {
resolve(records)
});
})
}
저는 논평하고 싶지만, 평판이 충분하지 않습니다.
주의 사항: 스트림을 전달하고 비동기/대기를 수행하는 응용 프로그램이 있는 경우 대기하기 전에 모든 파이프를 연결하도록 매우 주의하십시오.스트림이 생각했던 것을 포함하지 않는 결과를 초래할 수 있습니다.다음은 최소한의 예입니다.
const { PassThrough } = require('stream');
async function main() {
const initialStream = new PassThrough();
const otherStream = new PassThrough();
const data = [];
otherStream.on('data', dat => data.push(dat));
const resultOtherStreamPromise = new Promise(resolve => otherStream.on('end', () => { resolve(Buffer.concat(data)) }));
const yetAnotherStream = new PassThrough();
const data2 = [];
yetAnotherStream.on('data', dat => data2.push(dat));
const resultYetAnotherStreamPromise = new Promise(resolve => yetAnotherStream.on('end', () => { resolve(Buffer.concat(data2)) }));
initialStream.pipe(otherStream);
initialStream.write('some ');
await Promise.resolve(); // Completely unrelated await
initialStream.pipe(yetAnotherStream);
initialStream.end('data');
const [resultOtherStream, resultYetAnotherStream] = await Promise.all([
resultOtherStreamPromise,
resultYetAnotherStreamPromise,
]);
console.log('other stream:', resultOtherStream.toString()); // other stream: some data
console.log('yet another stream:', resultYetAnotherStream.toString()); // yet another stream: data
}
main();
언급URL : https://stackoverflow.com/questions/33599688/how-to-use-es8-async-await-with-streams