xdc_git_python_20210511/AWS-test/Lambda-exec-sqs.py

import json
import pymysql
import sys
import time
import boto3

def updata_db(m_key,m_value):
    conn2 = pymysql.connect(
        host='a.xdc.ink',
        port=3306,
        user='root',
        passwd='xclouds123',
        db='cmd',
        charset='utf8mb4')

    cs2 = conn2.cursor()
    select_sql = f'INSERT INTO kv (mykey, myvalue) VALUES ("{m_key}", "{m_value}");'
    cs2.execute(select_sql)
    conn2.commit()
    cs2.close()
    conn2.close()

def lambda_handler(event, context):
    # TODO implement
    sec = event['Records'][0]['messageAttributes']
    m_key = sec['mykey']['stringValue']
    m_value = sec['myvalue']['stringValue']
    print(m_key,m_value)
    updata_db(m_key,m_value)