Клей (pyspark) как указать jdbc SaveMode для ingore - PullRequest
1 голос
/ 30 апреля 2019

Я хотел бы написать Glue DynamicFrame для базы данных MySQL (не RDS, а простой экземпляр ec2 mysql)

Вот как я сейчас работаю:

datasink = glueContext.write_from_options(test, 'mysql', {"url": jdbcUrl, "user": userName, "password": dbPassword, "dbtable": myTable }, {}, {}, "datasink")

Как я могу указать saveMode?Нужно ли преобразовывать DynamicFrame в простой DataFrame и использовать .write.jdbc?

...