azure Cosmos DB Cassandra API Datastax Spark连接器示例代码示例

分享于 

1分钟阅读

Microsoft

  繁體
浏览代码下载ZIP

此maven项目提供了Azure Cosmos DB 的Cassandra API使用DataStax Spark Cassandra Connector的最佳实践。提供的所有示例都在Scala中,使用Maven构建。

注意-该示例是针对2.0.6版的spark connector配置的。

运行这个示例

前提条件

  • 使用Cassandra API配置的Cosmos DB帐户
  • Spark Cluster

Cassandra API连接参数

为了使spark作业能够与Cosmos DB的Cassandra API连接,必须设置以下配置:

注CosmosDB帐户的上可以找到所有这些值

属性名称价值
spark.cassandra.connection.host 你的Cassandra端点:ACOUNT_NAME.cassandra.cosmosdb.azure.com
spark.cassandra.connection.port10350
spark.cassandra.connection.ssl.enabledtrue
spark.cassandra.auth.usernameCOSMOSDB_ACCOUNTNAME
spark.cassandra.auth.passwordCOSMOSDB_KEY

数据  API  sam  spa  spark  Cassandra