为什么“等待”不等待 axios 请求完成？

Question

我尝试使用 axios 读取 HTTP 响应，并使用 stream-json 以流模式解析 JSON，这样我就可以按需完全适应我的数据库。它运行良好，但如果我尝试关闭数据库连接，一切都会崩溃，因为连接将很快关闭。 问题是：await 不会等待 extract_coins 函数完成（即使它正在返回承诺）并在最终范围内关闭数据库连接。

const main = async() => {
   const dbcfg = config.get('db.coins');
   const db = await coins_db_configure(dbcfg);
   try {
      console.log('Connected to the database and created coins table!');

      await extract_coins('some_url_which_gives_correct_json', coins_emitter);
   }
   catch(e){
      console.error(e);
   }
   finally {
      await db.close();
   }
   };

main();

extract_coins：

module.exports = async function extract_coins(url, emitter){
    return await axios({
        method: 'get',
        url: url,
        responseType: 'stream'
    }).then((res) => {
        const pipeline = chain([
            res.data,
            parser(),
            pick({filter: 'data'}),
            streamArray()
        ]);
        pipeline.on('data', data => {
            emitter.emit('coin_extracted', data.value);
        });
        pipeline.on('end', () => console.log("All the coins were successfully passed!"));
    });
};

Answer 1

由于与异步pipeline 相关的代码没有被承诺，您目前无法返回一个承诺，该承诺会在获得“结束”事件时解决。

您的await 确实等待承诺解决，但您的then 回调返回undefined，因此在那一刻解决了承诺，早于end事件正在广播。

所以改变这个：

then((res) => {
    const pipeline = chain([
        res.data,
        parser(),
        pick({filter: 'data'}),
        streamArray()
    ]);
    pipeline.on('data', data => {
        emitter.emit('coin_extracted', data.value);
    });
    pipeline.on('end', () => console.log("All the coins were successfully passed!"));
});

到这里：

then((res) => new Promise((resolve) => {
    const pipeline = chain([
        res.data,
        parser(),
        pick({filter: 'data'}),
        streamArray()
    ]);
    pipeline.on('data', data => {
        emitter.emit('coin_extracted', data.value);
    });
    pipeline.on('end', () => {
        console.log("All the coins were successfully passed!");
        resolve();
    });
}));

Answer 2

实际上，您使用 ES6+ 方式但不是以通用方式，这会导致此问题，但肯定的是，将 await 与 then 一起使用是错误的，您应该像这样编写它们以下代码：

const main = async () => {
   try {
     const dbcfg = config.get('db.coins');
     const db = await coins_db_configure(dbcfg);
     console.log('Connected to the database and created coins table!');
     await extract_coins('some_url_which_gives_correct_json', coins_emitter);

   } catch (e) {
      console.error(e);

   } finally {
      await db.close();

   }
};

main();

如你所见，我把所有代码都放在了try 块中，因为使用async/await 意味着我们假装写了一个sync 代码，但实际上它是async，所以我们应该将所有代码，尤其是异步行放在try 块内。将它们放入 try 块后，只是因为 () 后面的 async 标志 JavaScript 解释器等待每一行完成，如果每一行有错误，下一行将不会运行并且解释器落入 catch 块， finally 像现在一样在所有情况下运行。

好的，现在回到主要问题，extract_coins 函数：

export default (async function extract_coins(url, emitter) {
  try {
    const res = await axios({
      method: 'get',
      url: url,
      responseType: 'stream'
    });
    const pipeline = chain([
      res.data,
      parser(),
      pick({filter: 'data'}),
      streamArray()
    ]);
    await pipeline.on('data', data => {
      emitter.emit('coin_extracted', data.value);
    });
    await pipeline.on('end', () => console.log("All the coins were successfully passed!"));
    // HERE: return what you want

  } catch (e) {
    throw e;

  }

});

这是问题的原因，您应该使用新的 EcmaScript 方法传递 extract_coins 函数的承诺，而不是使用回调函数。

如果我想代替你，我会写extract_coins，如下所示：

const extract_coins = async (url, emitter) => {
  try {
    const res = await axios({
      method: 'get',
      url: url,
      responseType: 'stream'
    });
    const pipeline = chain([
      res.data,
      parser(),
      pick({filter: 'data'}),
      streamArray()
    ]);
    await pipeline.on('data', data => {
      emitter.emit('coin_extracted', data.value);
    });
    await pipeline.on('end', () => console.log("All the coins were successfully passed!"));
    // HERE: return what you want

  } catch (e) {
    throw e;

  }

};

export default extract_coins;