Azure函数中的Cosmos DB 408响应

Question

我有一个Azure函数（v2），可以访问Cosmos DB，但不是通过绑定（我们需要使用自定义序列化设置）。我遵循了这里的示例来设置一个对象，该对象应可用于活动函数的所有实例。我的有点不同，因为我们的自定义＜code＞CosmosDb

public static class AnalyzeActivityTrigger
{
    private static readonly Lazy<Task<CosmosDb>> LazyCosmosDb = new Lazy<Task<CosmosDb>>(InitializeDocumentClient);
    private static Task<CosmosDb> CosmosDb => LazyCosmosDb.Value;

    private static Task<CosmosDb> InitializeDocumentClient()
    {
        return StorageFramework.CosmosDb.GetCosmosDb(DesignUtilities.Storage.CosmosDbContainerDefinitions, DesignUtilities.Storage.CosmosDbMigrations);
    }

    [FunctionName(nameof(AnalyzeActivityTrigger))]
    public static async Task<Guid> Run(
        [ActivityTrigger]DurableActivityContext context,
        ILogger log)
    {
        var analyzeActivityRequestString = context.GetInput<string>();
        var analyzeActivityRequest = StorageFramework.Storage.Deserialize<AnalyzeActivityRequest>(analyzeActivityRequestString);
        var componentDesign = StorageFramework.Storage.Deserialize<ComponentDesign>(analyzeActivityRequest.ComponentDesignString);

        var (analysisSet, _, _) = await AnalysisUtilities.AnalyzeComponentDesignAndUploadArtifacts(componentDesign,
            LogVariables.Off, new AnalysisLog(), Stopwatch.StartNew(), analyzeActivityRequest.CommitName, await CosmosDb);

        return analysisSet.AnalysisReport.Guid;
    }
}

我们扇出，并行调用此活动函数。我们的文档相当大，因此更新它们很昂贵，这是此代码的一部分。

我有时会在容器时收到此错误。ReplaceItemAsync 称为：

响应状态码不表示成功：408子状态：0原因：（消息：请求超时。...

显然要做的事情似乎是增加超时，但这是否表明存在其他问题？增加超时似乎是在解决症状，而不是问题。我们有代码可以在这一切发生之前扩展我们的RU。我想知道这是否与Azure函数扇形展开有关，这会给它带来太多的负载。所以我也在调整主机。durableTask的json设置，如maxConcurrentActivityFunctions，和maxConcurrent OrchestratorFunctions，但到目前为止无效。

我应该如何处理这个408错误？除了增加请求超时时间之外，我还可以考虑采取什么措施来缓解这种情况？

更新1：我将默认请求超时时间增加到5分钟，现在我得到了503个响应。

更新 2：指向发布到高级计划中的 Azure 函数的克隆似乎在经过多次测试后仍能正常工作。

更新3：我们对它的测试不够努力。该问题也出现在Premium计划中。GitHub问题即将发布。

更新4：我们似乎已经通过在连接到Cosmos时使用网关模式和增加RU来解决这个问题。

Answer 1

超时确实可以表明有关实例资源的问题。参考：https://docs.microsoft.com/azure/cosmos-db/troubleshoot-dot-net-sdk#request-timeouts

如果在函数上运行，请查看连接。还要验证实例中的 CPU 使用情况。如果 CPU 很高，则可能会影响请求延迟并最终导致超时。

对于函数，你当然可以使用DI来避免整个懒惰声明:https://github . com/Azure/Azure-cosmos-dot net-v3/tree/master/Microsoft。Azure.Cosmos.Samples/Usage/AzureFunctions

使用以下内容创建< code>Startup.cs文件:

using System;
using Microsoft.Azure.Cosmos;
using Microsoft.Azure.Functions.Extensions.DependencyInjection;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;

[assembly: FunctionsStartup(typeof(YourNameSpace.Startup))]

namespace YourNameSpace
{
    public class Startup : FunctionsStartup
    {
        public override void Configure(IFunctionsHostBuilder builder)
        {
            builder.Services.AddSingleton((s) => {
                CosmosClient cosmosClient = new CosmosClient("connection string");

                return cosmosClient;
            });
        }
    }
}

然后你可以让你的函数不是静态的并注入它：

public class AnalyzeActivityTrigger
{
    private readonly CosmosClient cosmosClient;
    public AnalyzeActivityTrigger(CosmosClient cosmosClient)
    {
        this.cosmosClient = cosmosClient;
    }

    [FunctionName(nameof(AnalyzeActivityTrigger))]
    public async Task<Guid> Run(
        [ActivityTrigger]DurableActivityContext context,
        ILogger log)
    {
        var analyzeActivityRequestString = context.GetInput<string>();
        var analyzeActivityRequest = StorageFramework.Storage.Deserialize<AnalyzeActivityRequest>(analyzeActivityRequestString);
        var componentDesign = StorageFramework.Storage.Deserialize<ComponentDesign>(analyzeActivityRequest.ComponentDesignString);

        var (analysisSet, _, _) = await AnalysisUtilities.AnalyzeComponentDesignAndUploadArtifacts(componentDesign,
            LogVariables.Off, new AnalysisLog(), Stopwatch.StartNew(), analyzeActivityRequest.CommitName, this.cosmosClient);

        return analysisSet.AnalysisReport.Guid;
    }
}