python - 在数据块上使用数据框对象的写入方法时出错
问题描述
我正在尝试使用 Azure Databricks 和 Python 将一些数据写入 Azure SQL 数据仓库。我正在使用的代码如下:
salesdf.write\
.format('com.databricks.spark.sqldw')\
.option('url', sqlDwUrlSmall)\
.option('dbtable', 'StgSales')\
.option( 'forward_spark_azure_storage_credentials','True')\
.option('tempdir', tempDir)\
.mode('overwrite')\
.save()
此方法失败,没有特定的错误消息。追溯也没有任何意义。我很确定我已经正确说明了所有选项和格式,但它仍然无法正常工作。
解决方案
不确定,但我认为问题出在语法上。这是我在官方文档中找到的。
df.write \
.format("com.databricks.spark.sqldw") \
.option("url", "jdbc:sqlserver://<the-rest-of-the-connection-string>") \
.option("forwardSparkAzureStorageCredentials", "true") \
.option("dbTable", "my_table_in_dw_copy") \
.option("tempDir", "wasbs://<your-container-name>@<your-storage-account-name>.blob.core.windows.net/<your-directory-name>") \
.save()
检查您的代码中的.option("forwardSparkAzureStorageCredentials", "true"),您似乎已将 (_) 下划线。
推荐阅读
- ios - 如果我在录制期间播放 AVPlayer,iOS ReplayKit 会停止录制麦克风
- sharepoint - 如何在 SPFX 经典视图中创建自定义母版页
- continuous-integration - 必须启用“允许脚本访问 OAuth 令牌”
- javascript - Typescript/Angular 数组在副本上操作对象
- c# - 为什么我们需要创建、打开和关闭数据库连接来检索多个结果集,但如果检索一个结果集则不需要?
- php - 如何打印存储在多维数组中并使用 PHP 从数据库中获取的数据?
- python - Python - 如何在第一行条件下提取子集
- android - 通过 Web URL 安装 .apk 的意图
- python - xpath lxml无法获取html的ul标签内的所有元素
- javascript - JQUERY - 使用键从多维数组中删除数组