为什么await不在fs中等待

Question

我试图解析 csv 文件，根据获取的信息，我正在使用它进行 api 调用。

代码如下：

let booklist = [];
let updatedBook;
fs.createReadStream("Book1.csv")
.pipe(csv())
.on('data', async function(data){
  console.log("data");
  updatedBook = await apiCall(data.title, data.author, booklist);
})
console.log(updatedBook);
return updatedBook;

这里的预期行为是打印data，执行apiCall()函数，获取CSV文件中的下一个数据，打印data，执行apiCall()等等。

但是，await 不会完成 apiCall 并读取 CSV 文件中的下一个数据。所以，最后，它只返回未定义的updatedBook。

如果我睡 10 秒并等待所有 apiCall 完成，它会返回正确的 updatedBook，但我认为这不是正确的做法。

我在这里缺少什么？ await 不应该在这个特定的功能中工作吗？

您的回答将不胜感激！谢谢！！

Answer 1

只需“等到”读取 csv 文件完成，尝试捕获 'finish' 事件，然后将其全部包装到 Promise 中，在 Promise 中，我们更新调用 update books。

（您可以使用error 事件覆盖读取文件错误情况）

const yourFunctionName = async () => {
  let booklist = [];
  let updatedBooks = []; // I think you have too many books to update.

  await new Promise((resolve) => {
    fs.createReadStream("Book1.csv")
      .pipe(csv())
      .on('data', async function (data) {
        console.log("data");
        const updatedBook = await apiCall(data.title, data.author, booklist);
        updatedBooks.push(updatedBook); //
      })
      .on('finish', () => { // fires when no more data will be provided.
        resolve(); // I'm done, go to `console.log(updatedBooks);`
      });
  });
  console.log(updatedBooks);
  return updatedBooks;
}

至于为什么会发生这种情况：await，如您所知，在异步函数中工作。这意味着await 仅适用于调用它的上下文。基本上，您的代码会看到“异步”功能 - 它已经将其标记为异步并将其发送到事件循环。因此，“await”只会阻止它找到的函数内部的执行，但主代码仍会运行。这就是为什么您必须在同一个异步函数中进行与“等待”功能相关的数据转换。