博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Azure IOT (EventHub + Stream Analytics + Table Storage)的使用
阅读量:4982 次
发布时间:2019-06-12

本文共 813 字,大约阅读时间需要 2 分钟。

最近研究利用Azure的 Event hub ,Stream Analytics和TableStorage来实现IOT的一个方案,

利用Event hub来采集传感器设备数据值,然后输入到StreamAnalytics进行分析,最后将分析数据流输入到TableStorage进行存储和展现,

我们将利用程序模拟50个传感器终端将数据值传送到Eventhub中进行试验

第一步:在Azure上创建Event Hub、Stream Analytics和TableStorage

1.创建服务总线:

 

创建完成后,单击进入选择事件中心,单击创建一个事件中心

单击进入事件中心,选择配置,设置共享的访问策略

设置完成后单击保存即可。

2.创建流分析

创建完成后单击进入,我们将配置stream的输入、输出、查询

添加输入数据流:

 

输入别名要记住,stream 在查询时要使用到这个别名

至此,输入流配置完毕

添加输出数据流:

选择输出选项卡,进行添加

同样,输出别名将在stream 查询语句中使用,分区键类似于sql中的主键但也有所不同,这里我将设备ID赋值给他

 

至此输出创建完成。

设置查询

查询将利用T-SQL语句进行,pmmstreameh和pmmtable分别是在流分析中创建的事件中心的别名和输出table的别名

数据流输出时会自动在pmmtb(表存储)里面添加 streamOutTime,deviceId,pmValue,addTime列

 

至此,所有配置都完成,接下来启动此流分析然后将模拟程序启动将模拟数据进行推送到Eventhub中

启动流分析:

启动模拟程序:(模拟程序是将数据发送到Event Hub中)

我们用 Azure Storage Explorer连接到表进行查看输出的数据流:

所有配置完成

 

转载于:https://www.cnblogs.com/wanghaixing/p/5280621.html

你可能感兴趣的文章
SQL Server将一列的多行内容拼接成一行
查看>>
Spring Controller RequestMapping
查看>>
socket
查看>>
小程序 跳转问题 (来源见注明)
查看>>
JBPM4入门——9.自动节点单线执行
查看>>
//停止关联的进程
查看>>
SQL 生成公曆和農曆對照數據,公曆查找農曆和農曆查找公曆函數
查看>>
为何场效应管要用UGD与UGS(off)来比较判断夹断情况?
查看>>
.pem证书转xml格式字符串(.net)
查看>>
js构建ui的统一异常处理方案(二)
查看>>
三线程连续打印ABC
查看>>
ECharts
查看>>
初识网络爬虫
查看>>
git push 时不用每次都输入密码的方法
查看>>
54点提高PHP编程效率 引入缓存机制提升性能
查看>>
编解码-marshalling
查看>>
CDN原理
查看>>
java.lang.outofmemoryerror android
查看>>
coding
查看>>
省市联级(DataReader绑定)
查看>>