Azure Cosmos DB无法正常工作-获取吞吐量控制以使用Cosmos DB Spark连接器

xzv2uavs  于 2023-08-07  发布在  Spark
关注(0)|答案(1)|浏览(117)

我正在尝试让吞吐量控制与Cosmos DB Spark连接器一起工作,但我没有看到创建的新容器。
代码如下:

val changeFeedCfg = Map("spark.cosmos.accountEndpoint" -> cosmosEndpoint,"spark.cosmos.accountKey" -> cosmosMasterKey,"spark.cosmos.database" -> cosmosDatabaseName,"spark.cosmos.container" -> cosmosContainerName,"spark.cosmos.read.inferSchema.enabled" -> "false","spark.cosmos.changeFeed.startFrom" -> "Beginning","spark.cosmos.changeFeed.mode" -> "Incremental","spark.cosmos.changeFeed.itemCountPerTriggerHint" -> "100000"//optional configuration for throughput control// "spark.cosmos.throughputControl.enabled" -> "true",// "spark.cosmos.throughputControl.name" -> "SourceContainerThroughputControl",// "spark.cosmos.throughputControl.targetThroughputThreshold" -> "0.30",// "spark.cosmos.throughputControl.globalControl.database" -> "database-v4",// "spark.cosmos.throughputControl.globalControl.container" -> "ThroughputControl"
"spark.cosmos.throughputControl.useGatewayMode" -> "true")`

字符串
我已经尝试了代码,它是不工作的例外。

35g0bw71

35g0bw711#

我看到你正在使用网关模式。

"spark.cosmos.throughputControl.useGatewayMode" -> "true"

字符串
目前我们不支持网关模式下的吞吐量控制
https://github.com/Azure/azure-sdk-for-java/issues/34229

相关问题