2.AzureFunctions实战-创新互联

本案例适用于开发者入门理解Azure Functions/ IoT Hub / Service Bus / Power BI等几款产品。

从事成都棕树电信机房，服务器租用，云主机，网站空间，空间域名，CDN，网络代维等服务。

主要实战的内容为：

1. 将设备遥测数据上传到物联网中心，

2. 将遥测数据路由到消息中间件的Topic中，

3. 使用Azure Function解析消息中间件Topic中的消息并推送到大屏 。

先了解下Azure Functions的基本概念：

https://v.qq.com/x/page/j3031z2zlns.html

在Azure Portal 创建Functions 并体验：

https://v.qq.com/x/page/v3031m1g9vv.html

IoT Hub 和Service Bus的准备工作，请参考：

设备数据通过Azure Functions 推送到 Power BI 数据大屏进行展示（1.准备工作）

使用Visual studio 2019 创建并发布Functions：

https://v.qq.com/x/page/a3031iu2d4q.html

本示例中的示例代码：

using System;using System.IO;using System.Net;using System.Text;using Microsoft.Azure.WebJobs;using Microsoft.Azure.WebJobs.Host;using Microsoft.Extensions.Logging;using Newtonsoft.Json;namespace FunctionApp2{    public static class Function1    {        [FunctionName("Function1")]        public static void Run([ServiceBusTrigger("fromiothubtopic", "sub", Connection = "sbconn")]string mySbMsg, ILogger log)        {            log.LogInformation($"C# ServiceBus topic trigger function processed message: {mySbMsg}");            string url = "https://api.powerbi.cn/beta/请替换成您自己的URL";            IoTDeviceMsg msg = JsonConvert.DeserializeObject<IoTDeviceMsg>(mySbMsg);            // Create JSON message            var telemetryDataPoint = new            {                temperature = msg.temperature,                humidity = msg.humidity,                time = DateTime.Now            };            var messageString = JsonConvert.SerializeObject(telemetryDataPoint);            HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);            req.Method = "POST";            req.Timeout = 8000;//设置请求超时时间，单位为毫秒            req.ContentType = "application/json";            byte[] data = Encoding.UTF8.GetBytes("[" + messageString + "]");            req.ContentLength = data.Length;            using (Stream reqStream = req.GetRequestStream())            {                reqStream.Write(data, 0, data.Length);                reqStream.Close();            }            HttpWebResponse resp = (HttpWebResponse)req.GetResponse();            Stream stream = resp.GetResponseStream();            //获取响应内容            if (resp.StatusCode == HttpStatusCode.OK)            {                log.LogInformation($"OK: {messageString}");            }        }    }    public class IoTDeviceMsg    {        public decimal temperature { get; set; }        public decimal humidity { get; set; }    }}

针对开发人员入门，需关注如下基本概念：

1.Azure Functions Trigger

AzureFunctions 提供了几种模板，模板支持如下的触发：

HTTPTrigger - 使用 HTTP 请求触发执行代码。 

TimerTrigger - 按预定义的计划执行清除或其他批处理任务。

CosmosDBTrigger - 在 NoSQL 数据库中以集合形式添加或更新Azure CosmosDB 文档时，对这些文档进行处理。 

QueueTrigger - 当消息到达 Azure 存储队列时，响应这些消息。

BlobTrigger - Azure 存储 blob 添加到容器时，处理这些 blob。 可以使用此函数调整图像大小。

EventHubTrigger - 响应传送到 Azure 事件中心的事件。 

ServiceBusQueueTrigger - 通过侦听消息队列将代码连接到其他Azure 服务或本地服务。

ServiceBusTopicTrigger - 通过订阅主题将代码连接到其他Azure 服务或本地服务。

2. Azure Functions 集成

AzureFunctions 可与各种 Azure 和第三方服务集成。 这些服务可以触发函数开始执行，或者可用作代码的输入和输出。 AzureFunctions 支持以下服务集成：

Azure CosmosDB

Azure 事件中心

Azure 通知中心

Azure 服务总线（队列和主题）

Azure 存储（blob、队列和表）

本地（使用服务总线）

两种计费方式：

使用计划（Consumptionplan）：只为代码运行时间付费

应用服务计划（App Serviceplan）：将函数像 Web 应用一样运行。 如果已对其他应用程序使用应用服务，可以按相同的计划运行自己的函数，而不用另外付费。

具体的计费请参考：

https://www.azure.cn/zh-cn/pricing/details/azure-functions/

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

网页标题：2.AzureFunctions实战-创新互联
本文网址：https://www.cdcxhl.com/article32/dpspsc.html

成都网站建设公司_创新互联，为您提供网站设计公司、用户体验、定制开发、静态网站、网站策划、企业建站

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联