Azure Functions（三）集成 Azure Queue Storage 存储消息

• 2021 年 3 月 3 日
• 筆記
• Azure

一，引言

　　接着上一篇文章继续介绍 Azure Functions，今天我们将尝试绑定 Queue Storage，将消息存储到 Queue 中，并且学会适用于 Azure Functions 的 Azure 队列存储输出绑定，以达到 Azure Functions 设置输出绑定来创建新的 Azure Queue Storage。以下是今天讲解内容的基础设施资源的架构图

——————–Azure Functions 系列——————–

1，使用 Visual Studio 开发、测试和部署 Azure Functions（一）开发

2，使用 Visual Studio 开发、测试和部署 Azure Functions（二）测试，部署

3，使用Azure Functions 在web 应用中启用自动更新（一）分析基于轮询的 Web 应用的限制

4，Azure Functions（一）什么是 ServerLess

5，Azure Functions（二）集成 Azure Blob Storage 存储文件

6，Azure Functions（三）集成 Azure Queue Storage 存储消息

二，正文

1，创建 Queue Storage

我们可以在现有的 Azure Storage Account 上创建 Queue，找到 “Web_Test_Functions_RG” 中的叫 “cnbatestorageaccount” 的 Storage Account.

点击进入后，选择 “Queue service=》Queue”，点击 “+ Queue” 添加新的 Queue Storage

输入 Queue name：“validationcode”，点击 “OK”

添加完成后，可以看到当前的 Queue 的信息

2，Azure Function App 添加对 Queue Storage 的使用方法

2.1，新创建 Azure Function 项目，并且命名为 “UploadTxt.Queue”，并且添加相关 Nuget 依赖包的引用

使用程序包管理器控制台进行安装

Install-Package Microsoft.Azure.Functions.Extensions -Version 1.1.0
Install-Package Microsoft.Azure.WebJobs.Extensions.Storage -Version 4.0.4
Install-Package Microsoft.Extensions.DependencyInjection -Version 3.1.0
Install-Package Microsoft.NET.Sdk.Functions -Version 3.0.11

大家需要主要的是，我们如果想要操作 Queue Storage，我们就必须添加 “Microsoft.Azure.WebJobs.Extensions.Storage”

2.2，添加Queue Storage绑定以及实现 Http 触发器的方法内容

我们需要在方法的参数中绑定 Queue Storage，并且需要制定 Storage Account 的连接字符串以及 Queue Storage 的名称。

 Storage Account 的连接字符串需要配置在 “local.settings.json” 中

{
  "IsEncrypted": false,
  "Values": {
    //"AzureWebJobsStorage": "UseDevelopmentStorage=fasle",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet",
    "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=cnbatestorageaccount;AccountKey=XXXXXXXXXXXXXXXXXXXXX;EndpointSuffix=core.windows.net"
  }
}

2.3，Queue Storage 中添加信息

string content ="My name is Allen,he is zhangsan";
queue.Add(content);

3，测试Htpp Trigger，通过网络请求将信息保存到 Queue Storage 中

F5运行，复制控制台中显示的 Function App 的访问的URL：//localhost:7071/api/UpLoadTrigger_Input_Binding

我们在postman 中输入URL，并点击 “Send” 进行测试

我们发送完请求之后，可以看到返回的200ok (状态码)

同时，我们可以在控制台中看到执行成功的日志

回到 VS 中，我们使用 ”Cloud Expoere“ 工具查看Queue Storage 中的信息

VS 点击 ”视图=》Cloud Expoere“

点击当前 ”账号管理“ 找到与之对应的自己的Azure 订阅相关联的账号

点击 ”cnbateblogaccount“ 的 Azure Storage 账号，找到刚刚创建好的 ”validationcode“ Azure Queue Storage，右键点击”打开“

 OK，我们成功的将信息写到 Queue Storage 中。

今天的分享到此结束，撒花🎉🎉🎉🎉🎉🎉！

三，结尾

　　今天，我们通过代码演示了一下如何通过Azure Functions 操作 Queue，将文本信息写入到Queue Storage。大家对于这个偏操作类的实践要多多练习，实际的要操作一番才会更加深入的了解