Este es mi código para obtener una matriz de registros y escribirlos como cadena CSV uno por uno en un archivo. No puedo obtener la secuencia de escritura para escribir en el archivo. Simplemente borra todo lo que hay en el archivo y no escribe los nuevos datos.
const writeStream = fs.createWriteStream(process.env.SAVED_FILE); const transformStream = new Stream.Transform({ writableObjectMode: true, readableObjectMode: true, }) transformStream._transform = (chunk, encoding, callback) => { console.log(chunk); transformStream.push("\"" + chunk.join("\",\"") + "\""); callback(); } const readable = new Stream.Readable({objectMode: true}) .pipe(transformStream) .pipe(writeStream); let records = [["a", "b"], [1, 2], ["c", "d"], [8, 9]]; records.forEach(record => readable.push(record)); readable.push(null); writeStream.on("error", function (err) { console.log("there is an error!") }); writeStream.on("end", function () { console.log("reached the end of the stream!") });¡Cualquier ayuda apreciada en este ejemplo básico!
El método pipe() devuelve el flujo de destino, es decir, el flujo de escritura.
En tu código,
const readable = new Stream.Readable({objectMode: true}) .pipe(transformStream) .pipe(writeStream); readable no contiene una referencia a una secuencia legible como espera. En su lugar, se refiere al último flujo de la cadena, es decir, writeStream y no puede llamar a push en un flujo de escritura.
Cambie su código como se muestra a continuación:
const readable = new stream.Readable({ objectMode: true }); readable .pipe(transformStream) .pipe(writeStream);