Ошибка подключения к космосу DB из DataBricks: AnalySisexception: Catalog 'Cosmoscatalog' не найден ⇐ Python

[Anonymous]

Я следил за документацией от начала до конца. />com.azure.cosmos.spark:azure-cosmos-spark_3-3_2-12:4.15.0 в соответствии с документацией. < /p>
У меня есть следующий код: < /p>
cosmosEndpoint = "MyEndpoint"
cosmosMasterKey = "MyMasterKey"
cosmosDatabaseName = "SampleDB"
cosmosContainerName = "testContainer"

#Configure Catalog Api to be used

spark.conf.set("spark.sql.catalog.cosmosCatalog", "com.azure.cosmos.spark.CosmosCatalog") spark.conf.set("spark.sql.catalog.cosmosCatalog.spark.cosmos.accountEndpoint", cosmosEndpoint) spark.conf.set("spark.sql.catalog.cosmosCatalog.spark.cosmos.accountKey", cosmosMasterKey)

#create an Azure Cosmos DB database using catalog api

spark.sql("CREATE DATABASE IF NOT EXISTS cosmosCatalog.{};".format(cosmosDatabaseName))

#create an Azure Cosmos DB container using catalog api

spark.sql("CREATE TABLE IF NOT EXISTS cosmosCatalog.{}.{} using cosmos.oltp TBLPROPERTIES(partitionKeyPath = '/id', manualThroughput = '1100')".format(cosmosDatabaseName, cosmosContainerName)) `
< /code>
Я получаю ошибки Analysisexception: Catalog 'Cosmoscatalog' не найден. Я следил за документацией от начала до конца. Кто -нибудь знает, почему возникает эта ошибка?

Подробнее здесь: https://stackoverflow.com/questions/746 ... alog-cosmo