Поделиться через

Задания потоковой передачи Microsoft.StreamAnalytics 2016-03-01

  • Статья

Определение ресурса Bicep

Тип ресурса streamingjobs можно развернуть с помощью операций, предназначенных для:

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

Формат ресурсов

Чтобы создать ресурс Microsoft.StreamAnalytics/streamingjobs, добавьте следующий Bicep в шаблон.

resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2016-03-01' = {
  name: 'string'
  location: 'string'
  tags: {
    tagName1: 'tagValue1'
    tagName2: 'tagValue2'
  }
  properties: {
    compatibilityLevel: '1.0'
    dataLocale: 'string'
    eventsLateArrivalMaxDelayInSeconds: int
    eventsOutOfOrderMaxDelayInSeconds: int
    eventsOutOfOrderPolicy: 'string'
    functions: [
      {
        name: 'string'
        properties: {
          type: 'string'
          // For remaining properties, see FunctionProperties objects
        }
      }
    ]
    inputs: [
      {
        name: 'string'
        properties: {
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          type: 'string'
          // For remaining properties, see InputProperties objects
        }
      }
    ]
    outputErrorPolicy: 'string'
    outputs: [
      {
        name: 'string'
        properties: {
          datasource: {
            type: 'string'
            // For remaining properties, see OutputDataSource objects
          }
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
        }
      }
    ]
    outputStartMode: 'string'
    outputStartTime: 'string'
    sku: {
      name: 'Standard'
    }
    transformation: {
      name: 'string'
      properties: {
        query: 'string'
        streamingUnits: int
      }
    }
  }
}

Объекты FunctionProperties

Задайте свойство type , чтобы указать тип объекта .

Для скалярных используйте:

  type: 'Scalar'
  properties: {
    binding: {
      type: 'string'
      // For remaining properties, see FunctionBinding objects
    }
    inputs: [
      {
        dataType: 'string'
        isConfigurationParameter: bool
      }
    ]
    output: {
      dataType: 'string'
    }
  }

Объекты FunctionBinding

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.MachineLearning/WebService используйте:

  type: 'Microsoft.MachineLearning/WebService'
  properties: {
    apiKey: 'string'
    batchSize: int
    endpoint: 'string'
    inputs: {
      columnNames: [
        {
          dataType: 'string'
          mapTo: int
          name: 'string'
        }
      ]
      name: 'string'
    }
    outputs: [
      {
        dataType: 'string'
        name: 'string'
      }
    ]
  }

Для Microsoft.StreamAnalytics/JavascriptUdf используйте:

  type: 'Microsoft.StreamAnalytics/JavascriptUdf'
  properties: {
    script: 'string'
  }

Объекты InputProperties

Задайте свойство type , чтобы указать тип объекта .

Для справки используйте:

  type: 'Reference'
  datasource: {
    type: 'string'
    // For remaining properties, see ReferenceInputDataSource objects
  }

Для Stream используйте:

  type: 'Stream'
  datasource: {
    type: 'string'
    // For remaining properties, see StreamInputDataSource objects
  }

Объекты сериализации

Задайте свойство type , чтобы указать тип объекта .

Для Avro используйте:

  type: 'Avro'
  properties: any()

Для CSV используйте:

  type: 'Csv'
  properties: {
    encoding: 'UTF8'
    fieldDelimiter: 'string'
  }

Для Json используйте:

  type: 'Json'
  properties: {
    encoding: 'UTF8'
    format: 'string'
  }

Объекты ReferenceInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Storage/Blob используйте:

  type: 'Microsoft.Storage/Blob'
  properties: {
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
      }
    ]
    timeFormat: 'string'
  }

Объекты StreamInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Devices/IotHubs используйте:

  type: 'Microsoft.Devices/IotHubs'
  properties: {
    consumerGroupName: 'string'
    endpoint: 'string'
    iotHubNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

Для Microsoft.ServiceBus/EventHub используйте:

  type: 'Microsoft.ServiceBus/EventHub'
  properties: {
    consumerGroupName: 'string'
    eventHubName: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

Для Microsoft.Storage/Blob используйте:

  type: 'Microsoft.Storage/Blob'
  properties: {
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    sourcePartitionCount: int
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
      }
    ]
    timeFormat: 'string'
  }

Объекты OutputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.DataLake/Accounts используйте:

  type: 'Microsoft.DataLake/Accounts'
  properties: {
    accountName: 'string'
    dateFormat: 'string'
    filePathPrefix: 'string'
    refreshToken: 'string'
    tenantId: 'string'
    timeFormat: 'string'
    tokenUserDisplayName: 'string'
    tokenUserPrincipalName: 'string'
  }

Для Microsoft.ServiceBus/EventHub используйте:

  type: 'Microsoft.ServiceBus/EventHub'
  properties: {
    eventHubName: 'string'
    partitionKey: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

Для Microsoft.ServiceBus/Queue используйте:

  type: 'Microsoft.ServiceBus/Queue'
  properties: {
    propertyColumns: [
      'string'
    ]
    queueName: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

Для Microsoft.ServiceBus/Topic используйте:

  type: 'Microsoft.ServiceBus/Topic'
  properties: {
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
    topicName: 'string'
  }

Для Microsoft.Sql/Server/Database используйте:

  type: 'Microsoft.Sql/Server/Database'
  properties: {
    database: 'string'
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }

Для Microsoft.Storage/Blob используйте:

  type: 'Microsoft.Storage/Blob'
  properties: {
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
      }
    ]
    timeFormat: 'string'
  }

Для Microsoft.Storage/DocumentDB используйте:

  type: 'Microsoft.Storage/DocumentDB'
  properties: {
    accountId: 'string'
    accountKey: 'string'
    collectionNamePattern: 'string'
    database: 'string'
    documentId: 'string'
    partitionKey: 'string'
  }

Для Microsoft.Storage/Table используйте:

  type: 'Microsoft.Storage/Table'
  properties: {
    accountKey: 'string'
    accountName: 'string'
    batchSize: int
    columnsToRemove: [
      'string'
    ]
    partitionKey: 'string'
    rowKey: 'string'
    table: 'string'
  }

Для PowerBI используйте:

  type: 'PowerBI'
  properties: {
    dataset: 'string'
    groupId: 'string'
    groupName: 'string'
    refreshToken: 'string'
    table: 'string'
    tokenUserDisplayName: 'string'
    tokenUserPrincipalName: 'string'
  }

Значения свойств

streamingjobs

Имя Описание Значение
name имя ресурса. строка (обязательно)

Ограничение символов: 3–63

Допустимые символы:
Буквенно-цифровые символы, дефисы и символы подчеркивания.
location Географическое расположение, в котором находится ресурс строка
tags Теги ресурсов. Словарь имен и значений тегов. См . раздел Теги в шаблонах
properties Свойства, связанные с заданием потоковой передачи. Требуется для запросов PUT (CreateOrReplace). StreamingJobProperties

StreamingJobProperties

Имя Описание Значение
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. '1.0'
dataLocale Языковой стандарт данных задания Stream Analytics. Значение должно быть именем поддерживаемого языка и региональных параметров .NET из набора https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110.aspx. Если значение не указано, по умолчанию используется "en-US". строка
eventsLateArrivalMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой могут быть добавлены события, поступающие с запозданием. Поддерживаемый диапазон — от –1 до 1814399 (20,23:59:59 дней). Значение –1 используется для указания неограниченного времени ожидания. Если свойство не указано, по умолчанию используется значение –1. INT
eventsOutOfOrderMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой события, поступающие не по порядку, могут быть упорядочены. INT
eventsOutOfOrderPolicy Указывает политику, применяемую к событиям, которые поступают в потоке входных событий не по порядку. 'Adjust'
"Drop"
functions Список одной или нескольких функций для задания потоковой передачи. Свойство name для каждой функции является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Функция[]
Ввод данных Список из одного или нескольких входных данных для задания потоковой передачи. Свойство name для каждого входного параметра является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных входных данных. Input[]
outputErrorPolicy Указывает политику, применяемую к событиям, которые поступают в выходные данные и не могут быть записаны во внешнее хранилище из-за неправильного формата (значения столбцов отсутствуют, имеют неправильный тип или размер). "Drop"
Stop
outputs Список из одного или нескольких выходных данных для задания потоковой передачи. Свойство name для каждого выходных данных является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных выходных данных. Выходные данные[]
outputStartMode Это свойство следует использовать только в том случае, если требуется, чтобы задание было запущено сразу после создания. Значение может иметь значение JobStartTime, CustomTime или LastOutputEventTime, чтобы указать, должна ли начальная точка потока выходных событий запускаться при каждом запуске задания, начинаться с пользовательской метки времени, указанной с помощью свойства outputStartTime, или с момента последнего времени вывода события. CustomTime
JobStartTime
LastOutputEventTime
outputStartTime Значением является либо метка времени в формате ISO-8601, указывающая начальную точку выходного потока событий, или значение NULL, указывающее, что выходной поток событий запускает при каждом запуске задания потоковой передачи. Это свойство должно иметь значение , если для параметра outputStartMode задано значение CustomTime. строка
sku Описывает номер SKU задания потоковой передачи. Требуется для запросов PUT (CreateOrReplace). SKU
преобразование Указывает запрос и количество единиц потоковой передачи, используемых для задания потоковой передачи. Свойство name преобразования является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Преобразование

