python - 无法从 Azure 事件中心写入 CosmosDB

Question

我正在开发一个 Azure Function(2.x)，它由来自事件中心的事件触发，并将接收到的数据写入 CosmosDB 实例。在部署它之前，我想在本地测试它并且读取事件可以完美地工作。但是，当我尝试写入 CosmosDB 时，出现此错误:

“System.Private.CoreLib:执行函数时出现异常:Functions.EventHubTrigger。Microsoft.Azure.DocumentDB.Core:消息:{“错误”:[“指定的输入之一无效”]}”

数据库实例是使用 Azure 门户创建的，我添加了几个虚拟条目，所有这些都运行良好。我做错了什么？

function.json:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "eventHubTrigger",
      "name": "event",
      "direction": "in",
      "eventHubName": "event-hub-name",
      "connection": "event-hub-connection",
      "cardinality": "many",
      "consumerGroup": "$Default"
    },
    {
      "type": "cosmosDB",
      "direction": "out",
      "name": "doc",
      "databaseName": "database-name",
      "collectionName": "test",
      "createIfNotExists": "true",
      "connectionStringSetting": "CosmosDBConnectionString"
    }
  ]
}

local.settings.json:

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "storage-key",
    "CosmosDBConnectionString": "AccountEndpoint=document-db-endpoint;AccountKey=account-key;",
    "FUNCTIONS_WORKER_RUNTIME": "python",
    "event-hub-connection": "Endpoint=sb://endpoint-name;SharedAccessKeyName=shared-access-key-name;SharedAccessKey=shared-access-key" 
  }
}

host.json:

{
  "version": "2.0",
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[1.*, 2.0.0)"
  }
}

__init__.py:

import logging, json

import azure.functions as func


def main(event: func.EventHubEvent, doc: func.Out[func.Document]):

    event_data = event.get_body().decode("utf-8")
    logging.info('Python EventHub trigger processed an event: %s', event_data)

    # json object for testing the DB write operation
    temp = {}
    temp["id"] = 1
    temp["category"] = "feedback"
    temp = json.dumps(temp)

    doc.set(func.Document.from_json(temp))
    logging.info("CosmosDB updated!; Value: ", temp)

Answer 1

该错误是 HTTP 400，BadRequest。这意味着负载中的某些内容未正确形成 JSON，或者您的某些属性无效。

我看到你的 id 是一个数字，但在 REST 合约中，它是一个字符串。引用:https://learn.microsoft.com/rest/api/cosmos-db/create-a-document#body

你能把id改成字符串吗？