2.Azure Functions实战

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

主要实战的内容为：

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/