Отправка событий в среду службы "Аналитика временных рядов Azure" 1-го поколения с помощью концентратора событий

Замечание

Служба "Аналитика временных рядов" будет прекращена 7 июля 2024 года. Рассмотрите возможность переноса существующих сред в альтернативные решения как можно скорее. Для получения дополнительной информации об устаревании и миграции см. нашу документацию.

Осторожность

Это статья Gen1.

Эта статья содержит сведения о том, как создать и настроить концентратор событий в Центрах событий Azure. Здесь также описывается, как запустить пример приложения для отправки событий в службу "Аналитика временных рядов Azure" из Центров событий. Если у вас уже есть концентратор событий, содержащий события в формате JSON, пропустите это руководство и просмотрите свою среду в службе Аналитика временных рядов Azure.

Настройка концентратора событий

Чтобы создать концентратор событий, следуйте инструкциям из документации по Центрам событий.
В поле поиска введите Центры событий. В возвращенном списке выберите Центры событий.
Выберите центр управления событиями.
Когда вы создаете концентратор событий, вы также создаете пространство имен для него. Если вы еще не создали концентратор событий в пространстве имен, создайте его в меню в разделе Сущности.
После создания концентратора событий выберите его в списке концентраторов событий.
В меню в разделе Сущности выберите Центры событий.
Выберите имя концентратора событий, чтобы настроить его.
В разделе Обзор щелкните Группы потребителей, а затем выберите Группу потребителей.
Создайте группу потребителей, которая используется исключительно источником событий Аналитики временных рядов Azure.

Это важно

Убедитесь, что эта группа потребителей не используется никакой другой службой, например, заданием Azure Stream Analytics или другой средой Azure Time Series Insights. Если группа потребителей используется другими службами, это негативно влияет на операции чтения как в этой, так и в других службах. Использование $Default в качестве группы объектов-получателей может потенциально привести к ее повторному использованию другими читателями.
В меню в разделе Параметры выберите Политики общего доступа, а затем — Добавить.
На панели Добавить новую политику общего доступа создайте политику общего доступа с именем MySendPolicy. Далее вы будете использовать эту политику общего доступа для отправки событий в примерах C#.
В разделе Утверждение установите флажок Отправить.

Добавить экземпляр Azure Time Series Insights

В службе "Аналитика временных рядов Azure" 2-го поколения можно добавить контекстные данные во входящую телеметрию с помощью модели временных рядов (ТСМ). В TSM ваши теги или сигналы называются экземплярами, и вы можете хранить контекстные данные в полях экземпляра. Данные присоединяются во время запроса с помощью идентификатора временного ряда. Идентификатор временного ряда для примера проекта ветряных мельниц, который мы будем использовать далее в этой статье, указан как id. Чтобы узнать больше о хранении данных в полях экземпляра, прочтите обзор модели временных рядов.

Создание источника событий службы "Аналитика временных рядов Azure"

Если вы еще не создали источник событий, создайте его, выполнив соответствующие шаги.
Задайте значение для timeSeriesId. Дополнительные сведения об идентификаторе временного ряда см. в статье Модели временных рядов.

Принудительная отправка событий в пример с ветряными мельницами

В поле поиска введите Центры событий. В возвращенном списке выберите Центры событий.
Выберите свой экземпляр концентратора событий.
Перейдите в раздел Политики общего доступа>MySendPolicy. Скопируйте значение параметра Строка подключения — первичный ключ.
Перейдите к TSI Sample Wind Farm Pusher. Сайт создает и запускает имитированные устройства ветряной мельницы.
В поле Строка подключения концентратора событий на веб-странице вставьте строку подключения, скопированную в разделе о поле ввода для ветряных мельниц.
Выберите Нажмите, чтобы начать.

Подсказка

Симулятор ветряных мельниц также создает JSON, который можно использовать в качестве нагрузки для работы с API запросов Azure Time Series Insights GA.

Замечание

Симулятор продолжит отправку данных, пока вкладка браузера не закроется.
Вернитесь к вашему концентратору событий в портале Azure. На странице Обзор отображаются новые события, полученные концентратором событий.

Поддерживаемые формы JSON

Пример 1

Входные данные: простой объект JSON.

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

Выходные данные: одно событие.

id отметка времени

устройство1 08.01.2016 04:08 MSK

id	отметка времени
устройство1	08.01.2016 04:08 MSK

Пример 2

Входные данные: массив JSON с двумя объектами JSON. Каждый объект JSON преобразуется в событие.

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

Выходные данные: два события.

id отметка времени

устройство1 08.01.2016, 01:08 (UTC)

устройство2 2016-01-08T01:17:00Z

id	отметка времени
устройство1	08.01.2016, 01:08 (UTC)
устройство2	2016-01-08T01:17:00Z

Пример 3

Входные данные: объект 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 device1 2016-01-08 01:08:00

WestUs устройство2 2016-01-08T01:17:00Z

расположение	events.id	события.временная_метка
WestUs	device1	2016-01-08 01:08:00
WestUs	устройство2	2016-01-08T01:17:00Z

Пример 4

Входные данные: объект 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
            }
        }
    ]
}

Выходные данные: два события.

расположение	manufacturer.name	местоположение производителя	events.id	events.timestamp	events.data.type	события.дата.единицы	events.data.value
WestUs	производитель1	EastUs	device1	08.01.2016 01:08:00 (UTC)	давление	psi	108.09
WestUs	manufacturer1	EastUs	устройство2	2016-01-08T01:17:00Z	vibration	abs G	217.09

Дальнейшие шаги

Узнайте больше о сообщениях с устройств в Центре Интернета вещей

Last updated on 2020-09-30