Actualmente, tengo un código que consulta desde la base de datos Neo4j y luego lo escribo en un archivo CSV en el servidor:
const session = driver.session(); const query = '<my query>'; var file = fs.createWriteStream('export.csv'); file.write('<some CSV header here'); await new Promise((resolve, reject) => { session.run(query).subscribe({ onNext: i => { file.write('<data of record i>'); }, onCompleted: () => { session.close() file.end() resolve() }, onError: error => { console.log(error) reject() } }) }) return response.download('export.csv');Todo está bien hasta ahora, tengo más datos en la base de datos, por lo que el proceso para escribir un archivo CSV lleva mucho tiempo, luego el cliente recibe un error de tiempo de espera.
Encontré un par de soluciones que usan pipe() para enviar la transmisión directamente al cliente, pero lo probé y fallé porque el resultado de session.run() es una transmisión no observable. ¿Hay alguna otra manera?
Nota: estoy usando AdonisJs para backend
Puede escribir datos directamente en la respuesta de esta manera:
const session = driver.session(); const query = '<my query>'; response.response.writeHead(200, { 'Content-Type': 'application/csv', 'Content-Disposition': 'attachment; filename="export.csv"' }); response.response.write('<some CSV header here'); await new Promise((resolve, reject) => { const results = session.run(query).subscribe({ onNext: i => { response.response.write('<data of record i>'); }, onCompleted: () => { session.close() response.response.end() resolve() }, onError: error => { console.log(error) reject() } }) })