我正在尝试使用PySpark和JDBC将数据插入PostgreSQL数据库。但是,在数据插入过程中,它意外地尝试重新创建表并生成以下输出。
org.postgresql.util.PSQLException: ERROR: relation "account" already exists
我正在尝试使用下面的代码片段在Postgres中写入数据。
def postgres_writes(url, driver, username, password, table_name, df):
df.write \
.format("jdbc") \
.option("url", url) \
.option("dbtable", table_name) \
.option("user", username) \
.option("password", password) \
.option("driver", driver) \
.mode("append") \
.save()
我想在现有表中追加数据。
1条答案
按热度按时间ttp71kqs1#
请确保您传递的是适当的jdbcurl。根据Postgres文档Documentation Link,您可以使用以下JDBC URL的表单
同时尝试重新创建表并尝试再次加载数据。Spark会话级别可能存在一些问题。