PySpark连接NetSuite2沙盒时JDBC连接失败问题求助

问题详情 #

requirement failed: The driver could not open a JDBC connection. Check the URL: jdbc:netsuite://xxxxx-sb1.connect.api.netsuite.com:1708;ServerDataSource=NetSuite2.com;Encrypted=1;NegotiateSSLClose=false;

已将JDBC驱动部署到集群，尝试连接NetSuite2沙盒环境时持续触发上述错误。所用角色已配置以下全权限：

• 设置：访问令牌管理
• 使用访问令牌登录
• REST Web服务
• SOAP Web服务
• SuiteAnalytics Connect

关联代码 #

account_id = "xxx_SB1"
role_id = "1174" 
consumer_key = "xxx"
consumer_secret = "xxx"
token_id = "xxx"
token_secret = "xxx"

host = "xxx-sb1.connect.api.netsuite.com"
port = 1708
driver = "com.netsuite.jdbc.openaccess.OpenAccessDriver"

jdbc_url = (f"jdbc:netsuite://{host}:{port};"
            f"ServerDataSource=NetSuite2.com;"
            f"Encrypted=1;"
            f"NegotiateSSLClose=false;")

connection_properties = {
    "driver": driver,
    "CustomProperties": (
        f"AccountID={account_id};"
        f"RoleID={role_id};"
        f"AuthType=TOKEN;"
        f"TokenID={token_id};"
        f"TokenSecret={token_secret};"
        f"ConsumerKey={consumer_key};"
        f"ConsumerSecret={consumer_secret}"
    )
}

# testing on oa_tables..
df = spark.read.jdbc(
    url=jdbc_url,
    table="OA_TABLES",
    properties=connection_properties
)

display(df)

排查方向 #

• 修正数据源参数：沙盒环境的ServerDataSource应改为NetSuite2Sandbox.com，而非生产环境的NetSuite2.com，这是沙盒连接的常见配置错误。
• 校验凭证有效性：确认account_id、令牌、密钥等所有凭证均为沙盒环境专属，避免混用生产环境的密钥或ID。
• 检查驱动兼容性：确保使用的JDBC驱动是NetSuite官方提供的最新SuiteAnalytics Connect版本，旧版本可能不支持沙盒新接口。
• 验证网络连通性：测试集群到xxx-sb1.connect.api.netsuite.com:1708的端口连通性，排查防火墙、安全组是否拦截该端口。
• 规范参数格式：检查CustomProperties中所有键值对的格式，确保无多余空格、分号使用正确（末尾无需额外分号）。

内容的提问来源于stack exchange，提问作者KristiLogos