Выходные данные разделов служебной шины из Azure Stream Analytics

Очереди служебной шины предоставляют метод обмена данными от отправителя к получателю. Разделы служебной шины предоставляют форму взаимодействия "один ко многим".

В следующей таблице перечислены имена свойств и их описания для создания выходных данных раздела служебной шины.

Имя свойства Описание
Псевдоним выходных данных Понятное имя, используемое в запросах для направления выходных данных запроса в этот раздел служебной шины.
Пространство имен служебной шины Контейнер для набора сущностей обмена сообщениями. При создании нового концентратора событий вы также создали пространство имен служебной шины.
Имя раздела Разделы — это сущности обмена сообщениями, аналогичные концентраторам событий и очередям. Они предназначены для сбора потоков событий с устройств и служб. При создании раздела также присваивается определенное имя. Сообщения, отправленные в раздел, недоступны, если подписка не создана, поэтому убедитесь, что в разделе есть одна или несколько подписок.
Имя политики раздела При создании раздела служебной шины можно также создать политики общего доступа на вкладке "Настройка раздела". Каждая политика общего доступа имеет имя, заданные разрешения и ключи доступа.
Ключ политики раздела Общий ключ доступа, используемый для проверки подлинности доступа к пространству имен служебной шины.
Формат сериализации событий Формат сериализации выходных данных. Поддерживаются JSON, CSV и Avro.
Кодирование Если используется формат CSV или JSON, необходимо указать кодировку. В настоящее время единственным поддерживаемым форматом кодировки является UTF-8.
Разделитель Применимо только для сериализации CSV. Stream Analytics поддерживает ряд общих разделителей для сериализации данных в формате CSV. Поддерживаемые значения: запятая, точка с запятой, пробел, вкладка и вертикальная полоса.
Столбцы свойств Необязательно. Разделенные запятыми столбцы, которые должны быть присоединены в качестве свойств пользователя исходящего сообщения, а не полезных данных. Дополнительные сведения об этой функции приведены в разделе "Настраиваемые свойства метаданных" для выходных данных.
Столбцы системного свойства Необязательно. Пары "Ключевые значения" системных свойств и соответствующие имена столбцов, которые должны быть присоединены к исходящему сообщению вместо полезных данных.

Количество секций основано на номере SKU служебной шины и размере. Ключ секции — это уникальное целочисленное значение для каждой секции.

Partitioning

Секционирование автоматически выбирается. Количество секций основано на номере SKU служебной шины и размере. Ключ секции — это уникальное целочисленное значение для каждой секции. Число операций записи выходных данных совпадает с числом секций в выходном разделе.

Размер выходного пакета

Максимальный размер сообщения составляет 256 КБ для уровня "Стандартный" и 1 МБ для уровня "Премиум". Дополнительные сведения см. в разделе об ограничениях служебной шины. Для оптимизации используйте одно событие для каждого сообщения.

Настраиваемые свойства метаданных для выходных данных

Вы можете присоединить столбцы запросов в качестве свойств пользователя к исходящим сообщениям. Эти столбцы не попадают в полезные данные. Свойства присутствуют в виде словаря в выходном сообщении. Ключом является имя столбца и значение столбца в словаре свойств. Поддерживаются все типы данных Stream Analytics, кроме записей и массивов.

В следующем примере поля DeviceId и DeviceStatus добавляются в метаданные.

  1. Используйте следующий запрос:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. Настройте DeviceId,DeviceStatus столбцы свойств в выходных данных.

    Столбцы свойств

На следующем рисунке представлены ожидаемые свойства выходных сообщений, проверенные в EventHub с помощью Service Bus Explorer.

Настраиваемые свойства события

Свойства системы

Вы можете присоединить столбцы запросов как системные свойства к исходящим сообщениям очереди служебной шины или раздела. Эти столбцы не попадают в полезные данные, а соответствующее системное свойство ServiceBusMessage заполняется значениями столбца запроса. Эти системные свойства поддерживаются . MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc

Строковые значения этих столбцов анализируются как соответствующий тип значения системного свойства, а все ошибки синтаксического анализа обрабатываются как ошибки данных. Это поле предоставляется в формате объекта JSON. Сведения об этом формате приведены следующим образом:

  • Окруженные фигурными скобками {}.
  • Записаны пары "ключ-значение".
  • Ключи и значения должны быть строками.
  • Ключом является имя и значение системного свойства — имя столбца запроса.
  • Ключи и значения разделены двоеточием.
  • Каждая пара "ключ-значение" разделена запятой.

В этом разделе показано, как использовать это свойство:

  • Запрос: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • Столбцы системных свойств: { "MessageId": "column1", "PartitionKey": "column2"}

Это задает MessageId сообщения очереди служебной шины со значениями column1и PartitionKey заданы значениями column2.

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

  • Last updated on