Estoy tratando de cargar archivos muy grandes en fragmentos a un servidor. El lado del servidor funciona muy bien. En la función que se me ocurrió, intenta cargar todos los archivos a la vez. Soy nuevo en async/await y no estoy seguro de cómo proceder. El objetivo es simplemente subir uno a la vez en fragmentos.
Tenga en cuenta que eliminé esto de una clase, actualicé para mayor claridad y eliminé todos los bits innecesarios.
Usando node-fetch para agregar fetch().
Gracias por cualquier ayuda o consejo :)
let tree = [] const start = () => { scan('/foo/bar', err => { tree.forEach(file => { upload(file) }) }) } const scan = dir => { ... } // assigns array of files to tree const upload = file => { const stream = fs.createReadStream(file) stream.on('data', async chunk => { stream.pause() try { let response = await fetch('https://some/endpoint', { method: 'post', body: JSON.stringify({ file: file, chunk: chunk.toString('base64') }) }) stream.resume() } catch(e) { // handle errors } }) stream.on('end', () => { console.log('end', file) }) stream.on('error', err => { console.log('error', err) }) }Array.prototype.forEach se ejecuta de forma síncrona hasta que se hayan procesado todos los elementos de una matriz, descartando cualquier valor devuelto por la función de argumento que llama.
Para cargar un archivo a la vez, intente usar await (dentro de una función asincrónica) para esperar a que se cargue cada archivo, en combinación con devolver una promesa del proceso de carga que se cumple cuando se completa una carga. Conceptualmente (sin un manejo elegante de errores) podría parecer
const uploadTree = async tree => { for( file of tree) { await uploadFile( file); // process files one at a time } } // wrap the existing upload code in a promise executor: const uploadFile = file => new Promise( (resolve, reject) => { const stream = fs.createReadStream(file) stream.on('data' ... ... } catch(e) { console.log( "Error uploading chunk of %s", file) reject(e) // handle errors } stream.on('end', resolve) stream.on('error', e=> { console.log(" Error reading %s", file) reject (e) }) }); // upload complete tree array files: uploadTree(tree) .then( ()=> console.log( "tree uploaded successfully")); .catch( err=> console.log("An upload failed: ", err));