不知道为什么节点会持续运行

Question

我不明白为什么这个应用程序一直在运行。我试过使用 why-is-node-running 包，但我不完全确定如何正确读取输出。这是它的第一个输出：

There are 30 handle(s) keeping the process running
    # TCPWRAP
    /node_modules/mongodb/lib/core/connection/connect.js:269 - socket = tls.connect(parseSslOptions(family, options));
    /node_modules/mongodb/lib/core/connection/connect.js:29  - makeConnection(family, options, cancellationToken, (err, socket) => {
    /node_modules/mongodb/lib/core/sdam/monitor.js:182       - connect(monitor.connectOptions, monitor[kCancellationToken], (err, conn) => {
    /node_modules/mongodb/lib/core/sdam/monitor.js:206       - checkServer(monitor, e0 => {
    /node_modules/mongodb/lib/core/sdam/monitor.js:92        - monitorServer(this); 

我的猜测是它与 MongoDB 没有正确关闭有关。虽然，当我在打开客户端和关闭客户端之间删除所有其他功能时，它完美地打开和关闭。

在末尾添加process.exit() 可以正确关闭程序，但我想弄清楚为什么它没有关闭。

该应用程序的摘要是它正在从 MongoDB 获取数据，清理它，然后将其写入 Firestore - 所以很多异步操作正在进行，但我没有看到与 Firestore 相关的东西弹出为什么节点运行日志。

const GrabStuffFromDBToCalculate = require("./helpers/GrabStuffFromDBToCalculate");
const SendToFirestore = require("./helpers/SendToFirestore");
const log = require("why-is-node-running");
const { MongoClient } = require("mongodb");
require("dotenv").config();

const main = async () => {
  try {
    const client = await MongoClient.connect(process.env.MONGODB_URI, {
      useNewUrlParser: true,
      useUnifiedTopology: true
    });
    const collection = await client.db("test").collection("testcollection");
    const trip_object = await GrabStuffFromDBToCalculate(collection);
    SendToFirestore(trip_object);
    client.close();
    log(); // "There are 30 handle(s) keeping the process running including node_modules/mongodb/lib/core/connection/connect.js:269 - socket = tls.connect(parseSslOptions(family, options));"
    // process.exit() // this closes everything but I'd rather not have to use this
  } catch (err) {
    console.log(err);
    client.close();
  }
};

const runAsync = async () => {
  await main(); // this exists because I'm usually running multiple main() functions
};

runAsync();

SendToFirestore 代码：

const firebase = require("firebase");
const firebaseConfig = require("../config");

module.exports = SendToFirestore = trip_object => {
  if (!firebase.apps.length) {
    firebase.initializeApp(firebaseConfig);
  }
  const db = firebase.firestore();
  db.doc(`hello/${object._id}`).set({
    objectid:object._id
  });
};

GrabStuffFromDBToCalculate 代码（简化方式）：

module.exports = GrabStuffFromDBToCalculate = async collection => {
  const cursor = await collection
    .aggregate([

        // does a bunch of stuff here

    ])
    .toArray();
  const newObj = cursor[0];
  return newObj;
};

Answer 1

将我的评论变成答案，因为它导致了丢失的部分。

节点没有关闭，因为您有一个打开的 Firestore 连接。您必须调用 terminate 以允许 SDK 关闭和释放资源：

db.terminate();

这与允许 nodejs 自动关闭有关。

---

另外，我不确定你是否理解我建议你使用await，就像在

await client.close()

在调用log() 之前，您可以确保在进行日志记录之前客户端连接已关闭。 client.close() 是一种异步方法，因此您的原始代码将在关闭完成之前 log()。