Node.js Express 不等待异步等待

我相信问题出在函数的第一行......getCars()

await fs.readFile(__dirname + '/cars.json', function (err, data) {
}

您不能等待在回调中返回结果的函数。使用 readFile 的“sync”版本并从中删除 await/async，或者使用 readFile 的混合版本：getCars()

try {
const data = await fs.promises.readFile(filepath, 'utf8');
} catch (e) {
 // handle errors herer
}

首先应了解同步/异步概念。这是我的解决方案。

import express from 'express'
import { readFile } from 'fs'
import { dirname } from 'path'
import { fileURLToPath } from 'url'
import { promisify } from 'util'

const app = express()

const readFileAsync = promisify(readFile)

const __filename = fileURLToPath(import.meta.url)
const __dirname = dirname(__filename)

const getCars = async () => {
  const file = await readFileAsync(`${__dirname}/cars.json`, 'utf8')
  const cars = JSON.parse(file)

  // DO YOUR LOGIC HERE

  return cars
}

app.get('/', async (req, res) => {
  try {
    const cars = await getCars()
    res.json(cars)
  } catch (error) {
    console.log(error)
  }
})

app.listen(7777, () => {
  console.log('Example app listening on port 7777!')
})

我看到的唯一问题是您将 async/await 与回调概念混合在一起。只需将所有回调替换为 async/await 并将它们包装在 try/catch 周围即可。

const getCars = async () => {
    // TODO: Replace this with a call to the database
    try {
        const data = await fs.readFile(__dirname + '/cars.json') 
            let cars = JSON.parse(data)
        
            //Groups the cars to their location, to be sorted and chosen based on arrivalDate
            const groupBy = (xs, f) => {
              return xs.reduce(
                (r, v, i, a, k = f(v)) => ((r[k] || (r[k] = [])).push(v), r),
                {}
              )
            }
        
            const result = groupBy(cars, (c) => c.locationName)
        
            Object.keys(result).forEach((car) => {
              console.log(car)
              // filters out cars with no arrival dates
              let filtered = result[car].filter(obj => Object.keys(obj).includes("arrivalDate"));
        
              //Sort cars by the last update time
              filtered.sort(function (a, b) {
                let keyA = new Date(a.arrivalDate.toString().split(' ')[0]),
                  keyB = new Date(b.arrivalDate.toString().split(' ')[0])
                // Compare the 2 dates
                if (keyA < keyB) return -1
                if (keyA > keyB) return 1
                return 0
              }).reverse()
              
        
              //Add the top two (latest) of each car to the new array  
              emailCars = [...emailCars, { [car]: [ result[car][0], result[car][1] ]}]
        
            })
            console.log('returning' + emailCars)
            return emailCars
    } catch (e) {
        console.log(e);
    }
    
  }

如果您在理解此概念时遇到任何困难，请查看此链接。

如果我这样做，它会返回所有排序的数据，但我只需要 对象中每个子数组的前 2 个（这就是 emailCars 确实，只获取每个数组中的前 2 个对象）。或者我应该做 而不是在 /get 函数中？

任何实用程序函数都应正确组织，以保持应用程序的正确结构。路由不应该包含太多逻辑，逻辑应该放在控制器或类似的东西下。

您需要设计自己的逻辑，如果您遇到任何问题，欢迎您在此平台上提问。