Lambda + pg-promise + 事务 = 随机超时

Question

在过去的 48 小时里，我一直在为这个问题苦苦挣扎，在阅读了这里的大量答案、博客、文章、文档等之后......我仍然找不到解决方案！

基本上，我有一个 2 分钟超时的 lambda 函数。根据日志和见解，它可以很好地处理大多数请求，但在尝试执行以下事务时会随机失败并出现“超时”错误。

Lambda 代码（为了便于阅读而截断）：

import pgp from 'pg-promise'
import logger from '../lib/logger'

const Database = pgp()

const db = Database({
 connectionString: process.env.DATABASE_URL,
 max: 3,
 idleTimeoutMillis: 10000,
})

db.connect()
 .then(() => logger.info('Successfully connected to the PG database'))
 .catch(err => logger.error({ err }))

export const handler = async (event, context) => {
 logger.info('transaction start...')

 await db.tx(async tx => {
   await tx.none(
     `
     INSERT INTO...`,
     [someValue1, someValue2]
   )
   const updatedRow = await tx.one(
     `
     UPDATE Something...`,
     [somethingId]
   )
   return someFunction(updatedRow)
 })

 logger.info('transaction end...')
}

const someFunction = async (data) => {
 return db.task('someTask', async ctx => {
   const value = await ctx.oneOrNone(
     `SELECT * FROM Something...`,
     [data.id]
   )

   if (!value) {
     return
   }

   const doStuff = async (points) =>
     ctx.none(
       `UPDATE Something WHERE id =.....`,
       [points]
     )

   // increment points x miles
   if (data.condition1) {
     await doStuff(10)
   }

   if (data.condition2) {
     await doStuff(20)
   }

   if (data.condition3) {
     await doStuff(30)
   }
 })
}

我看到事务开始但永远不会结束，所以函数不可避免地被超时杀死。

我阅读了pg-promise 中的整个 wiki，并了解了有关调整、性能、良好做法等的所有内容。但仍然有一些非常错误的地方。

您可以看到，我还更改了池大小和最大超时时间以进行试验，但这并没有解决问题。

有什么想法吗？

谢谢！

Answer 1

很可能您的连接用完了。您没有正确使用它们，同时您将连接限​​制设置为非常低的 3。

第一个问题，您正在通过调用connect 来测试连接，而没有使用done 来跟踪它，它会永久占用，从而浪费您的初始/主要连接。 请参阅the example here，我们在测试后释放连接。

第二个问题 - 您在事务中请求新连接（通过在根 db 级别上调用 .task），这对任何环境都不利，但在可用连接很少时尤其重要。

任务应该是重用当前事务的连接，这意味着您的someFunction 应该需要连接上下文，或者至少将其作为可选参数：

const someFunction = async (data, ctx) => {
 return (ctx || db).task('someTask', async tx => {
   const value = await tx.oneOrNone(

任务 pg-promise 中的事务接口可以完全嵌套，您会看到，将当前连接传播到所有级别。

另外，我建议使用pg-monitor，以获得良好的查询+上下文可视化。