Node.js: Lambda で MariaDB のデータを更新 (Update)

$ tree -a
.
├── .env
├── function_update.sh
├── index.js
└── test_local.js

#! /usr/bin/node
// ---------------------------------------------------------------
//  maria_update/index.js
//
//                  Jun/07/2020
//
// ---------------------------------------------------------------
var mysql = require('mysql2/promise')

// ---------------------------------------------------------------
function get_current_date_proc ()
{
    const today = new Date ()
    var ddx = (1900 + today.getYear ()) + "-" + (today.getMonth () +1)
    ddx += "-" + today.getDate ()

    return ddx
}

// ---------------------------------------------------------------
function update_command_gen (id_in,population_in)
{
    const today = get_current_date_proc()
    var command = "update cities set population = " + population_in
    command += " , date_mod = '" + today + "'"
    command += " where id = '" + id_in + "'"
    console.log (command)

    return  command
}

// ---------------------------------------------------------------
async function main(key_in,population_in)
{
    console.error("key_in = " + key_in)
    console.error("population_in = " + population_in)

    const host = `${process.env.host}`
    const user = `${process.env.user}`
    const password = `${process.env.password}`
    const data_base = `${process.env.data_base}`

    console.error("host = " + host)
    console.error("user = " + user)
    console.error("password = " + password)
    console.error("data_base = " + data_base)

    try{
    var conn = await mysql.createConnection ({
        host: host,
        user: user,
        password: password,
        database: data_base
        })

    console.error("***** after mysql.createConnection ***")

    const command = update_command_gen (key_in,population_in)

    console.error(command)
    console.error("***** before execute ***")
    await conn.execute(command)
    console.error("***** after execute ***")
    } catch (ee) {
        console.log(ee)
        console.error ("*** error *** read01 ***")
        console.error(ee)
        return ''
    } finally {
        if (conn && conn.connection) {
        conn.end()
    console.error ("*** 終了 ***")
        }
    }

}

// ---------------------------------------------------------------
console.error ("*** 開始 ***")


exports.handler = async (event) => {
    const key_in = event['key']
    const population_in = event['population']
    console.error (key_in + "\t" + population_in)

    console.error("***** start maria_update PM 16:30 ***")
    var rvalue = {}
    rvalue['message'] = 'Hello from maria_update'

await main(key_in,population_in)

    const response = {
        statusCode: 200,
        body: JSON.stringify(rvalue),
    }

    console.error("***** end maria_update ***")
    return response
}

// ---------------------------------------------------------------

#! /usr/bin/node
// ---------------------------------------------------------------
//  maria_update/test_local.js
//
//                  Jun/07/2020
//
// ---------------------------------------------------------------
var maria_update = require('./')
// ---------------------------------------------------------------
console.error ("*** 開始 *** test_local.js ***")

const key_in = process.argv[2]
const population_in = parseInt(process.argv[3],10)

const event = {
    "key": key_in,
    "population": population_in
}

rvalue = maria_update.handler(event)
console.log(rvalue)

console.error ("*** 終了 *** test_local.js ***")
// ---------------------------------------------------------------

export NODE_PATH=/usr/lib/node_modules
node -r dotenv/config ./test_local.js t3328 21498700

FUNCTION='maria_update'
ZIP_FILE=$FUNCTION".zip"
#
rm -f *.zip
#
zip -r $ZIP_FILE index.js
#
aws lambda update-function-code \
    --function-name $FUNCTION \
    --zip-file fileb://$ZIP_FILE
#

#
aws lambda invoke --invocation-type Event \
    --function-name maria_update --region ap-northeast-1 \
    --payload '{"key": "t3326", "population": 4312500}' \
 outputfile.txt