PostgreSQL
 sql >> Datenbank >  >> RDS >> PostgreSQL

Spark-Datenrahmen in die Postgres-Datenbank schreiben

Probieren Sie write.jdbc aus und übergeben Sie die individuell erstellten Parameter außerhalb von write.jdbc(). Überprüfen Sie auch den Port, auf dem Postgres zum Schreiben verfügbar ist. Meiner ist 5432 für Postgres 9.6 und 5433 für Postgres 8.4.

mode = "overwrite"
url = "jdbc:postgresql://198.123.43.24:5432/kockpit"
properties = {"user": "postgres","password": "password","driver": "org.postgresql.Driver"}
data.write.jdbc(url=url, table="test_result", mode=mode, properties=properties)