Я использую следующее для подключения своей AWS лямбды к БД:
https://www.isc.upenn.edu/accessing-mysql-databases-aws-python-lambda-function
вот код, который выполняет работу:
def lambda_handler(event, context):
"""
This function inserts content into mysql RDS instance
"""
item_count = 0
with conn.cursor() as cur:
cur.execute("create table Employee3 (EmpID int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (EmpID))")
cur.execute('insert into Employee3 (EmpID, Name) values(1, "Joe")')
cur.execute('insert into Employee3 (EmpID, Name) values(2, "Bob")')
cur.execute('insert into Employee3 (EmpID, Name) values(3, "Mary")')
conn.commit()
cur.execute("select * from Employee3")
for row in cur:
item_count += 1
logger.info(row)
return "Added %d items to RDS MySQL table" %(item_count)
ПроблемаКогда я пытаюсь использовать лямбду, я получаю результат обратно нормально, но если я изменяю данные в БД, а затем снова отправляю запрос, пока работает лямбда-контейнер, я не вижу обновленных данных и вижу старые данные.Но когда я сохраняю лямбду после изменения, чтобы убить текущий контейнер, он начинает загружать последнюю информацию.Как я могу это исправить?