Функция

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с функцией. Свойства функции

Свойства функции

Имя Описание Значение
тип Установка типа объекта Скалярный (обязательно)

ScalarFunctionProperties

Имя Описание Значение
тип Указывает тип функции. Scalar (обязательно)
properties Описывает конфигурацию скалярной функции. ScalarFunctionConfiguration

ScalarFunctionConfiguration

Имя Описание Значение
binding Физическая привязка функции. Например, в случае веб-службы Машинного обучения Azure это описывает конечную точку. Привязка функций
Ввод данных Список входных данных, описывающих параметры функции. FunctionInput[]
output Выходные данные функции. FunctionOutput

Привязка функций

Имя Описание Значение
тип Установка типа объекта Microsoft.MachineLearning/WebService
Microsoft.StreamAnalytics/JavascriptUdf (обязательно)

AzureMachineLearningWebServiceFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. Microsoft.MachineLearning/WebService (обязательно)
properties Свойства привязки, связанные с веб-службой Машинного обучения Azure. AzureMachineLearningWebServiceFunctionBindingPropert...

AzureMachineLearningWebServiceFunctionBindingPropert...

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в Request-Response конечной точке. строка
batchSize Число от 1 до 10 000, описывающее максимальное количество строк для каждого запроса RRS azure ML. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнить конечную точку веб-службы Машинного обучения Azure. Дополнительные сведения см. здесь: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputs
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceOutputColumn[]

AzureMachineLearningWebServiceInputs

Имя Описание Значение
columnNames Список входных столбцов для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputColumn[]
name Имя входа. Это имя, указанное при создании конечной точки. строка

AzureMachineLearningWebServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживается Машинным обучением Azure) входного столбца. Список допустимых типов данных Машинного обучения Azure описан по адресу https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляются входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningWebServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживается Машинным обучением Azure) выходного столбца. Список допустимых типов данных Машинного обучения Azure описан по адресу https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
name Имя выходного столбца. строка

JavaScriptFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. Microsoft.StreamAnalytics/JavascriptUdf (обязательно)
properties Свойства привязки, связанные с функцией JavaScript. JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

Имя Описание Значение
скрипт Код JavaScript, содержащий одно определение функции. Например: 'function (x, y) { return x + y; }' строка

FunctionInput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) входного параметра функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка
isConfigurationParameter Флаг, указывающий, является ли параметр параметром конфигурации. Значение true, если ожидается, что этот входной параметр является константой. Значение по умолчанию — false. bool

FunctionOutput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) выходных данных функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка

Входные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). Свойства InputProperties

Свойства InputProperties

Имя Описание Значение
сериализацию Описывает, как сериализуются данные из входных данных или как данные сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
тип Установка типа объекта Справочные материалы
Stream (обязательно)

Сериализация

Имя Описание Значение
тип Установка типа объекта Avro
Csv
Json (обязательно)

AvroSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). Avro (обязательно)
properties Свойства, связанные с типом сериализации Avro. Требуется для запросов PUT (CreateOrReplace). Для Bicep можно использовать функцию any().

CsvSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). "CSV" (обязательно)
properties Свойства, связанные с типом сериализации CSV. Требуется для запросов PUT (CreateOrReplace). CsvSerializationProperties

CsvSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае входных данных и кодировку исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace). 'UTF8'
fieldDelimiter Указывает разделитель, который будет использоваться для разделения записей с разделителями-запятыми (CSV). Список поддерживаемых значений см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . Требуется для запросов PUT (CreateOrReplace). строка

JsonSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). "Json" (обязательно)
properties Свойства, связанные с типом сериализации JSON. Требуется для запросов PUT (CreateOrReplace). JsonSerializationProperties

JsonSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае входных данных и кодировку исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace). 'UTF8'
format Это свойство применяется только к сериализации выходных данных JSON. Она неприменима к входным данным. Это свойство задает формат JSON, в который будут записаны выходные данные. В настоящее время поддерживаются значения lineSeparated, указывающие, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON. Значение по умолчанию — lineSeparated, если оставить значение NULL. "Массив"
LineSeparated

ReferenceInputProperties

Имя Описание Значение
тип Указывает, является ли вход источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). "Ссылка" (обязательно)
datasource Описывает источник входных данных, содержащий эталонные данные. Требуется для запросов PUT (CreateOrReplace). ReferenceInputDataSource

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Storage/BLOB-объект (обязательно)

BlobReferenceInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими эталонные данные. Требуется для запросов PUT (CreateOrReplace). BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, по которому имена BLOB-объектов будут сопоставляться, чтобы определить, следует ли их включать в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

StorageAccount

Имя Описание Значение
accountKey Ключ учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка

StreamInputProperties

Имя Описание Значение
тип Указывает, является ли вход источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). Stream (обязательно)
datasource Описывает источник входных данных, содержащий потоковые данные. Требуется для запросов PUT (CreateOrReplace). StreamInputDataSource

StreamInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Devices/IotHubs
Microsoft.ServiceBus/EventHub
Microsoft.Storage/BLOB-объект (обязательно)

IoTHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Devices/IotHubs (обязательно)
properties Свойства, связанные с Центр Интернета вещей входными данными, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя группы потребителей Центр Интернета вещей, которая должна использоваться для чтения событий из Центр Интернета вещей. Если не указано, входные данные используют группу потребителей Центра Интернета вещей по умолчанию. строка
endpoint Конечная точка Центр Интернета вещей для подключения (например, messages/events, messages/operationsMonitoringEvents и т. д.). строка
iotHubNamespace Имя или URI Центр Интернета вещей. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для Центр Интернета вещей. Эта политика должна содержать по крайней мере разрешение Service Connect. Требуется для запросов PUT (CreateOrReplace). строка

EventHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/EventHub (обязательно)
properties Свойства, связанные с входными данными концентратора событий, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). EventHubStreamInputDataSourceProperties

EventHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если значение не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

BlobStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит blob-объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, с которым будут сопоставляться имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
sourcePartitionCount Число секций источника входных данных BLOB-объекта. Диапазон от 1 до 1024. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

Выходные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с выходными данными. Требуется для запросов PUT (CreateOrReplace). Свойства OutputProperties

Свойства OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как данные сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация

OutputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.DataLake/Accounts
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI (обязательно)

AzureDataLakeStoreOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.DataLake/Accounts (обязательно)
properties Свойства, связанные с выходными данными Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

Имя Описание Значение
accountName Имя учетной записи Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в filePathPrefix, в качестве формата даты используется значение этого свойства. строка
filePathPrefix Расположение файла, в который должны быть записаны выходные данные. Требуется для запросов PUT (CreateOrReplace). строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Действительный маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить здесь фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
tenantId Идентификатор клиента пользователя, используемого для получения маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
TimeFormat Формат времени. Везде, где {time} отображается в filePathPrefix, значение этого свойства используется в качестве формата времени. строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN) пользователя, который использовался для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

EventHubOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/EventHub (обязательно)
properties Свойства, связанные с выходными данными концентратора событий. Требуется для запросов PUT (CreateOrReplace). EventHubOutputDataSourceProperties

EventHubOutputDataSourceProperties

Имя Описание Значение
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionKey Ключ или столбец, используемый для определения секции, в которую следует отправлять данные о событиях. строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusQueueOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/Queue (обязательно)
properties Свойства, связанные с выходными данными очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). Свойства ServiceBusQueueOutputDataSource

