如何解决从Azure函数向Azure Cosmos缓慢插入的问题

Question

我想插入小文件(

插入代码是

await container.CreateItemAsync(
                    objectToAdd,
                    new PartitionKey(objectToAdd.PartitionKey),
                    new ItemRequestOptions { EnableContentResponseOnWrite = false })

查看诊断，大部分时间是在项目流期间花费的（请参阅末尾的日志）。

Azure 函数和 Cosmo 都部署到同一区域（北欧）。Cosmos 允许通过启用了服务终结点的 vnet 访问 Azure 函数。

我已经通读了https://blog . TD Wright . co . uk/2019/06/29/aggressive-tuning-cosmos-db-the-long-way-round/和https://docs . Microsoft . com/en-us/azure/cosmos-db/performance-tips-dot net-SDK-v3-SQL尝试了以下内容:

• 同时使用直接连接模式和网关连接模式（未发现显著差异）。
• 禁用写入操作时的内容响应（这会将写入时间减少到大约 250ms-500ms）。
• 确保存在单例 Cosmos 客户端

我没试过:

• 增加数据库上的RU，因为我只测试了少量7.6 RU插入
• 在文档单独到达时使用批量库

这似乎是一个很长的响应时间，应该完全在一个数据中心内。

我的问题：

• 上述信息是否表明网络问题？
  • 如果是这样，Cosmos是否提供了一种像TRACERT一样在Azure中跟踪连接的方法？
  • Cosmos是否记录了它认为连接来自的IP地址？

  {
      "Summary": {
          "StartUtc": "2020-10-22T21:21:03.3520979Z",
          "ElapsedTime": "00:00:01.0030109",
          "UserAgent": "cosmos-netstandard-sdk/3.6.0|3.4.2|38128|X86|Microsoft Windows 10.0.14393 |.NET Core 4.6.29215.02|"
      },
      "Context": [
          {
              "Id": "ItemStream",
              "ElapsedTime": "00:00:01.0030109"
          },
          {
              "Id": "ItemSerialize",
              "ElapsedTime": "00:00:00.0000212"
          },
          {
              "Id": "ExtractPkValue",
              "ElapsedTime": "00:00:00.0000402"
          },
          {
              "Id": "BatchAsyncContainerExecutor.Limiter",
              "ElapsedTime": "00:00:00.0000056"
          },
          {
              "Id": "RequestInvokerHandler",
              "ElapsedTime": "00:00:00.0071549"
          },
          {
              "Id": "Microsoft.Azure.Cosmos.Handlers.RetryHandler",
              "ElapsedTime": "00:00:00.0071272"
          },
          {
              "Id": "Microsoft.Azure.Cosmos.Handlers.RouterHandler",
              "ElapsedTime": "00:00:00.0070979"
          },
          {
              "Id": "TransportHandler",
              "ElapsedTime": "00:00:00.0070954"
          },
          {
              "Id": "PointOperationStatistics",
              "ActivityId": "...",
              "StatusCode": 200,
              "SubStatusCode": 0,
              "RequestCharge": 7.62,
              "RequestUri": "...",
              "RequestSessionToken": null,
              "ResponseSessionToken": "..",
              "ClientRequestStats": {
                  "RequestStartTimeUtc": "2020-10-22T21:21:04.3479626Z",
                  "RequestEndTimeUtc": "2020-10-22T21:21:04.3548940Z",
                  "RequestLatency": "00:00:00.0069314",
                  "IsCpuOverloaded": false,
                  "NumberRegionsAttempted": 1,
                  "ResponseStatisticsList": [
                      {
                          "ResponseTime": "2020-10-22T21:21:04.354894Z",
                          "ResourceType": 2,
                          "OperationType": 40,
                          "StoreResult": "StorePhysicalAddress: rntbd://cdb-ms-prod-northeurope1-fd8.documents.azure.com:14173/apps/.../, LSN: 304, GlobalCommittedLsn: 303, PartitionKeyRangeId: 0, IsValid: True, StatusCode: 200, SubStatusCode: 0, RequestCharge: 7.62, ItemLSN: -1, SessionToken: ..., UsingLocalLSN: False, TransportException: null"
                      }
                  ],
                  "AddressResolutionStatistics": [],
                  "SupplementalResponseStatistics": [],
                  "FailedReplicas": [],
                  "RegionsContacted": [
                      "<redacted>"
                  ],
                  "ContactedReplicas": [
                      "rntbd://cdb-ms-prod-northeurope1-fd8.documents.azure.com:14173/apps/<redacted>/",
                      "rntbd://cdb-ms-prod-northeurope1-fd8.documents.azure.com:14387/apps/<redacted>/",
                      "rntbd://cdb-ms-prod-northeurope1-fd8.documents.azure.com:14215/apps/<redacted>/",
                      "rntbd://cdb-ms-prod-northeurope1-fd8.documents.azure.com:14064/apps/<redacted>/"
                  ]
              }
          },
          {
              "Id": "BatchAsyncContainerExecutor.ToResponse",
              "ElapsedTime": "00:00:00.0000295"
          }
      ]
  }
  

Answer 1

您似乎正在使用批量模式。请记住，批量模式是在发送大量操作时使RU饱和的模式。你提到你正在发送

另请检查：

• 您是否正在使用辛格尔顿宇宙客户端？
• 实例是否在与写入 Cosmos DB 区域相同的区域中运行？
• 更新您的 SDK，您使用的是版本 3.6.0，在 3.11.0 中对批量（如果您仍要使用批量）进行了改进，以使其在低文档计数方案中更快。