问题描述
我在 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'
我不知道我做错了什么
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)