Soy nuevo en Javascript y NodeJS. Estoy tratando de leer varios archivos CSV antes de procesarlos. Mi problema actual es que cuando ejecuto el código, intenta ejecutar el procesamiento antes de que se complete la lectura del archivo. Me gustaría cargar ambos CSV antes de comenzar a procesarlos.
¿Podría alguien explicar por qué sucede esto y cómo puedo resolver el problema en Javascript/NodeJS?
function readCSV(path){ var events = [] fs.createReadStream(path).pipe(csv()).on('data', (row) => { events.push(row); }).on('end', () => { console.log('CSV file successfully processed. Length: ' + events.length); }); return events } function app(){ var file_list = listFiles(folder_path); for (let i = 0; i < file_list.length; i++) { const file = file_list[i]; var events = readCSV(file) } processCSV(events) // Some processing } app();Cualquier ayuda sería excelente y cualquier explicación sobre cómo puedo controlar cuándo se ejecuta el código sería muy apreciada.
Lo sentimos, su código no se puede compilar, por lo que solo puede responder con código no probado
Mi problema actual es que cuando ejecuto el código, intenta ejecutar el procesamiento antes de que se complete la lectura del archivo.
El principal problema de que fs.createReadStream no lee el archivo es que solicita al sistema de archivos que comience a leer e informe sus devoluciones de llamada cuando se leyeron algunos fragmentos, por lo que el evento 'fin' se llamará coincidencia más tarde, cuando readCSV se completará y devolverá un resultado vacío.
Su código fue escrito como si esperara una respuesta síncrona, y puede hacer que funcione correctamente con el uso de métodos de sincronización como fs.readFileSync
¿Cómo solucionarlo de forma asíncrona? escriba el procesamiento de csv en la devolución de llamada "on (final)" o use promesas
Las promesas son más simples y lineales.
Primero haga readCSV para devolver Promise
function readCSV(path: string){ //return Promise<any[]> return new Promise((resolve) => { var events = []; fs.createReadStream(path) .pipe(csv()) .on('data', (row) => { // this code called in future events.push(row); }).on('end', () => { // this code called in future to, console.log('CSV file successfully processed. Length: ' + events.length); resolve(events); //return csv parsed result }); }) }luego, en la aplicación principal, use Promise.all para esperar todas las promesas de lectura de archivos
function app(){ // i don't know what is listFiles, // i hope it returns sync result var file_list = fs.listFiles(folder_path); const dataPromises: Promise[] = [] for (let i = 0; i < file_list.length; i++) { const file = file_list[i]; //launch reading dataPromises.push(readCSV(file)) } Promise.all(dataPromises).then(result => { //this code will be called in future after all readCSV Promises call resolve(..) for(const events of result){ processCSV(events); } }) }