CosmosDB SDK python odata.error InvalidInput

问题描述

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

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

我确实设置了所有配置和连接,但是当我运行命令 upset_itemcreate_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'

我不知道我做错了什么

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)