#amazon-web-services #amazon-rds
#amazon-web-services #amazon-rds
Вопрос:
Когда я пишу динамический фрейм клея, используя ниже
datasink4 = glueContext.write_dynamic_frame.from_jdbc_conf(frame = dyf, catalog_connection = catalog_connection_name, connection_options = {"dbtable": "table_name", "database": "db_name"}, transformation_ctx = "datasink4")
он добавляет данные в существующую таблицу. Я скорее хочу его переписать. Как это можно сделать ?
Комментарии:
1. Я даже использовал «предварительные действия»: «удалить таблицу, если существует имя_таблицы;» как показано ниже
datasink4 = glueContext.write_dynamic_frame.from_jdbc_conf(frame = dyf, catalog_connection = catalog_connection_name, connection_options = {"preactions":"drop table if exists table_name;" "dbtable": "table_name", "database": "db_name"}, transformation_ctx = "datasink4"), но он все равно добавил данные2. Вы пробовали использовать mode в качестве режима сохранения. Перезаписать
3. можете ли вы поделиться синтаксисом @BaluVyamajala
4. Я не знаю синтаксиса на Python или с помощью Glue, но с помощью spark-scala
.write.format("jdbc").option("driver", "com.mysql.cj.jdbc.Driver").mode(SaveMode.Overwrite).option("url", "jdbc:url...").option("batchsize","1000").option("treatEmptyValuesAsNulls", "false").option("user", "username").option("password", "password").option("dbtable", destTableName).save();