Cách kết nối (Py) Spark với cơ sở dữ liệu Postgres bằng JDBC

Các vấn đề với việc phân giải tên được chỉ ra bởi org.postgresql.util.PSQLException và không dẫn đến NPE. Nguồn gốc của vấn đề thực sự là một chuỗi kết nối và cụ thể là cách bạn cung cấp thông tin đăng nhập người dùng. Thoạt nhìn, nó giống như một lỗi nhưng nếu bạn đang tìm kiếm một giải pháp nhanh chóng, bạn có thể sử dụng các thuộc tính URL:

url = 'jdbc:postgresql://PG_SERVER_IP/db_name?user=PG_USER&password=PASSWORD'

hoặc đối số thuộc tính:

properties = {
    "user": "PG_USER",
    "password": "PASSWORD",
    "driver": "org.postgresql.Driver"
}