小编Mo *_* B.的帖子

MessageLockLostExceptions我在处理消息时不断收到消息。

• 我将 Microsoft.Azure.ServiceBus 3.2.0 与 .NET Core 2.1 一起使用。
• 我有一个LockDuration设置为 30 秒的队列，其中已经包含许多要处理的消息。
• 我从https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-dotnet-get-started-with-queues#receive-messages获取了非常基本的消息接收教程代码-from-the-queue，效果很好。

现在我想LockDuration通过添加 来模拟运行时间稍长的消息处理任务（但仍在 之内）Task.Delay(10_000)。但随后我MessageLockLostException每收到 4 条消息就会收到一条消息。

即使我设置了MaxAutoRenewDuration = TimeSpan.FromDays(30)和 ，也会发生这种情况PrefetchCount = 0。

这是消息处理方法，我稍微修改一下，打印出剩余的锁定时长：

    private static async Task processMessagesAsync(Message message, CancellationToken token)
    {
        Console.Write($"Received message: {message.SystemProperties.SequenceNumber}. Remaining lock duration: {message.SystemProperties.LockedUntilUtc - DateTime.UtcNow}");
        await Task.Delay(10000);
        await queueClient.CompleteAsync(message.SystemProperties.LockToken);
        Console.WriteLine(" - Complete!");
    }

示例输出：

======================================================
Press ENTER key to exit after receiving all the messages.
====================================================== …

乍一看，延续令牌在 Cosmos DB 中的作用很明显：将它附加到下一个查询会为您提供下一组结果。但是“下一组结果”究竟是什么意思？

是不是意思：

1. 下一组结果就好像原始查询在第一次查询时没有分页完全执行一样（跳过适当数量的文档）？
2. 下一组结果就好像现在已经执行了原始查询（跳过了适当数量的文档）？
3. 完全不同的东西？

答案 1. 似乎更可取，但不太可能，因为服务器需要存储无限量的状态。但是答案 2. 也有问题，因为它可能会导致不一致，例如，如果基础数据在页面查询之间发生了变化，则同一文档可能会跨页面多次提供。

如果你写这样的东西

this.MyMethod(this.MyMethod(myParam)).Should().BeNull();

使用FluentAssertions库，当断言失败时抛出异常，并显示消息

Expected this.MyMethod(this.MyMethod(myParam)) to be <null>, but found "foo".

它如何设法获取方法调用的语法上下文以生成如此有意义的异常消息？显然使用了某种反射，并且可能使用了一些堆栈跟踪检查（实际上，它仅在调试模式下和表达式写在一行中时才能正常工作），但究竟如何？

更具体地说，如何编写带有签名的方法

Expected this.MyMethod(this.MyMethod(myParam)) to be <null>, but found "foo".

满足（在调试模式下）以下内容？

public static string GetSyntacticContext(object parameter);

我（成功）使用客户端凭据流与 MSAL 来验证应用程序，如下所示：

private static async Task<AuthenticationResult> getAuthResultNonInteractively()
{
    string[] scopes = {"api://xxx/.default"};

    IConfidentialClientApplication app = ConfidentialClientApplicationBuilder.CreateWithApplicationOptions(
            new ConfidentialClientApplicationOptions
            {
                TenantId = "xxx",
                ClientId = "xxx",
                RedirectUri = "http://localhost",
                ClientSecret = "xxx"
            })
        .Build();
    
    // Desired behaviour: acquires token online only if token does not 
    // exist in cache or is expired
    AuthenticationResult authResult = await app.AcquireTokenForClient(scopes)
        .ExecuteAsync();

    return authResult;
}

对first的调用是否AcquireTokenForClient会尝试在令牌缓存中查找令牌，并且仅当令牌在缓存中尚不存在或令牌已过期时才在线获取它？或者它总是在线获取令牌？如果后者是正确的，我需要改变什么才能获得所需的行为？

这个问题涉及到Microsoft.Azure.Cosmos v3.11.0。

该文件中UpsertItemAsync没有为“更新插入”操作指定确切的语义。特别是，它是插入 + 替换，还是插入 +（部分）更新？（我怀疑是前者，因为截至今天这个问题仍然存在。）