如何等待异步函数导致nodejs

Question

我正在编写代码来添加与我的 json 数据中每一行对应的数据。 所有功能和代码编写都已完成。当所有数据都被调用后，它应该返回 json。 但在执行所有代码之前，它会返回 json。 所以即使所有代码都运行良好，json 总是返回一个空值。 请指教。

var request = require('request');
var axios = require('axios');

router.get('/geometric/getAddress', async (req, res) => {
    let confmKey = "secret";
    let resultType = "json";
    let countPerPage = "10"

    let page = appjs.vCheck(req.query.page, "");
    let kw = appjs.vCheck(req.query.keyword, "");

    var stmt = "http://10.10.100.12:8080/addr.do?";
    stmt = stmt + "currentPage=" + page; 
    stmt = stmt + "&countPerPage=" + countPerPage;
    stmt = stmt + "&resultType=" + resultType;
    stmt = stmt + "&confmKey=" + confmKey;
    stmt = stmt + "&keyword=" + qs.escape(kw)

    request(stmt, async (err, result) => {
        if (err) throw err;

        const con = JSON.parse(result.body);
        const juso = con.results.juso;


        var dd = ""
        let res_data = juso.map(async (addr) => {
            let admCd = appjs.vCheck(addr.admCd, "");
            let rnMgtSn = appjs.vCheck(addr.rnMgtSn, "");
            let udrtYn = appjs.vCheck(addr.udrtYn, "");
            let buldMnnm = appjs.vCheck(addr.buldMnnm, "");
            let buldSlno = appjs.vCheck(addr.buldSlno, "");

            axios.post("http://localhost:3001/web/api/geometric/coordinates",
                {
                    admCd : admCd,
                    rnMgtSn : rnMgtSn,
                    udrtYn : udrtYn,
                    buldMnnm : buldMnnm,
                    buldSlno : buldSlno
            }).then((d) => {
                return {
                    "roadAddr" : d.roadAddr,
                    "jibunAddr" : roadAddr,
                    "zipNo" : d.roadAddr,
                    "longitude" : roadAddr,
                    "latitude" : d.roadAddr
                }
            })
        })

        let aa = await Promise.all(res_data)
        res.json(aa)
    })
});

Answer 1

发生这种情况是因为您没有从 map 回调中返回任何承诺。你应该这样做：

let res_data = juso.map(async (addr) => {
  let admCd = appjs.vCheck(addr.admCd, "");
  let rnMgtSn = appjs.vCheck(addr.rnMgtSn, "");
  let udrtYn = appjs.vCheck(addr.udrtYn, "");
  let buldMnnm = appjs.vCheck(addr.buldMnnm, "");
  let buldSlno = appjs.vCheck(addr.buldSlno, "");

  return axios.post("http://localhost:3001/web/api/geometric/coordinates",
    {
      admCd : admCd,
      rnMgtSn : rnMgtSn,
      udrtYn : udrtYn,
      buldMnnm : buldMnnm,
      buldSlno : buldSlno
     })
   })

let aa = (await Promise.all(res_data)).map(({data: d}) => ({
  "roadAddr" : d.roadAddr,
  "jibunAddr" : roadAddr,
  "zipNo" : d.roadAddr,
  "longitude" : roadAddr,
  "latitude" : d.roadAddr
}));

res.json(aa)

Answer 2

由于您没有从map 函数返回任何promise，因此await Promise.all(res_data) 是微不足道的代码。

更新：

• Axios 库返回完整的 Promise，因此可以简单地从地图回调中返回。
• 然后可以等待这些返回的 Promise 并将其映射到所需的结果。

  let res_data = juso.map(async addr => {
  let admCd = appjs.vCheck(addr.admCd, "");
  let rnMgtSn = appjs.vCheck(addr.rnMgtSn, "");
  let udrtYn = appjs.vCheck(addr.udrtYn, "");
  let buldMnnm = appjs.vCheck(addr.buldMnnm, "");
  let buldSlno = appjs.vCheck(addr.buldSlno, "");

  return axios.post("http://localhost:3001/web/api/geometric/coordinates", {
    admCd: admCd,
    rnMgtSn: rnMgtSn,
    udrtYn: udrtYn,
    buldMnnm: buldMnnm,
    buldSlno: buldSlno
  });
});

然后await 用于返回的承诺（try/catch 用于任何失败的承诺或Promise.all(res_data).then().catch(e) 也用于处理错误）：

await Promise.all(res_data)
  .then(resolvedPromises => {
    const aa = resolvedPromises.map(d => ({
      roadAddr: d.roadAddr,
      jibunAddr: d.roadAddr,
      zipNo: d.roadAddr,
      longitude: d.roadAddr,
      latitude: d.roadAddr
    }));

    return res.json(aa);
  })
  .catch(e => {
    //handle error because one of those axios promises failed: e.message
  });