如何解决如何通过 Node.js/AdonisJs 从 Neo4j 查询结果发送 CSV 数据
目前,我有一些代码从 Neo4j
数据库查询,然后写入服务器上的 CSV 文件:
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');
一切都很好,直到现在我在数据库中有更多数据,因此写入 CSV 文件的过程需要很长时间,然后客户端收到超时错误。
我找到了几个使用 pipe()
将流直接发送到客户端的解决方案,但我尝试了它并失败了,因为 session.run()
的结果是一个可观察的非流。还有其他办法吗?
注意:我使用 AdonisJs 作为后端
解决方法
您可以像这样直接将数据写入响应中:
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()
}
})
})
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。