当前位置: 首页 > 知识库问答 >
问题:

如何使用MongoDB API将Azure数据库连接到Cosmos DB?

越安翔
2023-03-14

我使用MongoDB API创建了一个azure CosmosDB帐户。我需要将CosmosDB(MongoDB API)连接到Azure Databricks集群,以便从Cosmos读写数据。

如何将Azure Databricks集群连接到CosmosDB帐户?

共有1个答案

濮阳奇逸
2023-03-14

下面是pyspark代码,我使用Azure Databricks中的MongoDB API(5.2毫升Beta版(包括Apache Spark 2.4.0,Scala 2.11)和MongoDB Connector:org.MongoDB.Spark:mongo-spark-connector2.11:2.4.0)连接到CosmosDB数据库:

from pyspark.sql import SparkSession

my_spark = SparkSession \
    .builder \
    .appName("myApp") \
    .getOrCreate()

df = my_spark.read.format("com.mongodb.spark.sql.DefaultSource") \
  .option("uri", CONNECTION_STRING) \
  .load()

其CONNECTION_STRING如下所示:“mongoDb://username:password@testgp.documents.azure.com:10255/database_name.collection_name?ssl=true&replicaset=globaldb”

我尝试了许多其他不同的选项(添加数据库和集合名称作为SparkSession的选项或配置),但都没有成功。告诉我它是否对你有效...

 类似资料:
  • (这适用于AzureSQL数据库) 几乎每篇文章都在开始时说,在创建新数据库之前“连接到主数据库”。 我已使用SSMS 2014连接到我的Azure SQL数据库服务器,没有问题。我在系统数据库下看到了主数据库。我右键单击LHS树中的数据库(位于系统数据库上方),然后单击新建数据库。。。 模板查询注释区域会显示“…连接到主机…”这对我来说意味着我与大师没有联系。 我显然错过了一些关于基础的非常基本

  • 我试图将一个Azure Blob存储容器挂载到一个DataBricks实例上,虽然挂载确实有效,但它似乎没有使用存储容器。 我在这里漏掉了什么?

  • ConnectionURL=“jdbc:jtds:sqlserver://havvasemserv3.database.windows.net:1433;DatbaseName=Newfin;用户=;密码=;加密=真;trustServerCertificate=false;hostNameInCertificate=*。数据库窗户。网loginTimeout=30”; } 我正在尝试将azure

  • 问题内容: 如何使用java连接到mysql数据库? 问题答案: 逐步说明如何安装MySQL和JDBC以及如何使用它: 1.下载并安装MySQL服务器。只需按照通常的方式进行即可。每次更改时都请记住端口号。默认情况下3306。 2.下载 JDBC驱动程序并放入classpath,解压缩ZIP文件并将包含的JAR文件放入classpath。特定于供应商的JDBC驱动程序是 JDBC API的具体实现

  • 问题内容: 我正在尝试将Java连接到ms Access数据库,但效果不是很好 我收到这样的错误消息 这是我的代码: 问题答案: 您可以使用ucanacess.jar连接Aceess女士数据库 在此处显示一些示例http://www.benchresources.net/jdbc-msaccess-database-connection- steps-in-java-8/

  • 我正在尝试使用SpringBoot连接MySQL数据库,但我遇到以下错误: 应用程序无法以类路径启动:[文件:/C:/Dev/Repositorios/jira quality/target/classes/,文件:/C:/Users/jboscod/.m2/repository/mysql/mysql连接器java/8.0.21/mysql-connector-java-8.0.21.jar,文