Блог

У меня есть DynamicFrame с данными, которые я хочу загрузить в таблицу MySQL8. Я написал следующий код (у меня есть драйвер JDBC MySQL8 для корзины S3):

 options = {
'customJdbcDriverS3Path': 's3-jdbc-path', 
'customJdbcDriverClassName': 'com.mysql.cj.jdbc.Driver', 
'user': 'user_name',
'password': 'pwd', 
'url': 'url:port/db',
'connectionType': 'mysql',
'dbtable': 'table_name',
'database': 'db'}

glueContext.write_dynamic_frame.from_options(df, connection_type="mysql", connection_options=options)
 

Но когда я запускаю задание, оно занимает неопределенно много времени и не возвращает сообщения об ошибке. Я использовал тот же набор параметров, что и выше, и код

 frame = glueContext.create_dynamic_frame.from_options(connection_type="mysql", connection_options=options)
 

для успешного чтения из таблицы в той же базе данных, в которую я пытаюсь записать сейчас.

Почему это не работает? Как я могу записать в свою таблицу MySQL8 на RDS с помощью AWS Glue?

Спасибо.

Неважно, это работает. Это просто занимает много времени.