У меня есть требование загружать данные из одного кластера Redshift в другой, каждый в другом регионе.
Для того же самого сначала создается таблица в целевой схеме, а затем в источнике выполняется команда UNLOAD
, которая помещает файлы введро S3.
Чтобы загрузить данные из S3 в целевую схему Redshift, я буду использовать код Python в AWS Lambda.Функция AWS Lambda сработает на пути S3, куда будут поступать все файлы при выполнении команды выгрузки.
После приема мне нужно выполнить запрос преобразования, который поместит данные в таблицы фактов и измерений.Как я могу узнать статус для целевой таблицы, что конкретная таблица успешно загружена?
Лямбда-код Python будет запущен для каждого файла и скопирует данные в целевую таблицу.Если я знаю состояние, я выдам запрос на преобразование.
Есть ли в AWS Lambda какая-либо функция, которая поможет мне узнать состояние команды COPY
?