Скрипт Python для работы с AWS

Question

У меня есть две таблицы: исходная и целевая в разных базах данных.Мне нужно вставить новые записи в цель из источника, обновить существующие записи и удалить записи из целевой таблицы.Мне нужно добиться этого с помощью скрипта AWS glue python.Какое преобразование мне нужно использовать?

Answer 1

Вы не упомянули, какую исходную и целевую базу данных вы собираетесь использовать. Я сделал UPSERTS для базы данных Aurora Mysql в качестве цели, а S3 - в качестве моего источника.

Я использовал "INSERT INTO TABLE .... ON DUPLICATE KEY update ...". Это проверит, существует ли запись в целевой базе данных (на основе ПЕРВИЧНЫХ КЛЮЧЕЙ), и, если она существует, записи ОБНОВЛЕНЫ, иначе запись будет вставлена.

Дайте мне знать, если вам нужна помощь с образцом. Вы можете проверить мои другие вопросы и ответы на тот же. Вы должны использовать библиотеку коннекторов базы данных python как отдельный zip-файл для вашего задания Glue.