Свойства ServiceBusQueueOutputDataSource

Имя Описание Значение
propertyColumns Массив строк с именами выходных столбцов, которые будут присоединены к сообщениям служебной шины в виде настраиваемых свойств. string[]
queueName Имя очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/Topic (обязательно)
properties Свойства, связанные с выходными данными раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). Свойства ServiceBusTopicOutputDataSourceProperties

Свойства ServiceBusTopicOutputDataSourceProperties

Имя Описание Значение
propertyColumns Массив строк с именами выходных столбцов, которые будут присоединены к сообщениям служебной шины в виде настраиваемых свойств. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

AzureSqlDatabaseOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.Sql/Server/Database (обязательно)
properties Свойства, связанные с Azure SQL выходными данными базы данных. Требуется для запросов PUT (CreateOrReplace). AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL Server, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

BlobOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с выходными данными большого двоичного объекта. Требуется для запросов PUT (CreateOrReplace). BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, по которому имена BLOB-объектов будут сопоставляться, чтобы определить, следует ли их включать в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

DocumentDbOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/DocumentDB (обязательно)
properties Свойства, связанные с выходными данными DocumentDB. Требуется для запросов PUT (CreateOrReplace). DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

Имя Описание Значение
accountId Имя или идентификатор учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
accountKey Ключ учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
collectionNamePattern Шаблон имен для используемых коллекций. Формат имени коллекции можно составить с помощью необязательного маркера {partition}, где разделы начинаются с 0. Дополнительные сведения см. в разделе https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
documentId Имя поля в выходных событиях, используемое для указания основного ключа, на котором основаны операции вставки или обновления. строка
partitionKey Имя поля в выходных событиях, указывающее ключ для разделения выходных данных между коллекциями. Если collectionNamePattern содержит маркер {partition}, необходимо указать это свойство. строка

AzureTableOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/Table (обязательно)
properties Свойства, связанные с выходными данными таблицы Azure. Требуется для запросов PUT (CreateOrReplace). AzureTableOutputDataSourceProperties

AzureTableOutputDataSourceProperties

Имя Описание Значение
accountKey Ключ учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
batchSize Количество строк, записываемых в таблицу Azure за раз. INT
columnsToRemove Если указано, каждый элемент в массиве является именем столбца для удаления (при его наличии) из выходных данных сущностей событий. string[]
partitionKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа секции для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
rowKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа строки для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

PowerBIOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). PowerBI (обязательно)
properties Свойства, связанные с выходными данными Power BI. Требуется для запросов PUT (CreateOrReplace). Свойства PowerBIOutputDataSource

Свойства PowerBIOutputDataSource

Имя Описание Значение
набор данных Имя набора данных Power BI. Требуется для запросов PUT (CreateOrReplace). строка
groupId Идентификатор группы Power BI. строка
groupName Имя группы Power BI. Используйте это свойство, чтобы запомнить, какой идентификатор группы Power BI использовался. строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Действительный маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить здесь фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Power BI в указанном наборе данных. Требуется для запросов PUT (CreateOrReplace). строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN) пользователя, который использовался для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

Sku

Имя Описание Значение
name Имя номера SKU. Требуется для запросов PUT (CreateOrReplace). "Стандартный"

Преобразование

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с преобразованием. Требуется для запросов PUT (CreateOrReplace). Свойства преобразования

Свойства преобразования

Имя Описание Значение
query Указывает запрос, который будет выполняться в задании потоковой передачи. Дополнительные сведения о языке запросов Stream Analytics (SAQL) см. здесь: https://msdn.microsoft.com/library/azure/dn834998 . Требуется для запросов PUT (CreateOrReplace). строка
streamingUnits Число единиц потоковой передачи, используемых заданием потоковой передачи. INT

Шаблоны быстрого запуска

Следующие шаблоны быстрого запуска развертывают этот тип ресурса.

Шаблон Описание
Создание задания Stream Analytics уровня "Стандартный"

Развертывание в Azure		 Этот шаблон создает стандартное задание Stream Analytics. Дополнительные сведения см. в статье Azure Stream Analytics — это подсистема аналитики в режиме реального времени и сложная подсистема обработки событий, предназначенная для одновременного анализа и обработки больших объемов данных быстрой потоковой передачи из нескольких источников. Она обеспечивает определение закономерностей и связей в данных, извлеченных из нескольких источников, таких как устройства, датчики, данные посещений сайта, каналы социальных сетей и приложения. На основе этих закономерностей можно активировать действия и инициировать рабочие процессы, например создавать оповещения, отправлять данные в средства составления отчетов или сохранять преобразованные данные для дальнейшего использования. Кроме того, Stream Analytics доступна в среде выполнения Azure IoT Edge и поддерживает такие же язык или синтаксис, что и в облаке.

Определение ресурса шаблона ARM

Тип ресурса streamingjobs можно развернуть с помощью операций, предназначенных для:

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

Формат ресурсов

Чтобы создать ресурс Microsoft.StreamAnalytics/streamingjobs, добавьте следующий код JSON в шаблон.

{
  "type": "Microsoft.StreamAnalytics/streamingjobs",
  "apiVersion": "2016-03-01",
  "name": "string",
  "location": "string",
  "tags": {
    "tagName1": "tagValue1",
    "tagName2": "tagValue2"
  },
  "properties": {
    "compatibilityLevel": "1.0",
    "dataLocale": "string",
    "eventsLateArrivalMaxDelayInSeconds": "int",
    "eventsOutOfOrderMaxDelayInSeconds": "int",
    "eventsOutOfOrderPolicy": "string",
    "functions": [
      {
        "name": "string",
        "properties": {
          "type": "string"
          // For remaining properties, see FunctionProperties objects
        }
      }
    ],
    "inputs": [
      {
        "name": "string",
        "properties": {
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          },
          "type": "string"
          // For remaining properties, see InputProperties objects
        }
      }
    ],
    "outputErrorPolicy": "string",
    "outputs": [
      {
        "name": "string",
        "properties": {
          "datasource": {
            "type": "string"
            // For remaining properties, see OutputDataSource objects
          },
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          }
        }
      }
    ],
    "outputStartMode": "string",
    "outputStartTime": "string",
    "sku": {
      "name": "Standard"
    },
    "transformation": {
      "name": "string",
      "properties": {
        "query": "string",
        "streamingUnits": "int"
      }
    }
  }
}

Объекты FunctionProperties

Задайте свойство type , чтобы указать тип объекта .

Для скалярных используйте:

  "type": "Scalar",
  "properties": {
    "binding": {
      "type": "string"
      // For remaining properties, see FunctionBinding objects
    },
    "inputs": [
      {
        "dataType": "string",
        "isConfigurationParameter": "bool"
      }
    ],
    "output": {
      "dataType": "string"
    }
  }

Объекты FunctionBinding

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.MachineLearning/WebService используйте:

  "type": "Microsoft.MachineLearning/WebService",
  "properties": {
    "apiKey": "string",
    "batchSize": "int",
    "endpoint": "string",
    "inputs": {
      "columnNames": [
        {
          "dataType": "string",
          "mapTo": "int",
          "name": "string"
        }
      ],
      "name": "string"
    },
    "outputs": [
      {
        "dataType": "string",
        "name": "string"
      }
    ]
  }

Для Microsoft.StreamAnalytics/JavascriptUdf используйте:

  "type": "Microsoft.StreamAnalytics/JavascriptUdf",
  "properties": {
    "script": "string"
  }

Объекты InputProperties

Задайте свойство type , чтобы указать тип объекта .

Для справки используйте:

  "type": "Reference",
  "datasource": {
    "type": "string"
    // For remaining properties, see ReferenceInputDataSource objects
  }

Для Stream используйте:

  "type": "Stream",
  "datasource": {
    "type": "string"
    // For remaining properties, see StreamInputDataSource objects
  }

Объекты сериализации

Задайте свойство type , чтобы указать тип объекта .

Для Avro используйте:

  "type": "Avro",
  "properties": {}

Для CSV используйте:

  "type": "Csv",
  "properties": {
    "encoding": "UTF8",
    "fieldDelimiter": "string"
  }

Для Json используйте:

  "type": "Json",
  "properties": {
    "encoding": "UTF8",
    "format": "string"
  }

