2.AzureFunctions实战

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

创新互联专注于企业成都营销网站建设、网站重做改版、芒市网站定制设计、自适应品牌网站建设、HTML5成都做商城网站、集团公司官网建设、成都外贸网站建设、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为芒市等各大城市提供网站开发制作服务。

主要实战的内容为:

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

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

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

2.Azure Functions实战

先了解下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(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/

2.Azure Functions实战


本文标题:2.AzureFunctions实战
网页链接:http://scyanting.com/article/pgoopd.html