Я успешно подключился к своему большому запросу, используя:
sparkSession.read.format("jdbc").option("url",jdbc_url).option("dbtable","cash_in").option("driver","cdata.jdbc.googlebigquery.GoogleBigQueryDriver").load()
Однако я не хочу читать данные из BigQuery, я хочу записать в них из своей базы данных Aurora.
Что-то вроде:
retDatasink4 = glueContext.write_dynamic_frame.from_options(frame = orders, connection_type = "bigquery", connection_options = {"jdbc_url": jdbc_url, "dbtable" : "cash_in", "driver", "cdata.jdbc.googlebigquery.GoogleBigQueryDriver" })
Однако тип соединения mysql, postgresql, красное смещение, sqlserver e oracle. ,