h12 nodejs的heroku服务器请求超时

Question

我在heroku服务器上部署了nodejs代码。

我面临H12请求超时问题

这是与pgsql的db连接，它是异步的

const { Pool } = require("pg");
import nodeEnvFile = require("node-env-file");
import { Query } from "src/models/query";
nodeEnvFile(".env");

const config = {
    user: process.env.DB_USER,
    host: process.env.DB_IP,
    database: process.env.DB,
    password: process.env.DB_PASSWORD,
    port: process.env.DB_PORT,
    max: 5, // max number of connection can be open to database
    idleTimeoutMillis: 30000, // how long a client is allowed to remain idle before being closed
    ssl: true
};

const pool = new Pool(config);

export class DB {
    static async query(queryInfo: Query): Promise<any> {
        // to hold undefined values while stringfy json
        const replacer = (_key, value) => typeof value === "undefined" ? null : value;
        let _arguments = "()";
        if (queryInfo.arguments) {
            _arguments = `('${JSON.stringify(queryInfo.arguments, replacer)}'::json)`;
        }
        const query = `select * from ${queryInfo.name} ${_arguments} as info;`;
        console.log(query);
        try {
            return pool.query(query)
                .then((response) => {
                    console.log("response", response);
                    return response.rows[0].info;
                })
                .catch((err) => {
                    console.log("Db Error : ", err);
                    throw err;
                });
        } catch (err) {
            console.log("err", err);
            throw err;
        }
    }
}

这是我如何调用这个数据库

const _loginInfo: any = await AuthFacade.login(credentials);

以及立面功能

static async login(credentials: LoginCredentials): Promise<{ userId: number, token: string }> {
    const query = new Query({
        name: this.PROCS.LOGIN,
        arguments: credentials
    });
    return DB.query(query);
}

同样的编码在本地工作，它也在heroku工作。但是突然间我得到了这个问题。有什么帮助吗？

Answer 1

pgsql连接有问题。我使用的是pg的第7版，我想这对HeroKu不起作用。所以我更新了pg的版本

"pg": "^8.5.1",

并更新了池配置

const Pool = require("pg-pool");
import nodeEnvFile = require("node-env-file");
import { Query } from "src/models/query";
nodeEnvFile(".env");

const config = {
    user: process.env.DB_USER,
    host: process.env.DB_IP,
    database: process.env.DB,
    password: process.env.DB_PASSWORD,
    port: process.env.DB_PORT,
    max: 5, // max number of connection can be open to database
    idleTimeoutMillis: 30000, // how long a client is allowed to remain idle before being closed
    ssl: { rejectUnauthorized: false }
};

const pool = new Pool(config);

export class DB {
    static async query(queryInfo: Query): Promise<any> {
        // to hold undefined values while stringfy json
        const replacer = (_key, value) => typeof value === "undefined" ? null : value;
        let _arguments = "()";
        if (queryInfo.arguments) {
            _arguments = `('${JSON.stringify(queryInfo.arguments, replacer)}'::json)`;
        }
        const query = `select * from ${queryInfo.name} ${_arguments} as info;`;
        console.log(query);
        try {
            return pool.query(query)
                .then((response) => {
                    return response.rows[0].info;
                })
                .catch((err) => {
                    console.log("Db Error : ", err);
                    throw err;
                });
        } catch (err) {
            console.log("err", err);
            throw err;
        }
    }
}

现在它正在工作