如何在 C# ASP.NET Web API 2 中从 Azure 队列返回 HTTP 状态代码

Question

我有一个 web api（在 ASP.NET Web API 2 上用 c# 编写）。其中一种方法采用 HTTP POST 并将其添加到 Azure 队列。

我想知道如何从 Azure 队列中获取 http 状态码（或任何可用的），以便我可以从我的方法中返回适当的 http 状态码。

到目前为止的代码是这样的：

[Route("api/v1/somewhere/")]
        [ResponseType(typeof(Thingy))]
        public async Task<IHttpActionResult> Post(Thingy thingy)
        {
            if (!ModelState.IsValid)
            {
                return BadRequest(ModelState);
            }

            var storageAccount = CloudStorageAccount.Parse(ConfigurationManager.ConnectionStrings["AzureWebJobsStorage"].ToString());
            var queueClient = storageAccount.CreateCloudQueueClient();
            var queue = queueClient.GetQueueReference("thingys");

            var msg = new CloudQueueMessage(JsonConvert.SerializeObject(thingy));
            await queue.AddMessageAsync(msg);

            return Json(thingy);
        }

如果await queue.AddMessageAsync(msg); 一切顺利，我想换掉return Json(thingy); 行并返回http 状态代码202，如果出现问题，则返回另一个适当的代码。

有什么想法吗？

Answer 1

您应该使用OperationContext 对象的LastResult 属性。它有一个HttpStatusCode 属性，它将从存储服务返回状态代码。这是一个相同的例子：

    static void QueueTest1()
    {
        var account = new CloudStorageAccount(new StorageCredentials(accountName, accountKey), true);
        var queueClient = account.CreateCloudQueueClient();
        var queue = queueClient.GetQueueReference("my-queue");
        queue.CreateIfNotExists();
        var messageContents = "This is a test message";
        var opContext = new OperationContext();
        var msg = new CloudQueueMessage(messageContents);
        queue.AddMessage(msg, null, null, null, opContext);
        var statusCode = opContext.LastResult.HttpStatusCode;
        Console.WriteLine("Status Code = " + statusCode);//Prints 201 as status code
        queue.DeleteIfExists();
    }

Answer 2

查看此页面： http://bitoftech.net/2014/03/05/new-asp-net-web-api-2-ihttpactionresult-cors-tutorial/

我认为你应该在你自己的类中包装你想要的响应，像这样：

public class MyResponse : IHttpActionResult
{
    public string Message { get; private set; }
    public HttpRequestMessage Request { get; private set; }


    public Task<HttpResponseMessage> ExecuteAsync(CancellationToken cancellationToken)
    {
        return Task.FromResult(ExecuteResult());
    }

    public HttpResponseMessage ExecuteResult()
    {
        HttpResponseMessage response = new HttpResponseMessage(HttpStatusCode.Accepted);

        response.Content = new StringContent(Message);
        response.RequestMessage = Request;
        return response;
    }
}