「Pool is closed」のエラーについて

Question

nodeのmysql2のエラーに関する質問です。
下記のコードをAWSのLambda関数で実行すると、何度かに１度初回のDB接続(check()関数)にて「Pool is closed」のエラーが発生致します。
(問題なく実行できる場合もあります。)

どういう状況でこのエラーが発生するかもわからず困っております。
(当該lambda関数を短い時間(数分内)に連続して実行するとこのエラーが発生しているようにも見えます。)

どの部分を改善すれば「Pool is closed」エラーが発生しなくなるかご教示頂けましたら、幸甚で御座います。

const AWS = require('aws-sdk');
const mysql = require('mysql2');

const pool = mysql.createPool({
    host : 'xxxx',
    user : 'xxxx',
    password : 'xxxx',
    database: 'xxxx',
    port: 'xxx',
});

// 接続
pool.query = util.promisify(pool.query);

exports.lambdaHandler = async (event, context) => {
  const check_res = await check();
  const check_a_res = await check_a();
  const check_b_res = await check_b();
  const check_c_res = await check_c();
  pool.end();
  return check_c_res;
};

function check(){
  const data = ["a", "b"];

  try {
    const results = await pool.query('select id from table where id = ? and name = ?' ,data);
    return results;
  }catch(e){
    console.log("check error");
    pool.end();
    throw e;
  }
}

//function check_a()/check_b()/check_c()もDB接続し、それぞれinsert/update/deleteを含む関数となっております。

#エラー
"errorMessage": "Pool is closed.",
"errorType": "Error",
"stackTrace": [
"process.nextTick (/var/task/node_modules/mysql2/lib/pool.js:38:40)",
"_combinedTickCallback (internal/process/next_tick.js:131:7)",
"process._tickDomainCallback (internal/process/next_tick.js:218:9)"
]

#環境
AWS lambda関数(node.js : 8.10)

Answer 1

check_a,b,c各々は最初に作ったpoolを使いまわせばいいと思います。
それらの関数の中で毎回poolに接続するのが良くないと思いました。

やり方としては、ラムダ関数の中でpoolに接続して、check_a,b,cはそのpoolを使いまわして、check_cが終わったらpool.end()するでいいと思います。

Comments

[k.t.est]

ご回答ありがとう御座います。
ということは、私の当初のコードでいいという理解でよろしいでしょうか？？

[youk-h]

いえ、ソースコードを見た感じだと、poolに接続しているのがグローバルな位置にあります。
これだと、pool接続は一回しか行われません。

一つの案ですが
exports.lambdaHandler = async (event, context) => {
const pool = mysql.createPool({
host : 'xxxx',
user : 'xxxx',
password : 'xxxx',
database: 'xxxx',
port: 'xxx',
});

const check_res = await check(pool);
const check_a_res = await check_a(pool);
const check_b_res = await check_b(pool);
const check_c_res = await check_c(pool);
pool.end();
return check_c_res;
};

のように書けばいいと思います。
そのためにはcheck関数は引数にpoolを受け取る必要があります

[k.t.est]

詳細なご回答ありがとう御座います！大変よく分かりました！

[youk-h]

解決しましたか？^_^

Answer 2

try句の中をこうしたらどうでしょうか。

const results = await pool.query('select id from table where id = ? and name = ?' ,data);
return results;

↓

const results = await pool.query('select id from table where id = ? and name = ?' ,data);
pool.end();
return results;

Comments

[k.t.est]

ご回答誠に有難う御座います。
当方の質問に不備があり、大変申し訳御座いません。(質問内容を編集致しました。)
実際にはcheck()関数の後にもDBに接続する関数がいくつか続いておりまして、はじめにDBとのコネクトし、全ての関数の実行が終わった後にpool.end()している形になっております。
従いまして、初回のDBアクセス時にはpool.end()しない形に致したく存じます。

[michi_h]

Lambdaを連続して実行するときにエラーがでるんですよね？
関数実行時のバックエンドは同一ですので、適宜pool.end()するしかないと思いますが...
または、関数が実行し終わるまで再度関数を実行するのを控える、とか...

[k.t.est]

ご返信、誠に有難う御座います。
連続ではあるのですが、重複した連続ではなく、当該lambda関数が終わった後すぐに実行した際に当該エラーになることがあったという感じです(これも毎回エラーになるわけではないのです)。
一回一回DBとの接続を切ってというのは、実行時間が掛かるのではないかと思い、避けていたのですが、基本的には一回一回DBとは、接続-切断を繰り返すプログラムの方が良いプログラムなのでしょうか？？
ご教示頂けましたら大変有り難く存じます。