Блог

У меня есть функция lambda, которая загружает файл из s3 и загружает данные локально в MySQL Aurora .

 def lambda_handler(event, context):
    query = "LOAD DATA FROM S3 's3://test.csv' INTO TABLE table FIELDS TERMINATED BY ',' LINES TERMINATED BY 'n' (col1,clo2)"

    with conn.cursor() as cur:
        cur.execute(query)
    conn.commit()

    return "Success"
 

Запрос, отправленный лямбда-функцией, является асинхронным, и поэтому мы не знаем, каков результат этого запроса .

Есть ли какой-либо способ узнать в лямбда-функции, был ли мой запрос успешным или неудачным?

В моем случае выполнение этого запроса занимает 5 минут, и это нормально, если моя лямбда может подождать эти 5 минут.

Также нужно ли мне закрывать соединение с БД для этой функции лямбда или это произойдет автоматически?