Объекты ReferenceInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Storage/Blob используйте:

  "type": "Microsoft.Storage/Blob",
  "properties": {
    "container": "string",
    "dateFormat": "string",
    "pathPattern": "string",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string"
      }
    ],
    "timeFormat": "string"
  }

Объекты StreamInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Devices/IotHubs используйте:

  "type": "Microsoft.Devices/IotHubs",
  "properties": {
    "consumerGroupName": "string",
    "endpoint": "string",
    "iotHubNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

Для Microsoft.ServiceBus/EventHub используйте:

  "type": "Microsoft.ServiceBus/EventHub",
  "properties": {
    "consumerGroupName": "string",
    "eventHubName": "string",
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

Для Microsoft.Storage/Blob используйте:

  "type": "Microsoft.Storage/Blob",
  "properties": {
    "container": "string",
    "dateFormat": "string",
    "pathPattern": "string",
    "sourcePartitionCount": "int",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string"
      }
    ],
    "timeFormat": "string"
  }

Объекты OutputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.DataLake/Accounts используйте:

  "type": "Microsoft.DataLake/Accounts",
  "properties": {
    "accountName": "string",
    "dateFormat": "string",
    "filePathPrefix": "string",
    "refreshToken": "string",
    "tenantId": "string",
    "timeFormat": "string",
    "tokenUserDisplayName": "string",
    "tokenUserPrincipalName": "string"
  }

Для Microsoft.ServiceBus/EventHub используйте:

  "type": "Microsoft.ServiceBus/EventHub",
  "properties": {
    "eventHubName": "string",
    "partitionKey": "string",
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

Для Microsoft.ServiceBus/Queue используйте:

  "type": "Microsoft.ServiceBus/Queue",
  "properties": {
    "propertyColumns": [ "string" ],
    "queueName": "string",
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

Для Microsoft.ServiceBus/Topic используйте:

  "type": "Microsoft.ServiceBus/Topic",
  "properties": {
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string",
    "topicName": "string"
  }

Для Microsoft.Sql/Server/Database используйте:

  "type": "Microsoft.Sql/Server/Database",
  "properties": {
    "database": "string",
    "password": "string",
    "server": "string",
    "table": "string",
    "user": "string"
  }

Для Microsoft.Storage/Blob используйте:

  "type": "Microsoft.Storage/Blob",
  "properties": {
    "container": "string",
    "dateFormat": "string",
    "pathPattern": "string",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string"
      }
    ],
    "timeFormat": "string"
  }

Для Microsoft.Storage/DocumentDB используйте:

  "type": "Microsoft.Storage/DocumentDB",
  "properties": {
    "accountId": "string",
    "accountKey": "string",
    "collectionNamePattern": "string",
    "database": "string",
    "documentId": "string",
    "partitionKey": "string"
  }

Для Microsoft.Storage/Table используйте:

  "type": "Microsoft.Storage/Table",
  "properties": {
    "accountKey": "string",
    "accountName": "string",
    "batchSize": "int",
    "columnsToRemove": [ "string" ],
    "partitionKey": "string",
    "rowKey": "string",
    "table": "string"
  }

Для PowerBI используйте:

  "type": "PowerBI",
  "properties": {
    "dataset": "string",
    "groupId": "string",
    "groupName": "string",
    "refreshToken": "string",
    "table": "string",
    "tokenUserDisplayName": "string",
    "tokenUserPrincipalName": "string"
  }

Значения свойств

streamingjobs

Имя Описание Значение
тип Тип ресурса Microsoft.StreamAnalytics/streamingjobs
версия_API Версия API ресурсов '2016-03-01'
name имя ресурса. строка (обязательно)

Ограничение символов: 3–63

Допустимые символы:
Буквенно-цифровые символы, дефисы и символы подчеркивания.
location Географическое расположение, в котором находится ресурс строка
tags Теги ресурсов. Словарь имен и значений тегов. См . раздел Теги в шаблонах
properties Свойства, связанные с заданием потоковой передачи. Требуется для запросов PUT (CreateOrReplace). StreamingJobProperties

StreamingJobProperties

Имя Описание Значение
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. '1.0'
dataLocale Языковой стандарт данных задания Stream Analytics. Значение должно быть именем поддерживаемого языка и региональных параметров .NET из набора https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110.aspx. Если значение не указано, по умолчанию используется "en-US". строка
eventsLateArrivalMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой могут быть добавлены события, поступающие с запозданием. Поддерживаемый диапазон — от –1 до 1814399 (20,23:59:59 дней). Значение –1 используется для указания неограниченного времени ожидания. Если свойство не указано, по умолчанию используется значение –1. INT
eventsOutOfOrderMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой события, поступающие не по порядку, могут быть упорядочены. INT
eventsOutOfOrderPolicy Указывает политику, применяемую к событиям, которые поступают в потоке входных событий не по порядку. 'Adjust'
'Drop'
functions Список одной или нескольких функций для задания потоковой передачи. Свойство name для каждой функции является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Функция[]
Ввод данных Список из одного или нескольких входных данных для задания потоковой передачи. Свойство name для каждого входного значения является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных входных данных. Входные данные[]
outputErrorPolicy Указывает политику, применяемую к событиям, которые поступают в выходные данные и не могут быть записаны во внешнее хранилище из-за неправильного формата (значения столбцов отсутствуют, имеют неправильный тип или размер). 'Drop'
'Stop'
outputs Список из одного или нескольких выходных данных для задания потоковой передачи. Свойство name для каждого выходных данных является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных выходных данных. Выходные данные[]
outputStartMode Это свойство следует использовать только в том случае, если требуется, чтобы задание запускалось сразу после создания. Значение может иметь значение JobStartTime, CustomTime или LastOutputEventTime, чтобы указать, должна ли начальная точка потока выходных событий начинаться при запуске задания, начинаться с пользовательской метки времени, указанной в свойстве outputStartTime, или с момента последнего времени вывода события. CustomTime
'JobStartTime'
LastOutputEventTime
outputStartTime Значением является либо метка времени в формате ISO-8601, указывающая начальную точку выходного потока событий, или значение NULL, указывающее, что выходной поток событий запускает при каждом запуске задания потоковой передачи. Это свойство должно иметь значение , если параметр outputStartMode имеет значение CustomTime. строка
sku Описывает номер SKU задания потоковой передачи. Требуется для запросов PUT (CreateOrReplace). SKU
преобразование Указывает запрос и количество единиц потоковой передачи, используемых для задания потоковой передачи. Свойство name преобразования является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Преобразование

Функция

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с функцией. Свойства функции

Свойства функции

Имя Описание Значение
тип Установка типа объекта Скалярный (обязательный)

ScalarFunctionProperties

Имя Описание Значение
тип Указывает тип функции. Скалярный (обязательный)
properties Описывает конфигурацию скалярной функции. ScalarFunctionConfiguration

ScalarFunctionConfiguration

Имя Описание Значение
binding Физическая привязка функции. Например, в случае веб-службы Машинного обучения Azure это описывает конечную точку. FunctionBinding
Ввод данных Список входных данных, описывающих параметры функции. FunctionInput[]
output Выходные данные функции. FunctionOutput

FunctionBinding

Имя Описание Значение
тип Установка типа объекта Microsoft.MachineLearning/WebService
Microsoft.StreamAnalytics/JavascriptUdf (обязательно)

AzureMachineLearningWebServiceFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. Microsoft.MachineLearning/WebService (обязательно)
properties Свойства привязки, связанные с веб-службой Машинного обучения Azure. AzureMachineLearningWebServiceFunctionBindingPropert...

AzureMachineLearningWebServiceFunctionBindingPropert...

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в конечной точке Request-Response. строка
batchSize Число от 1 до 10 000, описывающее максимальное число строк для каждого запроса выполнения Azure ML RRS. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнять конечную точку веб-службы Машинного обучения Azure. Дополнительные сведения см. здесь: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputs
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceOutputColumn[]

AzureMachineLearningWebServiceInputs

Имя Описание Значение
columnNames Список входных столбцов для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputColumn[]
name Имя входа. Это имя, указанное при создании конечной точки. строка

AzureMachineLearningWebServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) входного столбца. Список допустимых типов данных Машинного обучения Azure описан в разделе https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningWebServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) выходного столбца. Список допустимых типов данных Машинного обучения Azure описан в разделе https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
name Имя выходного столбца. строка

JavaScriptFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. Microsoft.StreamAnalytics/JavascriptUdf (обязательно)
properties Свойства привязки, связанные с функцией JavaScript. JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

Имя Описание Значение
скрипт Код JavaScript, содержащий одно определение функции. Например: 'function (x, y) { return x + y; }' строка

FunctionInput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) входного параметра функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка
isConfigurationParameter Флаг, указывающий, является ли параметр параметром конфигурации. Значение true, если ожидается, что этот входной параметр является константой. Значение по умолчанию — false. bool

FunctionOutput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) выходных данных функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка

Входные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). InputProperties

InputProperties

Имя Описание Значение
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
тип Установка типа объекта Справочные материалы
Stream (обязательно)

Сериализация

Имя Описание Значение
тип Установка типа объекта Avro
Csv
Json (обязательно)

AvroSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). Avro (обязательно)
properties Свойства, связанные с типом сериализации Avro. Требуется для запросов PUT (CreateOrReplace).

CsvSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). Csv (обязательно)
properties Свойства, связанные с типом сериализации CSV. Требуется для запросов PUT (CreateOrReplace). CsvSerializationProperties

CsvSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае ввода и кодировку исходящих данных в случае вывода. Требуется для запросов PUT (CreateOrReplace). UTF8
fieldDelimiter Указывает разделитель, который будет использоваться для разделения записей с разделителями-запятыми (CSV). Список поддерживаемых значений см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . Требуется для запросов PUT (CreateOrReplace). строка

JsonSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). Json (обязательно)
properties Свойства, связанные с типом сериализации JSON. Требуется для запросов PUT (CreateOrReplace). JsonSerializationProperties

JsonSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае входных данных и кодировку исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace). 'UTF8'
format Это свойство применяется только к сериализации выходных данных JSON. Она неприменима к входным данным. Это свойство задает формат JSON, в который будут записаны выходные данные. В настоящее время поддерживаются значения lineSeparated, указывающие, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON. Значение по умолчанию — lineSeparated, если оставить значение NULL. "Массив"
LineSeparated

ReferenceInputProperties

Имя Описание Значение
тип Указывает, является ли вход источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). "Ссылка" (обязательно)
datasource Описывает источник входных данных, содержащий эталонные данные. Требуется для запросов PUT (CreateOrReplace). ReferenceInputDataSource

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Storage/BLOB-объект (обязательно)

BlobReferenceInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими эталонные данные. Требуется для запросов PUT (CreateOrReplace). BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, по которому имена BLOB-объектов будут сопоставляться, чтобы определить, следует ли их включать в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

StorageAccount

Имя Описание Значение
accountKey Ключ учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка

StreamInputProperties

Имя Описание Значение
тип Указывает, является ли вход источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). Stream (обязательно)
datasource Описывает источник входных данных, содержащий потоковые данные. Требуется для запросов PUT (CreateOrReplace). StreamInputDataSource

StreamInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Devices/IotHubs
Microsoft.ServiceBus/EventHub
Microsoft.Storage/BLOB-объект (обязательно)

IoTHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Devices/IotHubs (обязательно)
properties Свойства, связанные с Центр Интернета вещей входными данными, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя группы потребителей Центр Интернета вещей, которая должна использоваться для чтения событий из Центр Интернета вещей. Если не указано, входные данные используют группу потребителей Центра Интернета вещей по умолчанию. строка
endpoint Конечная точка Центр Интернета вещей для подключения (например, messages/events, messages/operationsMonitoringEvents и т. д.). строка
iotHubNamespace Имя или URI Центр Интернета вещей. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для Центр Интернета вещей. Эта политика должна содержать по крайней мере разрешение на подключение к службе. Требуется для запросов PUT (CreateOrReplace). строка

EventHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/EventHub (обязательно)
properties Свойства, связанные с входными данными концентратора событий, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). EventHubStreamInputDataSourceProperties

EventHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

BlobStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, с которым будут сопоставляться имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
sourcePartitionCount Число секций источника входных данных BLOB-объекта. Диапазон от 1 до 1024. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

Выходные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с выходными данными. Требуется для запросов PUT (CreateOrReplace). OutputProperties

OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация

OutputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.DataLake/Accounts
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI (обязательно)

AzureDataLakeStoreOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.DataLake/Accounts (обязательно)
properties Свойства, связанные с выходными данными Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

Имя Описание Значение
accountName Имя учетной записи Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в filePathPrefix, значение этого свойства используется в качестве формата даты. строка
filePathPrefix Расположение файла, в который должны быть записаны выходные данные. Требуется для запросов PUT (CreateOrReplace). строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Допустимый маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
tenantId Идентификатор клиента пользователя, используемого для получения маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
TimeFormat Формат времени. Везде, где {time} отображается в filePathPrefix, значение этого свойства используется в качестве формата времени. строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN), которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

EventHubOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/EventHub (обязательно)
properties Свойства, связанные с выходными данными концентратора событий. Требуется для запросов PUT (CreateOrReplace). EventHubOutputDataSourceProperties

EventHubOutputDataSourceProperties

Имя Описание Значение
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionKey Ключ или столбец, который используется для определения секции, в которую следует отправлять данные о событиях. строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusQueueOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/Queue (обязательно)
properties Свойства, связанные с выходными данными очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). ServiceBusQueueOutputDataSourceProperties

ServiceBusQueueOutputDataSourceProperties

Имя Описание Значение
propertyColumns Строковый массив имен выходных столбцов, которые будут присоединены к сообщениям служебной шины в качестве пользовательских свойств. string[]
queueName Имя очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/Topic (обязательно)
properties Свойства, связанные с выходными данными раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). ServiceBusTopicOutputDataSourceProperties

ServiceBusTopicOutputDataSourceProperties

Имя Описание Значение
propertyColumns Строковый массив имен выходных столбцов, которые будут присоединены к сообщениям служебной шины в качестве пользовательских свойств. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

AzureSqlDatabaseOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Sql/Server/Database (обязательно)
properties Свойства, связанные с выходными данными Azure SQL базы данных. Требуется для запросов PUT (CreateOrReplace). AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

BlobOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с выходными данными большого двоичного объекта. Требуется для запросов PUT (CreateOrReplace). BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит blob-объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, с которым будут сопоставляться имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

DocumentDbOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/DocumentDB (обязательно)
properties Свойства, связанные с выходными данными DocumentDB. Требуется для запросов PUT (CreateOrReplace). DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

Имя Описание Значение
accountId Имя или идентификатор учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
accountKey Ключ учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
collectionNamePattern Шаблон имен для используемых коллекций. Формат имени коллекции можно составить с помощью необязательного маркера {partition}, где разделы начинаются с 0. Дополнительные сведения см. в разделе https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
documentId Имя поля в выходных событиях, используемое для указания основного ключа, на котором основаны операции вставки или обновления. строка
partitionKey Имя поля в выходных событиях, указывающее ключ для разделения выходных данных между коллекциями. Если collectionNamePattern содержит маркер {partition}, необходимо указать это свойство. строка

AzureTableOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/Table (обязательно)
properties Свойства, связанные с выходными данными таблицы Azure. Требуется для запросов PUT (CreateOrReplace). AzureTableOutputDataSourceProperties

AzureTableOutputDataSourceProperties

Имя Описание Значение
accountKey Ключ учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
batchSize Количество строк, записываемых в таблицу Azure за раз. INT
columnsToRemove Если указано, каждый элемент в массиве является именем столбца для удаления (при его наличии) из выходных данных сущностей событий. string[]
partitionKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа секции для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
rowKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа строки для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

PowerBIOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). PowerBI (обязательно)
properties Свойства, связанные с выходными данными Power BI. Требуется для запросов PUT (CreateOrReplace). Свойства PowerBIOutputDataSource

Свойства PowerBIOutputDataSource

Имя Описание Значение
набор данных Имя набора данных Power BI. Требуется для запросов PUT (CreateOrReplace). строка
groupId Идентификатор группы Power BI. строка
groupName Имя группы Power BI. Используйте это свойство, чтобы запомнить, какой идентификатор группы Power BI использовался. строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Действительный маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить здесь фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Power BI в указанном наборе данных. Требуется для запросов PUT (CreateOrReplace). строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN) пользователя, который использовался для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

Sku

