如何解决Databricks无法连接到Azure Synapse Analytics:返回了意外版本:Microsoft SQL AzureRTM-12.0.2000.8
我正在尝试使用以下代码从Databricks笔记本中向Azure Synapse Analytics写入一些数据:
write_to_synapse = (
spark.readStream.format('delta').option('ignoreChanges',True).table('turbine_agg') # Read in Gold turbine readings from Delta as a stream
.writeStream.format("com.databricks.spark.sqldw") # Write to Synapse (SQL DW connector)
.option("url",dbutils.secrets.get(<scope>,<secret>)) # SQL Pool JDBC connection (with SQL Auth) string
.option("tempDir",SYNAPSE_PATH) # Temporary ADLS path to stage the data (with forwarded permissions)
.option("forwardSparkAzureStorageCredentials","true")
.option("dbTable","turbine_agg") # Table in Synapse to write to
.option("checkpointLocation",CHECKPOINT_PATH+"synapse") # Checkpoint for resilient streaming
.start()
)
其中秘密是JDBC连接字符串格式的
jdbc:sqlserver://<on-demand-sql-pool>.sql.azuresynapse.net:1433;database=master;user=<user>;password=<password>;encrypt=true;trustServerCertificate=true;hostNameInCertificate=*.sql.azuresynapse.net;loginTimeout=30;
我遇到以下错误:
IllegalArgumentException: Unexpected version returned: Microsoft SQL Azure (RTM) - 12.0.2000.8
Aug 17 2020 07:52:53
Copyright (C) 2019 Microsoft Corporation
Make sure your JDBC url includes a "database=<DataWareHouseName>" option and that
it points to a valid Azure Synapse SQL Analytics (Azure SQL Data Warehouse) name.
This connector cannot be used for interacting with any other systems (e.g. Azure
SQL Databases).
我包括一个数据库选项,并且数据库主数据库存在。
出什么问题了,我该如何解决?
谢谢!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。