add ai_lambda-exec.py.

ai_lambda-exec.py

@@ -0,0 +1,31 @@
+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='123c13c12',
+        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)
+
+