Имя Описание Значение
name Имя номера SKU. Требуется для запросов PUT (CreateOrReplace). "Стандартный"

Преобразование

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с преобразованием. Требуется для запросов PUT (CreateOrReplace). TransformationProperties

TransformationProperties

Имя Описание Значение
query Указывает запрос, который будет выполняться в задании потоковой передачи. Дополнительные сведения о языке запросов Stream Analytics (SAQL) см. здесь: https://msdn.microsoft.com/library/azure/dn834998 . Требуется для запросов PUT (CreateOrReplace). строка
StreamingUnits Число единиц потоковой передачи, используемых заданием потоковой передачи. INT

Шаблоны быстрого запуска

Следующие шаблоны быстрого запуска развертывают этот тип ресурса.

Шаблон Описание
Создание стандартного задания Stream Analytics

Развертывание в Azure		 Этот шаблон создает стандартное задание Stream Analytics. Дополнительные сведения см. в статье Azure Stream Analytics — это подсистема аналитики в режиме реального времени и сложная подсистема обработки событий, предназначенная для одновременного анализа и обработки больших объемов данных быстрой потоковой передачи из нескольких источников. Она обеспечивает определение закономерностей и связей в данных, извлеченных из нескольких источников, таких как устройства, датчики, данные посещений сайта, каналы социальных сетей и приложения. На основе этих закономерностей можно активировать действия и инициировать рабочие процессы, например создавать оповещения, отправлять данные в средства составления отчетов или сохранять преобразованные данные для дальнейшего использования. Кроме того, Stream Analytics доступна в среде выполнения Azure IoT Edge и поддерживает такие же язык или синтаксис, что и в облаке.

Определение ресурса Terraform (поставщик AzAPI)

Тип ресурса streamingjobs можно развернуть с помощью операций, предназначенных для:

  • Группы ресурсов

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

Формат ресурсов

Чтобы создать ресурс Microsoft.StreamAnalytics/streamingjobs, добавьте следующую terraform в шаблон.

resource "azapi_resource" "symbolicname" {
  type = "Microsoft.StreamAnalytics/streamingjobs@2016-03-01"
  name = "string"
  location = "string"
  parent_id = "string"
  tags = {
    tagName1 = "tagValue1"
    tagName2 = "tagValue2"
  }
  body = jsonencode({
    properties = {
      compatibilityLevel = "1.0"
      dataLocale = "string"
      eventsLateArrivalMaxDelayInSeconds = int
      eventsOutOfOrderMaxDelayInSeconds = int
      eventsOutOfOrderPolicy = "string"
      functions = [
        {
          name = "string"
          properties = {
            type = "string"
            // For remaining properties, see FunctionProperties objects
          }
        }
      ]
      inputs = [
        {
          name = "string"
          properties = {
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
            type = "string"
            // For remaining properties, see InputProperties objects
          }
        }
      ]
      outputErrorPolicy = "string"
      outputs = [
        {
          name = "string"
          properties = {
            datasource = {
              type = "string"
              // For remaining properties, see OutputDataSource objects
            }
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
          }
        }
      ]
      outputStartMode = "string"
      outputStartTime = "string"
      sku = {
        name = "Standard"
      }
      transformation = {
        name = "string"
        properties = {
          query = "string"
          streamingUnits = int
        }
      }
    }
  })
}

Объекты FunctionProperties

Задайте свойство type , чтобы указать тип объекта .

Для скалярных используйте:

  type = "Scalar"
  properties = {
    binding = {
      type = "string"
      // For remaining properties, see FunctionBinding objects
    }
    inputs = [
      {
        dataType = "string"
        isConfigurationParameter = bool
      }
    ]
    output = {
      dataType = "string"
    }
  }

Объекты FunctionBinding

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.MachineLearning/WebService используйте:

  type = "Microsoft.MachineLearning/WebService"
  properties = {
    apiKey = "string"
    batchSize = int
    endpoint = "string"
    inputs = {
      columnNames = [
        {
          dataType = "string"
          mapTo = int
          name = "string"
        }
      ]
      name = "string"
    }
    outputs = [
      {
        dataType = "string"
        name = "string"
      }
    ]
  }

Для Microsoft.StreamAnalytics/JavascriptUdf используйте:

  type = "Microsoft.StreamAnalytics/JavascriptUdf"
  properties = {
    script = "string"
  }

Объекты InputProperties

Задайте свойство type , чтобы указать тип объекта .

Для справки используйте:

  type = "Reference"
  datasource = {
    type = "string"
    // For remaining properties, see ReferenceInputDataSource objects
  }

Для Stream используйте:

  type = "Stream"
  datasource = {
    type = "string"
    // For remaining properties, see StreamInputDataSource objects
  }

Объекты сериализации

Задайте свойство type , чтобы указать тип объекта .

Для Avro используйте:

  type = "Avro"

Для CSV используйте:

  type = "Csv"
  properties = {
    encoding = "UTF8"
    fieldDelimiter = "string"
  }

Для Json используйте:

  type = "Json"
  properties = {
    encoding = "UTF8"
    format = "string"
  }

Объекты ReferenceInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Storage/BLOB-объектов используйте:

  type = "Microsoft.Storage/Blob"
  properties = {
    container = "string"
    dateFormat = "string"
    pathPattern = "string"
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
      }
    ]
    timeFormat = "string"
  }

Объекты StreamInputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.Devices/IotHubs используйте:

  type = "Microsoft.Devices/IotHubs"
  properties = {
    consumerGroupName = "string"
    endpoint = "string"
    iotHubNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

Для Microsoft.ServiceBus/EventHub используйте:

  type = "Microsoft.ServiceBus/EventHub"
  properties = {
    consumerGroupName = "string"
    eventHubName = "string"
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

Для Microsoft.Storage/BLOB-объектов используйте:

  type = "Microsoft.Storage/Blob"
  properties = {
    container = "string"
    dateFormat = "string"
    pathPattern = "string"
    sourcePartitionCount = int
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
      }
    ]
    timeFormat = "string"
  }

Объекты OutputDataSource

Задайте свойство type , чтобы указать тип объекта .

Для Microsoft.DataLake/Accounts используйте:

  type = "Microsoft.DataLake/Accounts"
  properties = {
    accountName = "string"
    dateFormat = "string"
    filePathPrefix = "string"
    refreshToken = "string"
    tenantId = "string"
    timeFormat = "string"
    tokenUserDisplayName = "string"
    tokenUserPrincipalName = "string"
  }

Для Microsoft.ServiceBus/EventHub используйте:

  type = "Microsoft.ServiceBus/EventHub"
  properties = {
    eventHubName = "string"
    partitionKey = "string"
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

Для Microsoft.ServiceBus/Queue используйте:

  type = "Microsoft.ServiceBus/Queue"
  properties = {
    propertyColumns = [
      "string"
    ]
    queueName = "string"
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

Для Microsoft.ServiceBus/Topic используйте:

  type = "Microsoft.ServiceBus/Topic"
  properties = {
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
    topicName = "string"
  }

Для Microsoft.Sql/Server/Database используйте:

  type = "Microsoft.Sql/Server/Database"
  properties = {
    database = "string"
    password = "string"
    server = "string"
    table = "string"
    user = "string"
  }

Для Microsoft.Storage/BLOB-объектов используйте:

  type = "Microsoft.Storage/Blob"
  properties = {
    container = "string"
    dateFormat = "string"
    pathPattern = "string"
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
      }
    ]
    timeFormat = "string"
  }

Для Microsoft.Storage/DocumentDB используйте:

  type = "Microsoft.Storage/DocumentDB"
  properties = {
    accountId = "string"
    accountKey = "string"
    collectionNamePattern = "string"
    database = "string"
    documentId = "string"
    partitionKey = "string"
  }

Для Microsoft.Storage/Table используйте:

  type = "Microsoft.Storage/Table"
  properties = {
    accountKey = "string"
    accountName = "string"
    batchSize = int
    columnsToRemove = [
      "string"
    ]
    partitionKey = "string"
    rowKey = "string"
    table = "string"
  }

Для PowerBI используйте:

  type = "PowerBI"
  properties = {
    dataset = "string"
    groupId = "string"
    groupName = "string"
    refreshToken = "string"
    table = "string"
    tokenUserDisplayName = "string"
    tokenUserPrincipalName = "string"
  }

Значения свойств

streamingjobs

