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

Внимание!

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

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

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

  1. Чтобы создать концентратор событий, следуйте инструкциям из документации по Центрам событий.

  2. В поле поиска введите Центры событий. В возвращенном списке выберите Центры событий.

  3. Выберите свой концентратор событий.

  4. Создавая концентратор событий, вы на самом деле создаете его пространство имен. Если вы еще не создали концентратор событий в пространстве имен, создайте его в меню в разделе Сущности.

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

  5. После создания концентратора событий выберите его в списке.

  6. В меню в разделе Сущности выберите Центры событий.

  7. Выберите имя концентратора событий, чтобы настроить его.

  8. В разделе Обзор щелкните Группы потребителей, а затем выберите группу объектов-получателей.

    Создание группы потребителей

  9. Создайте группу потребителей, которая используется исключительно источником событий Аналитики временных рядов Azure.

    Важно!

    Убедитесь, что эта группа объектов-получателей не используется другой службой (например, заданием Azure Stream Analytics или другой средой службы "Аналитика временных рядов Azure"). Если группа объектов-получателей используется другими службами, это негативно скажется на операции чтения в этой среде и в других службах. Использование $Default в качестве группы объектов-получателей может потенциально привести к ее повторному использованию другими читателями.

  10. В меню в разделе Параметры выберите Политики общего доступа, а затем — Добавить.

    Выбор элемента

  11. На панели Добавить новую политику общего доступа создайте политику общего доступа с именем MySendPolicy. Далее вы будете использовать эту политику общего доступа для отправки событий в примерах C#.

    Ввод MySendPolicy в поле имени политики

  12. В разделе Утверждение установите флажок Отправить.

Добавление экземпляра службы "Аналитика временных рядов Azure"

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

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

  1. Если вы еще не создали источник событий, создайте его, выполнив соответствующие шаги.

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

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

  1. В поле поиска введите Центры событий. В возвращенном списке выберите Центры событий.

  2. Выберите свой экземпляр концентратора событий.

  3. Перейдите в раздел политики общего доступаMySendPolicy. Скопируйте значение параметра Строка подключения — первичный ключ.

    Копирование значения строки подключения первичного ключа

  4. Перейдите к https://tsiclientsample.azurewebsites.net/windFarmGen.html. URL-адрес создает и запускает имитацию устройств ветряных мельниц.

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

    Вставка строки подключения первичного ключа в поле Event Hub Connection String (Строка подключения концентратора событий)

  6. Выберите Click to start (Запустить).

    Совет

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

    Примечание

    Симулятор продолжит отправку данных, пока вкладка браузера не закроется.

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

    Страница обзора концентратора событий, отображающая метрики для концентратора событий

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

Пример 1

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

    {
        "id":"device1",
        "timestamp":"2016-01-08T01:08:00Z"
    }
    
  • Выходные данные: одно событие.

    идентификатор TIMESTAMP
    device1 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"
        }
    ]
    
  • Выходные данные: два события.

    идентификатор TIMESTAMP
    device1 2016-01-08T01:08:00Z
    device2 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 копируется для каждого события.

    location events.id events.timestamp
    WestUs device1 2016-01-08T01:08:00Z
    WestUs device2 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
                }
            }
        ]
    }
    
  • Выходные данные: два события.

    location manufacturer.name manufacturer.location events.id events.timestamp events.data.type events.data.units events.data.value
    WestUs manufacturer1 EastUs device1 2016-01-08T01:08:00Z давление psi 108.09
    WestUs manufacturer1 EastUs device2 2016-01-08T01:17:00Z vibration abs G 217.09

Дальнейшие действия