使用事件中心向 Azure 时序见解 Gen1 环境发送事件

项目
09/30/2020

注释

时序见解服务将于 2024 年 7 月 7 日停用。请考虑尽快将现有环境迁移到备用解决方案。关于废弃和迁移的详细信息，请访问我们的文档。

谨慎

这是一篇 Gen1 文章。

本文介绍如何在 Azure 事件中心中创建和配置事件中心。其中还介绍了如何运行样本应用程序，将事件从事件中心推送到 Azure 时序洞察。如果你已经有了一个事件中心，其中的事件采用 JSON 格式，则可跳过本教程，在 Azure 时序见解中查看你的环境。

配置事件中心

若要了解如何创建事件中心，请阅读事件中心文档。
在搜索框中，搜索“事件中心”。在返回的列表中选择“事件中心”。
选择事件中心。
在创建事件中心时，实际上要创建事件中心命名空间。如果尚未在命名空间中创建事件中心，请在菜单中的“实体”下创建事件中心。
创建事件中心后，请在事件中心列表中选择它。
在菜单中的“实体”下，选择“事件中心” 。
选择事件中心的名称对其进行配置。
在“总览”下选择“消费者组”，然后选择“消费者组”。
请确保创建一个专门由 Azure 时序见解事件源使用的使用者组。

重要

请确保该使用者组没有被任何其他服务（例如 Azure 流分析作业或另一个 Azure 时序见解环境）使用。如果使用者组由其他服务使用，则此环境和其他服务的读取操作会受到负面影响。如果使用 $Default 作为使用者组，则其他读者可能会重复使用使用者组。
在菜单中的“设置”下，选择“共享访问策略”，然后选择“添加” 。
在“添加新的共享访问策略”窗格中，创建名为“MySendPolicy”的共享访问。将使用此共享访问策略在本文后面的 C# 示例中发送事件。
在“索赔”下选择“发送”复选框。

添加 Azure 时序见解实例

在 Azure 时序见解 Gen2 中，可以使用时序模型 (TSM) 将上下文数据添加到传入遥测中。在 TSM 中，标记或信号称为“实例”，你可以将上下文数据存储在“实例字段”中。在查询时使用“时间序列 ID”联接该数据。我们在本文后面使用的示例风车项目的“时间序列 ID”是。若要详细了解如何在实例字段中存储数据，请参阅时序模型概述。

创建 Azure 时序洞察事件源

如果尚未创建事件源，请完成步骤以创建事件源。
为 timeSeriesId 设置一个值。若要详细了解时序 ID，请阅读时序模型。

将事件推送到风车的示例

在搜索栏中搜索“事件中心”。在返回的列表中选择“事件中心”。
选择您的事件中心实例。
转到共享访问策略>MySendPolicy。复制“连接字符串 - 主密钥”的值。
导航到 TSI Sample Wind Farm Pusher。该网站创建并运行风车模拟设备。
在网页上的“事件中心连接字符串”框中，粘贴在 windmill 输入字段中复制的连接字符串。
选择“点击开始”。

小提示

风车模拟器还会创建 JSON，可用作 Azure 时序见解 GA 查询 API 的负载。

注释

模拟器将继续发送数据，直到浏览器选项卡关闭。
返回到 Azure 门户中的事件中心。在“概述”页上，显示事件中心收到的新事件。

支持的 JSON 形状

示例 1

输入：一个简单的 JSON 对象。

{
    "id":"device1",
    "timestamp":"2016-01-08T01:08:00Z"
}

输出：一个事件。

id timestamp

设备1 2016-01-08T01:08:00Z

id	timestamp
设备1	2016-01-08T01:08:00Z

示例 2

输入：包含两个 JSON 对象的 JSON 数组。每个 JSON 对象都转换为事件。

[
    {
        "id":"device1",
        "timestamp":"2016-01-08T01:08:00Z"
    },
    {
        "id":"device2",
        "timestamp":"2016-01-17T01:17:00Z"
    }
]

输出：两个事件。

id timestamp

设备1 2016-01-08T01:08:00Z

设备2 2016-01-08T01:17:00Z

id	timestamp
设备1	2016-01-08T01:08:00Z
设备2	2016-01-08T01:17:00Z

示例三

输入：具有嵌套 JSON 数组（其中包含两个 JSON 对象）的 JSON 对象。

{
    "location":"WestUs",
    "events":[
        {
            "id":"device1",
            "timestamp":"2016-01-08T01:08:00Z"
        },
        {
            "id":"device2",
            "timestamp":"2016-01-17T01:17:00Z"
        }
    ]
}

输出：两个事件。 “location”属性会被复制到每个事件中。

位置 events.id 事件.时间戳

WestUs 设备1 2016年1月8日 01:08:00

WestUs 设备2 2016年01月08日 01:17:00

位置	events.id	事件.时间戳
WestUs	设备1	2016年1月8日 01:08:00
WestUs	设备2	2016年01月08日 01:17:00

示例四

输入：具有嵌套 JSON 数组（其中包含两个 JSON 对象）的 JSON 对象。此输入表明复杂 JSON 对象可以表示全局属性。

{
    "location":"WestUs",
    "manufacturer":{
        "name":"manufacturer1",
        "location":"EastUs"
    },
    "events":[
        {
            "id":"device1",
            "timestamp":"2016-01-08T01:08:00Z",
            "data":{
                "type":"pressure",
                "units":"psi",
                "value":108.09
            }
        },
        {
            "id":"device2",
            "timestamp":"2016-01-17T01:17:00Z",
            "data":{
                "type":"vibration",
                "units":"abs G",
                "value":217.09
            }
        }
    ]
}

输出：两个事件。

位置	制造商.名称	制造商位置	events.id	事件.时间戳	事件.数据.类型	events.data.units（事件数据单位）	events.data.value
WestUs	制造商1	EastUs	设备1	北京时间 2016年1月8日 01:08 (UTC)	压力	psi	108.09
WestUs	manufacturer1	EastUs	设备2	2016-01-08T01:17:00Z	振动	abs G	217.09

后续步骤

阅读有关 IoT 中心设备消息的详细信息

通过