Имя Описание Значение
тип Тип ресурса "Microsoft.StreamAnalytics/streamingjobs@2016-03-01"
name имя ресурса. string (обязательно)

Ограничение символов: 3-63

Допустимые символы:
Буквенно-цифровые символы, дефисы и символы подчеркивания.
location Географическое расположение, в котором находится ресурс строка
parent_id Для развертывания в группе ресурсов используйте идентификатор этой группы ресурсов. string (обязательно)
tags Теги ресурсов. Словарь имен и значений тегов.
properties Свойства, связанные с заданием потоковой передачи. Требуется для запросов PUT (CreateOrReplace). StreamingJobProperties

StreamingJobProperties

Имя Описание Значение
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. "1.0"
dataLocale Языковой стандарт данных задания Stream Analytics. Значение должно быть именем поддерживаемого языка и региональных параметров .NET из набора https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110.aspx. Если значение не указано, по умолчанию используется "en-US". строка
eventsLateArrivalMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой могут быть добавлены события, поступающие с запозданием. Поддерживаемый диапазон — от –1 до 1814399 (20,23:59:59 дней). Значение –1 используется для указания неограниченного времени ожидания. Если свойство не указано, по умолчанию используется значение –1. INT
eventsOutOfOrderMaxDelayInSeconds Максимальная приемлемая задержка в секундах, в течение которой события, поступающие не по порядку, могут быть упорядочены. INT
eventsOutOfOrderPolicy Указывает политику, применяемую к событиям, которые поступают в потоке входных событий не по порядку. "Настроить"
"Drop"
functions Список одной или нескольких функций для задания потоковой передачи. Свойство name для каждой функции является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Функция[]
Ввод данных Список из одного или нескольких входных данных для задания потоковой передачи. Свойство name для каждого входного значения является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных входных данных. Входные данные[]
outputErrorPolicy Указывает политику, применяемую к событиям, которые поступают в выходные данные и не могут быть записаны во внешнее хранилище из-за неправильного формата (значения столбцов отсутствуют, имеют неправильный тип или размер). "Drop"
"Stop"
outputs Список из одного или нескольких выходных данных для задания потоковой передачи. Свойство name для каждого выходных данных является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельных выходных данных. Выходные данные[]
outputStartMode Это свойство следует использовать только в том случае, если требуется, чтобы задание запускалось сразу после создания. Значение может иметь значение JobStartTime, CustomTime или LastOutputEventTime, чтобы указать, должна ли начальная точка потока выходных событий начинаться при запуске задания, начинаться с пользовательской метки времени, указанной в свойстве outputStartTime, или с момента последнего времени вывода события. "CustomTime"
"JobStartTime"
LastOutputEventTime
outputStartTime Значением является либо метка времени в формате ISO-8601, указывающая начальную точку выходного потока событий, или значение NULL, указывающее, что выходной поток событий запускает при каждом запуске задания потоковой передачи. Это свойство должно иметь значение , если параметр outputStartMode имеет значение CustomTime. строка
sku Описывает номер SKU задания потоковой передачи. Требуется для запросов PUT (CreateOrReplace). SKU
преобразование Указывает запрос и количество единиц потоковой передачи, используемых для задания потоковой передачи. Свойство name преобразования является обязательным при указании этого свойства в запросе PUT. Это свойство нельзя изменить с помощью операции PATCH. Необходимо использовать API PATCH, доступный для отдельного преобразования. Преобразование

Функция

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с функцией. Свойства функции

Свойства функции

Имя Описание Значение
тип Установка типа объекта Скалярный (обязательный)

ScalarFunctionProperties

Имя Описание Значение
тип Указывает тип функции. Скалярный (обязательный)
properties Описывает конфигурацию скалярной функции. ScalarFunctionConfiguration

ScalarFunctionConfiguration

Имя Описание Значение
binding Физическая привязка функции. Например, в случае веб-службы Машинного обучения Azure это описывает конечную точку. FunctionBinding
Ввод данных Список входных данных, описывающих параметры функции. FunctionInput[]
output Выходные данные функции. FunctionOutput

FunctionBinding

Имя Описание Значение
тип Установка типа объекта Microsoft.MachineLearning/WebService
Microsoft.StreamAnalytics/JavascriptUdf (обязательно)

AzureMachineLearningWebServiceFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. "Microsoft.MachineLearning/WebService" (обязательно)
properties Свойства привязки, связанные с веб-службой Машинного обучения Azure. AzureMachineLearningWebServiceFunctionBindingPropert...

AzureMachineLearningWebServiceFunctionBindingPropert...

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в конечной точке Request-Response. строка
batchSize Число от 1 до 10 000, описывающее максимальное число строк для каждого запроса выполнения Azure ML RRS. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнять конечную точку веб-службы Машинного обучения Azure. Дополнительные сведения см. здесь: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputs
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceOutputColumn[]

AzureMachineLearningWebServiceInputs

Имя Описание Значение
columnNames Список входных столбцов для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningWebServiceInputColumn[]
name Имя входа. Это имя, указанное при создании конечной точки. строка

AzureMachineLearningWebServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) входного столбца. Список допустимых типов данных Машинного обучения Azure описан в разделе https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningWebServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) выходного столбца. Список допустимых типов данных Машинного обучения Azure описан в разделе https://msdn.microsoft.com/library/azure/dn905923.aspx . строка
name Имя выходного столбца. строка

JavaScriptFunctionBinding

Имя Описание Значение
тип Указывает тип привязки функции. "Microsoft.StreamAnalytics/JavascriptUdf" (обязательно)
properties Свойства привязки, связанные с функцией JavaScript. JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

Имя Описание Значение
скрипт Код JavaScript, содержащий одно определение функции. Например: 'function (x, y) { return x + y; }' строка

FunctionInput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) входного параметра функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка
isConfigurationParameter Флаг, указывающий, является ли параметр параметром конфигурации. Значение true, если ожидается, что этот входной параметр является константой. Значение по умолчанию — false. bool

FunctionOutput

Имя Описание Значение
dataType Тип данных (поддерживается Azure Stream Analytics) выходных данных функции. Список допустимых типов данных Azure Stream Analytics описан в статье https://msdn.microsoft.com/library/azure/dn835065.aspx строка

Входные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). InputProperties

InputProperties

Имя Описание Значение
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
тип Установка типа объекта Справочные материалы
Stream (обязательно)

Сериализация

Имя Описание Значение
тип Установка типа объекта Avro
Csv
Json (обязательно)

AvroSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). "Avro" (обязательно)
properties Свойства, связанные с типом сериализации Avro. Требуется для запросов PUT (CreateOrReplace).

CsvSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). "CSV" (обязательно)
properties Свойства, связанные с типом сериализации CSV. Требуется для запросов PUT (CreateOrReplace). CsvSerializationProperties

CsvSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае ввода и кодировку исходящих данных в случае вывода. Требуется для запросов PUT (CreateOrReplace). "UTF8"
fieldDelimiter Указывает разделитель, который будет использоваться для разделения записей с разделителями-запятыми (CSV). Список поддерживаемых значений см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . Требуется для запросов PUT (CreateOrReplace). строка

JsonSerialization

Имя Описание Значение
тип Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace). "Json" (обязательно)
properties Свойства, связанные с типом сериализации JSON. Требуется для запросов PUT (CreateOrReplace). JsonSerializationProperties

JsonSerializationProperties

Имя Описание Значение
encoding Задает кодировку входящих данных в случае входных данных и кодировку исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace). "UTF8"
format Это свойство применяется только к сериализации выходных данных JSON. Она неприменима к входным данным. Это свойство задает формат JSON, в который будут записаны выходные данные. В настоящее время поддерживаются значения lineSeparated, указывающие, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON. Значение по умолчанию — lineSeparated, если оставить значение NULL. "Массив"
"LineSeparated"

ReferenceInputProperties

Имя Описание Значение
тип Указывает, является ли вход источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). "Ссылка" (обязательно)
datasource Описывает источник входных данных, содержащий эталонные данные. Требуется для запросов PUT (CreateOrReplace). ReferenceInputDataSource

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Storage/BLOB-объект (обязательно)

BlobReferenceInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace). "Microsoft.Storage/BLOB- объект" (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими эталонные данные. Требуется для запросов PUT (CreateOrReplace). BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, по которому имена BLOB-объектов будут сопоставляться, чтобы определить, следует ли их включать в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

StorageAccount

Имя Описание Значение
accountKey Ключ учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка

StreamInputProperties

Имя Описание Значение
тип Указывает, являются ли входные данные источником ссылочных данных или потоковых данных. Требуется для запросов PUT (CreateOrReplace). "Stream" (обязательно)
datasource Описывает источник входных данных, содержащий потоковые данные. Требуется для запросов PUT (CreateOrReplace). StreamInputDataSource

StreamInputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.Devices/IotHubs
Microsoft.ServiceBus/EventHub
Microsoft.Storage/BLOB-объект (обязательно)

IoTHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). "Microsoft.Devices/IotHubs" (обязательно)
properties Свойства, связанные с Центр Интернета вещей входными данными, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя Центр Интернета вещей группы потребителей, которая должна использоваться для чтения событий из Центр Интернета вещей. Если значение не указано, входные данные используют группу потребителей Центра Интернета вещей по умолчанию. строка
endpoint Конечная точка Центр Интернета вещей для подключения (например, messages/events, messages/operationsMonitoringEvents и т. д.). строка
iotHubNamespace Имя или URI Центр Интернета вещей. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для Центр Интернета вещей. Эта политика должна содержать по крайней мере разрешение Service Connect. Требуется для запросов PUT (CreateOrReplace). строка

EventHubStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/EventHub (обязательно)
properties Свойства, связанные с входными данными концентратора событий, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). EventHubStreamInputDataSourceProperties

EventHubStreamInputDataSourceProperties

Имя Описание Значение
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если значение не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

BlobStreamInputDataSource

Имя Описание Значение
тип Указывает тип источника входных данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с входными данными большого двоичного объекта, содержащими потоковые данные. Требуется для запросов PUT (CreateOrReplace). BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит blob-объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, с которым будут сопоставляться имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
sourcePartitionCount Число секций источника входных данных BLOB-объекта. Диапазон от 1 до 1024. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

Выходные данные

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с выходными данными. Требуется для запросов PUT (CreateOrReplace). OutputProperties

OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация

OutputDataSource

Имя Описание Значение
тип Установка типа объекта Microsoft.DataLake/Accounts
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI (обязательно)

AzureDataLakeStoreOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). "Microsoft.DataLake/Accounts" (обязательно)
properties Свойства, связанные с выходными данными Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

Имя Описание Значение
accountName Имя учетной записи Azure Data Lake Store. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в filePathPrefix, в качестве формата даты используется значение этого свойства. строка
filePathPrefix Расположение файла, в который должны быть записаны выходные данные. Требуется для запросов PUT (CreateOrReplace). строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Действительный маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить здесь фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
tenantId Идентификатор клиента пользователя, используемого для получения маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
TimeFormat Формат времени. Везде, где {time} отображается в filePathPrefix, значение этого свойства используется в качестве формата времени. строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN) пользователя, который использовался для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

EventHubOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). "Microsoft.ServiceBus/EventHub" (обязательно)
properties Свойства, связанные с выходными данными концентратора событий. Требуется для запросов PUT (CreateOrReplace). EventHubOutputDataSourceProperties

EventHubOutputDataSourceProperties

Имя Описание Значение
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionKey Ключ или столбец, используемый для определения секции, в которую следует отправлять данные о событиях. строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusQueueOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). Microsoft.ServiceBus/Queue (обязательно)
properties Свойства, связанные с выходными данными очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). Свойства ServiceBusQueueOutputDataSource

Свойства ServiceBusQueueOutputDataSource

Имя Описание Значение
propertyColumns Массив строк с именами выходных столбцов, которые будут присоединены к сообщениям служебной шины в виде настраиваемых свойств. string[]
queueName Имя очереди служебной шины. Требуется для запросов PUT (CreateOrReplace). строка
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будет записана запись. Требуется для запросов PUT (CreateOrReplace). "Microsoft.ServiceBus/Topic" (обязательно)
properties Свойства, связанные с выходными данными раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). ServiceBusTopicOutputDataSourceProperties

ServiceBusTopicOutputDataSourceProperties

Имя Описание Значение
propertyColumns Строковый массив имен выходных столбцов, которые будут присоединены к сообщениям служебной шины в качестве пользовательских свойств. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

AzureSqlDatabaseOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Sql/Server/Database (обязательно)
properties Свойства, связанные с выходными данными Azure SQL базы данных. Требуется для запросов PUT (CreateOrReplace). AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

BlobOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/BLOB-объект (обязательно)
properties Свойства, связанные с выходными данными большого двоичного объекта. Требуется для запросов PUT (CreateOrReplace). BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

Имя Описание Значение
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит blob-объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
PathPattern Шаблон пути к большому двоичному объекту. Не является регулярным выражением. Он представляет шаблон, с которым будут сопоставляться имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное объяснение и пример см https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-input . в разделе или https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output . строка
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

DocumentDbOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Storage/DocumentDB (обязательно)
properties Свойства, связанные с выходными данными DocumentDB. Требуется для запросов PUT (CreateOrReplace). DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

Имя Описание Значение
accountId Имя или идентификатор учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
accountKey Ключ учетной записи для учетной записи DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
collectionNamePattern Шаблон имен для используемых коллекций. Формат имени коллекции можно составить с помощью необязательного маркера {partition}, где разделы начинаются с 0. Дополнительные сведения см. в разделе https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных DocumentDB. Требуется для запросов PUT (CreateOrReplace). строка
documentId Имя поля в выходных событиях, используемое для указания основного ключа, на котором основаны операции вставки или обновления. строка
partitionKey Имя поля в выходных событиях, указывающее ключ для разделения выходных данных между коллекциями. Если collectionNamePattern содержит маркер {partition}, необходимо указать это свойство. строка

AzureTableOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). "Microsoft.Storage/Table" (обязательно)
properties Свойства, связанные с выходными данными таблицы Azure. Требуется для запросов PUT (CreateOrReplace). AzureTableOutputDataSourceProperties

AzureTableOutputDataSourceProperties

Имя Описание Значение
accountKey Ключ учетной записи для учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
batchSize Количество строк, записываемых в таблицу Azure за раз. INT
ColumnsToRemove Если указано, каждый элемент в массиве является именем столбца для удаления (при его наличии) из выходных данных сущностей событий. string[]
partitionKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа секции для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
rowKey Этот элемент указывает имя столбца из инструкции SELECT в запросе, который будет использоваться в качестве ключа строки для таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

PowerBIOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). "PowerBI" (обязательно)
properties Свойства, связанные с выходными данными Power BI. Требуется для запросов PUT (CreateOrReplace). PowerBIOutputDataSourceProperties

PowerBIOutputDataSourceProperties

Имя Описание Значение
набор данных Имя набора данных Power BI. Требуется для запросов PUT (CreateOrReplace). строка
groupId Идентификатор группы Power BI. строка
groupName Имя группы Power BI. Используйте это свойство, чтобы запомнить, какой идентификатор группы Power BI использовался. строка
refreshtoken Маркер обновления, который можно использовать для получения допустимого маркера доступа, который затем можно использовать для проверки подлинности в источнике данных. Допустимый маркер обновления в настоящее время можно получить только на портале Azure. Рекомендуется поместить фиктивное строковое значение при создании источника данных, а затем перейти на портал Azure для проверки подлинности источника данных, который обновит это свойство с помощью допустимого маркера обновления. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Power BI в указанном наборе данных. Требуется для запросов PUT (CreateOrReplace). строка
tokenUserDisplayName Отображаемое имя пользователя, которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка
tokenUserPrincipalName Имя участника-пользователя (UPN), которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

Sku

Имя Описание Значение
name Имя номера SKU. Требуется для запросов PUT (CreateOrReplace). "Стандартный"

Преобразование

Имя Описание Значение
name Имя ресурса строка
properties Свойства, связанные с преобразованием. Требуется для запросов PUT (CreateOrReplace). Свойства преобразования

Свойства преобразования

Имя Описание Значение
query Указывает запрос, который будет выполняться в задании потоковой передачи. Дополнительные сведения о языке запросов Stream Analytics (SAQL) см. здесь: https://msdn.microsoft.com/library/azure/dn834998 . Требуется для запросов PUT (CreateOrReplace). строка
streamingUnits Число единиц потоковой передачи, используемых заданием потоковой передачи. INT