CosmosDB SDK python odata.error InvalidInput

如何解决CosmosDB SDK python odata.error InvalidInput

我在 cosmosDB 中有一个表，我想在其中存储一些来自 azure 数据浏览器的查询。

在数据资源管理器（使用 python sdk）中，我运行一个查询来过滤和聚合我的数据，我想将此查询结果推送到 cosmosDB。

我确实设置了所有配置和连接，但是当我运行命令 upset_item 或 create_item

我收到以下错误：

azure.cosmos.exceptions.CosmoshttpResponseError: Status code: 400
{"odata.error":{"code":"InvalidInput","message":{"lang":"en-us","value":"Request url is invalid.\r\nActivityId: d8994113-504e-4198-9976-41316aaafb5f,documentdb-dotnet-sdk/2.11.0 Host/64-bit MicrosoftwindowsNT/6.2.9200.0\nRequestID:d8994113-504e-4198-9976-41316aaafb5f\n"}}}

这是我配置 azure-cosmos 的方式：

url = "url"
key = {"masterkey": "my-key"}
client = CosmosClient(url,key)
database_name = "database"
container_name = "table"
database = client.get_database_client(database_name)
container = database.get_container_client(container_name)

for i in df:
    container.upsert_item(i)

df 是我从 azure 数据浏览器查询的结果

我认为错误是由于我将查询正文传递给 upsert_item

对此有什么建议吗？

更新： 所以我尝试按照示例进行操作。我将我的 cosmosdb 更新为 sql API。

我现在的代码如下所示：

url = "url"
key = {"masterkey": "my-key"}
client = CosmosClient(url,key)
database_name = "database"
container_name = "table"
database = client.get_database_client(database_name)
container = database.get_container_client(container_name)
data = json.dumps(test)
data_dict = json.loads(data)
for i in data_dict:
    container.create_item(body=i)

我将数据框转换为 json。但是当我运行 for 时，我收到此错误：

AttributeError: 'str' object has no attribute 'get'

我不知道我做错了什么

解决方法

感谢您的回复，我认为我们需要更多关于调试的联系。

这是我的代码，运行良好。

from azure.cosmos import exceptions,CosmosClient,PartitionKey,ProxyConfiguration
import family

# Initialize the Cosmos client
endpoint = "https://cosmosdb_name.documents.azure.com:443/"
key = 'primary_key_in_keys_blade'

client = CosmosClient(endpoint,key)
database_name = 'AzureSampleFamilyDatabase'
database = client.create_database_if_not_exists(id=database_name)
# </create_database_if_not_exists>

# <create_container_if_not_exists>
container_name = 'FamilyContainer'
container = database.create_container_if_not_exists(
    id=container_name,partition_key=PartitionKey(path="/lastName"),offer_throughput=400
)

family_items_to_create = [
    {
        "id":"112233","name":"andersen"
    },{
        "id":"455646","name":"johnson"
    },{
        "id":"999999","name":"smith"
    }
]
 # <create_item>
for family_item in family_items_to_create:
    container.upsert_item(body=family_item)

根据你的错误，我认为你需要检查data_dict的数据格式，或者你可以使用我的示例数据进行测试以排除其他问题。就我而言，我不知道你为什么要在这里使用 json.loads()。