产品定价 立即试用
专业版
文档 > 集成 > Azure事件中心
入门
指南 安装 架构 API 常见问题
目录

Azure Event Hub 集成

文档信息图标
ThingsBoard PE 功能

专业版支持Platform Integrations功能。
请使用ThingsBoard Cloud自行安装平台实例。

概述

Azure Event Hub集成可从Azure Event Hub向ThingsBoard流式传输数据,并将设备负载转换为ThingsBoard格式。

image

使用Azure门户创建IoT Hub

首先,登录Azure门户

在Azure中创建IoT Hub

现在,您需要创建IoT Hub。您将在这里创建设备并执行一些其他操作。让我们按步骤进行:

  • 在Azure门户中,点击”Create a resource“按钮;
  • 在搜索字段中输入”IoT Hub“,并从列表中选择匹配项;
  • 点击”Create“;
  • 在配置页面中,点击”Create new“,指定资源组和IoT Hub名称,然后点击”Review + create“;
  • 在下一页中,点击”Create“;
  • 等待部署过程完成,然后点击”Go to resource“;

在IoT Hub中创建设备

完成第一步后,按照以下说明创建新设备:

  • 从上下文菜单导航到”IoT devices“页面;
  • 点击”+ New“按钮;
  • 在弹出窗口中,输入”Device ID“并点击”Save“。

很好!您已成功创建新设备。

添加Azure Event Hub集成

1. 基本设置

转到”Integrations center“部分的”Integrations“页面。点击”plus“按钮开始添加新的集成。选择”Azure Event Hub“集成类型并点击”Next“;

image


2. 上行数据转换器

上行转换器用于将设备传入的数据转换为ThingsBoard所需的显示格式。

在函数解码器字段中,指定用于解析和转换数据的脚本。在本示例中,使用默认的解码器函数(或使用您自己的配置)。然后,点击”Next“;

image

您可以在创建后随时更改解码器函数。


3. 下行数据转换器

在添加下行转换器的步骤中,您也可以选择之前创建的或创建新的下行转换器。但目前,将”Downlink data converter”字段留空。点击”Skip“;

image


4. 连接

在Azure门户中获取Event Hub兼容端点:

  • 导航到”IoT Hub“资源;
  • 从上下文菜单打开”Built-in endpoints“页面;
  • 找到并复制”Event Hub-compatible endpoint“值。

该值将用于与ThingsBoard服务进行集成。


要查找container name

  • 在Azure门户中,点击”Storage account“;
  • 转到”Data storage“部分的”Containers“页面。

在这里您可以找到container。保存其名称。


要查找存储connection string值,请导航到”Security + networking“部分的”Access keys“页面。


在ThingsBoard中:

  • 在”Connection String“字段中粘贴已复制的”Event Hub-compatible endpoint“;
  • 启用持久检查点,以便在集成重启后从上次检查点恢复处理,并在”Storage connection string“和”Container name“字段中填入相应的值。禁用此选项则始终从最新事件开始;
  • [可选] 点击”Check connection”按钮检查连接,以验证连接字符串是否正确复制;
  • 最后,点击”Add“按钮创建集成。

image

测试集成!

现在,我们准备好测试集成了。请按照以下步骤操作:

1) 转到”Rule chains“页面并选择一个规则链。在搜索节点字段中输入'gen',在菜单中找到generator节点。将其拖到画布上。在弹出窗口中,指定生成器的名称消息数量生成函数(可以使用我们的示例)。最后,点击”Add“;

1
2
3
4
5
6
7
8
9
10
11
var msg = {
    "devName": "TB-D-01",
    "msg": {
        "temp": 42,
        "humidity": 77
    }
};
var metadata = { data: 40 };
var msgType = "POST_TELEMETRY_REQUEST";

return { msg: msg, metadata: metadata, msgType: msgType };

2) 现在,查找设备的Primary key。转到Azure门户,导航到IoT devices选项卡,选择您的设备,找到”Primary key“字段。复制并保存以备后用;

3) 返回您的ThingsBoard实例。我们需要找到另一个规则节点。在搜索节点字段中输入'iot',选择azure iot hub节点。将其拖到画布上。在弹出窗口中,指定节点名称,将Topic中的<device_id>替换为您的设备名称,并从Azure门户的”IoT Hub“资源中获取Hostname。输入设备名称作为Device ID,并添加之前从设备凭据中复制的SAS KeyPrimary Key)。如果需要监控事件,请启用Debug模式;