Я использую клей aws для преобразования данных из CSV в RDS (mysql). На последнем этапе я реализую этот оператор
datasink = glueContext.write_dynamic_frame
.from_jdbc_conf(
frame = selectfields,
catalog_connection = "rds_conn",
connection_options = {"preactions":"truncate table dim_customer_scd;","dbtable": "dim_customer_scd", "database": "sales"},
transformation_ctx = "datasink")
Я ожидаю, что я хочу усечь таблицу (dim_customer_scd) перед вставкой в нее кадра c (selectfields). К сожалению, новые данные вставлены правильно, но старые данные все еще там (не удалены). Я сомневаюсь, что «предварительные действия»: «усечь таблицу dim_customer_scd» не работают. Есть у кого-нибудь идеи по этому поводу? Большое спасибо