javascript / intermediate
Snippet
Robuste Stream-Verarbeitung mit pipeline()
Das Pipeline-Utility ist eine sauberere und sicherere Alternative zu .pipe(), da es die Fehlerweiterleitung und die Bereinigung von Streams automatisch übernimmt und so Speicherlecks verhindert.
snippet.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
const { pipeline } = require('node:stream/promises');const { createReadStream, createWriteStream } = require('node:fs');async function compressLogs() {try {await pipeline(createReadStream('access.log'),createWriteStream('access.log.bak'));console.log('Pipeline succeeded');} catch (err) {console.error('Pipeline failed:', err);}}
nodejs
Erklärung
1
require('node:stream/promises')
Importiert die Promise-basierte Version des Stream-Moduls zur Verwendung mit async/await.
2
await pipeline(...)
Verbindet sequenziell mehrere Streams und wartet darauf, dass der gesamte Prozess abgeschlossen wird oder fehlschlägt.