WindowsAzure.Storage.Queue 与 dotnet core 3.1 兼容吗？

Question

我已经将一个项目从 dotnet core 2.2 迁移到 3.1，但似乎部分代码没有按预期工作：任务被取消并且 GetMessageQueue() returns 的调用为空。在一个class用来执行一些自动化测试，我有以下方法：

public static async Task<CloudQueueMessage> WaitForMessage(this CloudQueue queue, TimeSpan interval, CancellationToken ct)
        {
            var message = await queue.GetMessageAsync();
            while (message == null)
            {
                await Task.Delay(interval, ct);
                ct.ThrowIfCancellationRequested();
                message = await queue.GetMessageAsync();
            }
        }

我是这样称呼它的：

await myObject.CallbackQueue.WaitForMessage(TimeSpan.FromSeconds(1),
                new CancellationTokenSource(TimeSpan.FromSeconds(60)).Token)

在dotnet core 2.2 CloudQueueMessage中使用了来自Microsoft.WindowsAzure.Storage.Queue和方法returns的消息，但是在3.1中似乎没有返回消息并且任务被取消了。我已经用 Microsoft.Azure.Storage.Queue 替换了包 Microsoft.WindowsAzure.Storage.Queue，但仍然是同样的问题。

重现：

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Queue;
using System;
using System.Threading;
using System.Threading.Tasks;

 public async Task Test()
        {


            CloudStorageAccount storageAccount = CloudStorageAccount.Parse("UseDevelopmentStorage=true");
            CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
            CloudQueue queue = queueClient.GetQueueReference("callbackmock");

            var message = await queue.GetMessageAsync();
            var ct = new CancellationTokenSource(TimeSpan.FromSeconds(60)).Token;
            while (message == null)
            {
                await Task.Delay(TimeSpan.FromSeconds(1), ct);
                ct.ThrowIfCancellationRequested();
                message = await queue.GetMessageAsync();
            }

        }

Answer 1

.NET Core 3.1 似乎不支持您在此处使用的 nuget。请关注 Tutorial: Work with Azure Queue Storage queues in .NET 并使用如下代码读取队列消息：

static async Task<string> RetrieveNextMessageAsync(QueueClient theQueue)
{
    if (await theQueue.ExistsAsync())
    {
        QueueProperties properties = await theQueue.GetPropertiesAsync();

        if (properties.ApproximateMessagesCount > 0)
        {
            QueueMessage[] retrievedMessage = await theQueue.ReceiveMessagesAsync(1);
            string theMessage = retrievedMessage[0].MessageText;
            await theQueue.DeleteMessageAsync(retrievedMessage[0].MessageId, retrievedMessage[0].PopReceipt);
            return theMessage;
        }

        return null;
    }

    return null;
}

WindowsAzure.Storage.Queue 与 dotnet core 3.1 兼容吗？

Is WindowsAzure.Storage.Queue compatible with dotnet core 3.1?

.net

c#

task

azure-storage