node.js - Knex.js - Node 进程永远不会退出,如何优雅地关闭它 - 但只有当所有查询都得到解决时?

标签 node.js asynchronous promise async-await knex.js

我刚刚开始在使用 Node.js 的命令行脚本项目中使用 Knex.js。

我已经让它工作了,并且可以运行查询等。但是当我的脚本完成时(并且所有未决的 promise 都已解决),Node 进程永远挂起,直到我用 ctrl+c 杀死它

我是否需要做些什么来告诉 Knex 断开与数据库的连接 - 但仅在所有查询完成后才进行?

我试过将其作为脚本的结尾:

knex.destroy();

...但这只会立即终止连接,即如果有一个尚未完成的查询的未决 promise ,它会立即被终止,我得到:

UnhandledPromiseRejectionWarning: Error: aborted
...
(node:18284) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). 

...我明白错误是什么,它在我的一个查询完成之前终止了连接。我只是想不出如何解决在无事可做时让事情完成的整体问题。

我已经使用 Node 和 promises/async/await 几年了,但我似乎经常遇到这些问题,最后进程卡住,除非我编写代码专门关闭数据库连接和其他东西像这样……它通常做得太早了。我已经阅读了很多关于异步/ promise 的资源,但是我从来没有找到任何与 Node 进程关闭/退出相关的有用信息 - 但只有在没有 Unresolved promise 时才会出现。如果有人知道任何与此退出/永久卡住具体相关的有用资源,请告诉我 - 这似乎是我经常遇到的问题,所以我可能误解了一些东西。

更一般地说,是否有任何方法可以判断是否有任何 Node promise 未决(项目中全局的任何地方,而无需为每个 promise 手动编写跟踪代码)?我也一直在尝试解决这个问题很长时间,但从未找到任何答案。如果我能找到这个,那么我可以手动运行当时需要的任何关闭功能,但似乎没有办法做到这一点?

这是一个大项目,所以将 await 放在每个函数和查询的前面是不可行的,或者编写包装代码来做繁琐的事情,比如手动计算每一个创建/解决的 promise (考虑到 promises 主要是在 node_module 中生成的,这是不可能的),我猜这不是我应该做的事情?

最佳答案

听起来好像您只需要始终返回 promise 。在调用代码中,不会在promise resolve之前随意退出node进程,关闭数据库连接也是如此。所以像这样的结构变得有用:

function doWork () {
  Promise.all([
    createWombats(knex),
    cleanUpAardvarks(knex),
    optimiseLemurs(knex),
  ])
    .then(knex.destroy)
    .catch(() => {
      console.error('Something terrible happened.')
      knex.destroy()
    })
}

如果每个实用程序函数都返回已解决或已拒绝的 promise ,那么一切都应该按正确的顺序发生。假设您乐于使用阻塞请求,async/awaittry block 也可以进行类似的处理。

关于node.js - Knex.js - Node 进程永远不会退出,如何优雅地关闭它 - 但只有当所有查询都得到解决时?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61729606/

相关文章:

javascript - 如何通过断点使用 Selenium WebDriver 在 Node.js 上调试 javascript 测试?

node.js - 如何将一个模板的一些数据发送到另一个模板 Meteor

asynchronous - 从 tokio 套接字反序列化

c# - 直到第一个发布请求完成后才发送 jQuery 发布请求

javascript - react native : Handling Async calls to sqllite db

javascript - 如何检查 promise 是否已解决并有条件地呈现 Javascript?

javascript - Vuejs 应用程序显示无效的主机 header 错误循环

node.js - 电商网站paypal如何查看订阅支付状态

javascript - Promise在这种情况下如何实现?

java - 当我的所有线程在 android 中完成时,我如何执行函数?