如何通过 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()
    }
  })
})