设备数据通过Azure Functions 推送到 Power BI 数据大屏进行展示(2.Azure Functions实战)

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

 

主要实战的内容为:

 

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

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

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

     

设备数据通过Azure Functions 推送到 Power BI 数据大屏进行展示(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

 

本示例中的示例代码:

sing 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/

 

设备数据通过Azure Functions 推送到 Power BI 数据大屏进行展示(2.Azure Functions实战)

上一篇:javascript中的高阶函数


下一篇:Rustlings_functions