WOLFRAM

Wolfram 语言与系统参考资料中心
"Databricks" （数据连接）

"Databricks" （数据连接）

更多信息

属性

  • DataConnectionObject[assoc] 会创建一个对数据源的引用. 该数据源不必事先存在.
  • assoc 中通常出现的一般键包括：
  • "ConnectionName""Databricks"
    "Location"以字符串形式给出的 SQL 查询
    "Redownload"是否重新运行查询并覆盖缓存的结果
  • assoc 中必需的键：
  • "Host"提供数据库服务的主机
    "Warehouse"Databricks SQL 仓库的路径
  • assoc 中典型的键：
  • "Port"访问数据库的服务器端口
    "Schema"要连接的数据库或模式
  • 连接到 Databricks 时，"Location" 的可能形式包括：
  • "query"以字符串形式给出的 SQL 查询

    • 账户设置与认证

  • Authentication 的可能取值包括：
  • Automatic尝试使用已保存的凭证或弹出对话框
    "Dialog"通过对话框提供认证参数
    SystemCredential["key"]从安全存储中检索认证信息
    SystemCredentialData[…]存储的认证数据
    assoc提供显式凭证
  • 使用 Authentication :> SystemCredential["key"] 形式可延迟计算安全存储的凭证.
  • Authenticationassoc 接受以下键：
  • "Token"Databricks JDBC 令牌

    • 范例

    打开所有单元 关闭所有单元

    基本范例  (2)

    创建指向 Databricks 查询数据的 DataConnectionObject：

    Wolfram Language code: DataConnectionObject[<|"ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/abc123abc123", "Location" -> "SELECT * FROM table"|>, Authentication -> <|"Token" -> "mytoken"|>]
    Wolfram Language code: DataConnectionObject[Association["ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/d96fbbe2acr8d329", "Location" -> "SELECT * FROM table"], Association["UUID" -> "db9e416a-0032-4d9f-8ab4-44b58477454d"], Authentication -> Association["Token" -> "mytoken"]]

    使用 Import 获取数据：

    Wolfram Language code: Import@DataConnectionObject[<|"ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/abc123abc123", "Location" -> "SELECT * FROM table"|>, Authentication -> <|"Token" -> "mytoken"|>]

    认证  (2)

    使用账户令牌作为 Databricks 连接的认证方式：

    Wolfram Language code: DataConnectionObject[<|"ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/abc123abc123", "Location" -> "SELECT * FROM table"|>, Authentication -> <|"Token" -> "mytoken"|>]
    Wolfram Language code: DataConnectionObject[Association["ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/d96fbbe2acr8d329", "Location" -> "SELECT * FROM table"], Association["UUID" -> "db9e416a-0032-4d9f-8ab4-44b58477454d"], Authentication -> Association["Token" -> "mytoken"]]

    使用 Import 获取数据：

    Wolfram Language code: Import@DataConnectionObject[<|"ConnectionName" -> "Databricks", "Host" -> "dbc-123456abc-abc1.cloud.databricks.com", "Port" -> 443, "Warehouse" -> "/sql/1.0/warehouses/abc123abc123", "Location" -> "SELECT * FROM table"|>, Authentication -> <|"Token" -> "mytoken"|>]