Node.js: Lambda で MariaDB のデータを削除 (Delete)

フォルダー構造

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

maria_delete/index.js

// ---------------------------------------------------------------
//  maria_delete/index.js
//
//                  Jun/07/2020
//
// ---------------------------------------------------------------
var mysql = require('mysql2/promise')

// ---------------------------------------------------------------
async function main(id_in)
{
    console.error("id_in = " + id_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
        })

    const command = "delete from cities where id = '" + id_in + "'"

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

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

exports.handler = async (event) => {
const key_in = event['key']
console.error (key_in)

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

await main(key_in)

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

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


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

test_local.js

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

const key_in = process.argv[2]

const event = {
    "key": key_in
}

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

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

実行スクリプト

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

AWS のプログラムを更新するスクリプト

function_update.sh

FUNCTION='maria_delete'
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 のプログラムを cli で実行する方法

cli_exec.sh

#
aws lambda invoke --invocation-type Event \
    --function-name maria_delete --region ap-northeast-1 \
    --payload '{"key": "t3322"}' \
 outputfile.txt