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


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

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

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

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

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

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

resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview' = {
  name: 'string'
  location: 'string'
  tags: {
    tagName1: 'tagValue1'
    tagName2: 'tagValue2'
  }
  sku: {
    capacity: int
    name: 'Standard'
  }
  identity: {
    type: 'string'
    userAssignedIdentities: {
      {customized property}: any()
    }
  }
  properties: {
    cluster: {
      id: 'string'
    }
    compatibilityLevel: 'string'
    contentStoragePolicy: 'string'
    dataLocale: 'string'
    eventsLateArrivalMaxDelayInSeconds: int
    eventsOutOfOrderMaxDelayInSeconds: int
    eventsOutOfOrderPolicy: 'string'
    externals: {
      container: 'string'
      path: 'string'
      refreshConfiguration: {
        dateFormat: 'string'
        pathPattern: 'string'
        refreshInterval: 'string'
        refreshType: 'string'
        timeFormat: 'string'
      }
      storageAccount: {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    }
    functions: [
      {
        name: 'string'
        properties: {
          properties: {
            binding: {
              type: 'string'
              // For remaining properties, see FunctionBinding objects
            }
            inputs: [
              {
                dataType: 'string'
                isConfigurationParameter: bool
              }
            ]
            output: {
              dataType: 'string'
            }
          }
          type: 'string'
          // For remaining properties, see FunctionProperties objects
        }
      }
    ]
    inputs: [
      {
        name: 'string'
        properties: {
          compression: {
            type: 'string'
          }
          partitionKey: 'string'
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          watermarkSettings: {
            watermarkMode: 'string'
          }
          type: 'string'
          // For remaining properties, see InputProperties objects
        }
      }
    ]
    jobStorageAccount: {
      accountKey: 'string'
      accountName: 'string'
      authenticationMode: 'string'
    }
    jobType: 'string'
    outputErrorPolicy: 'string'
    outputs: [
      {
        name: 'string'
        properties: {
          datasource: {
            type: 'string'
            // For remaining properties, see OutputDataSource objects
          }
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          sizeWindow: int
          timeWindow: 'string'
          watermarkSettings: {
            maxWatermarkDifferenceAcrossPartitions: 'string'
            watermarkMode: 'string'
          }
        }
      }
    ]
    outputStartMode: 'string'
    outputStartTime: 'string'
    sku: {
      capacity: int
      name: 'Standard'
    }
    transformation: {
      name: 'string'
      properties: {
        query: 'string'
        streamingUnits: int
        validStreamingUnits: [
          int
        ]
      }
    }
  }
}

Объекты FunctionProperties

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

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

  type: 'Aggregate'

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

  type: 'Scalar'

Объекты 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.MachineLearningServices используйте:

  type: 'Microsoft.MachineLearningServices'
  properties: {
    apiKey: 'string'
    batchSize: int
    endpoint: 'string'
    inputRequestName: 'string'
    inputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
    numberOfParallelRequests: int
    outputResponseName: 'string'
    outputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
  }

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

  type: 'Microsoft.StreamAnalytics/CLRUdf'
  properties: {
    class: 'string'
    dllPath: 'string'
    method: 'string'
    updateMode: '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'
  }

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

  type: 'CustomClr'
  properties: {
    serializationClassName: 'string'
    serializationDllPath: 'string'
  }

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

  type: 'Delta'
  properties: {
    deltaTablePath: 'string'
    partitionColumns: [
      'string'
    ]
  }

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

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

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

  type: 'Parquet'
  properties: any()

Объекты ReferenceInputDataSource

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

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

  type: 'File'
  properties: {
    path: 'string'
  }

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

  type: 'Microsoft.Sql/Server/Database'
  properties: {
    authenticationMode: 'string'
    database: 'string'
    deltaSnapshotQuery: 'string'
    fullSnapshotQuery: 'string'
    password: 'string'
    refreshRate: 'string'
    refreshType: 'string'
    server: 'string'
    user: 'string'
  }

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

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

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

  type: 'Raw'
  properties: {
    payload: 'string'
    payloadUri: 'string'
  }

Объекты StreamInputDataSource

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

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

  type: 'GatewayMessageBus'
  properties: {
    topic: 'string'
  }

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

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

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

  type: 'Microsoft.EventGrid/EventSubscriptions'
  properties: {
    eventTypes: [
      'string'
    ]
    schema: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    subscriber: {
      properties: {
        authenticationMode: 'string'
        consumerGroupName: 'string'
        eventHubName: 'string'
        partitionCount: int
        prefetchCount: int
        serviceBusNamespace: 'string'
        sharedAccessPolicyKey: 'string'
        sharedAccessPolicyName: 'string'
      }
      type: 'string'
    }
  }

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

  type: 'Microsoft.EventHub/EventHub'
  properties: {
    authenticationMode: 'string'
    consumerGroupName: 'string'
    eventHubName: 'string'
    partitionCount: int
    prefetchCount: int
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

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

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

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

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

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

  type: 'Raw'
  properties: {
    payload: 'string'
    payloadUri: 'string'
  }

Объекты OutputDataSource

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

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

  type: 'GatewayMessageBus'
  properties: {
    topic: 'string'
  }

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

  type: 'Microsoft.AzureFunction'
  properties: {
    apiKey: 'string'
    functionAppName: 'string'
    functionName: 'string'
    maxBatchCount: int
    maxBatchSize: int
  }

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

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

Для Microsoft.DBForPostgreSQL/servers/databases используйте:

  type: 'Microsoft.DBForPostgreSQL/servers/databases'
  properties: {
    authenticationMode: 'string'
    database: 'string'
    maxWriterCount: int
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }

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

  type: 'Microsoft.EventHub/EventHub'
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

Для Microsoft.Kusto/clusters/databases используйте:

  type: 'Microsoft.Kusto/clusters/databases'
  properties: {
    authenticationMode: 'string'
    cluster: 'string'
    database: 'string'
    table: 'string'
  }

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

  type: 'Microsoft.ServiceBus/EventHub'
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }

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

  type: 'Microsoft.ServiceBus/Queue'
  properties: {
    authenticationMode: 'string'
    propertyColumns: [
      'string'
    ]
    queueName: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
    systemPropertyColumns: any()
  }

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

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

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

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

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

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

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

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

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

  type: 'Microsoft.Storage/DocumentDB'
  properties: {
    accountId: 'string'
    accountKey: 'string'
    authenticationMode: '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: {
    authenticationMode: 'string'
    dataset: 'string'
    groupId: 'string'
    groupName: 'string'
    refreshToken: 'string'
    table: 'string'
    tokenUserDisplayName: 'string'
    tokenUserPrincipalName: 'string'
  }

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

  type: 'Raw'
  properties: {
    payloadUri: 'string'
  }

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

streamingjobs

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

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

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

Идентификация

Имя Описание Значение
тип Тип удостоверения может быть SystemAssigned или UserAssigned. строка
userAssignedIdentities Назначенные пользователем удостоверения, связанные с ресурсом задания потоковой передачи. IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

Имя Описание Значение
{настроенное свойство} Для Bicep можно использовать функцию any().

StreamingJobProperties

Имя Описание Значение
cluster Кластер, в котором будут выполняться задания потоковой передачи. ClusterInfo
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. '1.0'
'1.2'
contentStoragePolicy Допустимые значения: JobStorageAccount и SystemAccount. Если задано значение JobStorageAccount, пользователь также должен указать свойство jobStorageAccount. . JobStorageAccount
SystemAccount
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[]
jobStorageAccount Свойства, связанные с учетной записью хранения Azure с MSI JobStorageAccount
jobType Описывает тип задания. Допустимые режимы: Cloud и "Edge". "Облако"
"Edge"
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, доступный для отдельного преобразования. Преобразование

ClusterInfo

Имя Описание Значение
идентификатор Идентификатор ресурса кластера. строка

Внешняя

Имя Описание Значение
контейнер Контейнер UserCustomCode. строка
path Путь UserCustomCode. строка
refreshConfiguration Параметры обновления для всех обновляемых пользовательских функций, присутствующих в конфигурации задания. RefreshConfiguration
storageAccount Свойства, связанные с учетной записью хранения Azure StorageAccount

RefreshConfiguration

Имя Описание Значение
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 . строка
refreshInterval Интервал обновления. строка
refreshType Это свойство указывает, какой параметр обновления данных следует использовать: Блокировать или Неблокировать. "Блокировка"
"Неблокирование"
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

StorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken

Функция

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

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

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

FunctionConfiguration

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

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

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

AzureMachineLearningStudioFunctionBinding

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

AzureMachineLearningStudioFunctionBindingProperties

Имя Описание Значение
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. AzureMachineLearningStudioInputs
outputs Список выходных данных выполнения конечной точки Студии машинного обучения Azure. AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioInputColumn

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

AzureMachineLearningStudioOutputColumn

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

AzureMachineLearningServiceFunctionBinding

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

AzureMachineLearningServiceFunctionBindingProperties

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в Request-Response конечной точке. строка
batchSize Число от 1 до 10 000, описывающее максимальное количество строк для каждого запроса RRS azure ML. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнять конечную точку веб-службы Машинного обучения Azure. строка
inputRequestName Метка для объекта входного запроса. строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests Количество параллельных запросов, которые будут отправляться в службу машинного обучения на каждую секцию задания. Значение по умолчанию: 1. INT
outputResponseName Метка для объекта выходного запроса. строка
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) входного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) выходного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя выходного столбца. строка

CSharpFunctionBinding

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

CSharpFunctionBindingProperties

Имя Описание Значение
class Код Csharp, содержащий одно определение функции. строка
dllPath Код Csharp, содержащий одно определение функции. строка
method Код Csharp, содержащий одно определение функции. строка
updateMode Режимы обновления для функций Stream Analytics. "Обновляемый"
"Статический"

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 строка

AggregateFunctionProperties

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

ScalarFunctionProperties

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

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

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

InputProperties

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

Сжатие

Имя Описание Значение
тип Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace). Deflate
'GZip'
None (обязательно)

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

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

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). строка

CustomClrSerialization

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

CustomClrSerializationProperties

Имя Описание Значение
serializationClassName Имя класса сериализации. строка
serializationDllPath Путь к библиотеке сериализации. строка

DeltaSerialization

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

DeltaSerializationProperties

Имя Описание Значение
deltaTablePath Указывает путь к таблице Delta Lake, в которую будут записываться выходные данные. string (обязательно)
partitionColumns Указывает имена столбцов, для которых будет секционирована таблица Delta Lake. Мы поддерживаем только 1 столбец секционирования, но сохраняем его как массив для расширяемости. string[]

JsonSerialization

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

JsonSerializationProperties

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

ParquetSerialization

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

InputWatermarkProperties

Имя Описание Значение
watermarkMode Режим входной подложки. "Нет"
ReadWatermark

ReferenceInputProperties

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

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Файл
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Необработанный (обязательный)

FileReferenceInputDataSource

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

FileReferenceInputDataSourceProperties

Имя Описание Значение
path Путь к файлу. строка

AzureSqlReferenceInputDataSource

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

AzureSqlReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Этот элемент связан с элементом datasource. Это имя базы данных, в которую буду записаны выходные данные. строка
deltaSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения добавочных изменений из базы данных SQL. Чтобы использовать этот параметр, рекомендуется использовать темпоральные таблицы в базе данных Azure SQL. строка
fullSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения данных из базы данных SQL. строка
password Этот элемент связан с элементом datasource. Это пароль, который будет использоваться для подключения к экземпляру базы данных SQL. строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
refreshRate Этот элемент связан с элементом datasource. Это указывает, как часто данные будут извлекаться из базы данных. Имеет формат DateTime. строка
refreshType Указывает тип параметра обновления данных. 'RefreshPeriodicallyWithDelta'
RefreshPeriodicallyWithFull
"Статический"
server Этот элемент связан с элементом datasource. Это имя сервера, содержащего базу данных,в которую будет выполняться запись. строка
пользователь Этот элемент связан с элементом datasource. Это имя пользователя, которое будет использоваться для подключения к экземпляру базы данных SQL. строка

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
blobName Имя входных данных большого двоичного объекта. строка
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
deltaPathPattern Шаблон пути разностного snapshot. строка
deltaSnapshotRefreshRate Интервал, в который пользователь создает разностный snapshot этого источника входных данных ссылочного BLOB-объекта. строка
fullSnapshotRefreshRate Интервал обновления источника входных данных BLOB-объекта. строка
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 до 256. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

RawReferenceInputDataSource

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

RawInputDatasourceProperties

Имя Описание Значение
payload Сериализованное содержимое json входных данных. Должны быть заданы либо полезные данные, либо полезные данныеUri, но не оба. строка
payloadUri URL-адрес SAS для большого двоичного объекта, содержащего сериализованное содержимое JSON входных данных. Должны быть заданы либо полезные данные, либо полезные данныеUri, но не оба. строка

StreamInputProperties

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

StreamInputDataSource

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

GatewayMessageBusStreamInputDataSource

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

GatewayMessageBusStreamInputDataSourceProperties

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

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). строка

EventGridStreamInputDataSource

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

EventGridStreamInputDataSourceProperties

Имя Описание Значение
eventTypes Список типов событий, поддерживаемых адаптером Сетки событий. string[]
схема Указывает тип схемы Сетки событий. CloudEventSchema
EventGridEventSchema
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
подписчик Подписчики сетки событий. В настоящее время поддерживается только подписчик EventHub. EventHubV2StreamInputDataSource

EventHubV2StreamInputDataSource

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

EventHubStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если значение не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
prefetchCount Количество сообщений, которые может одновременно запрашивать получатель сообщений. INT
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubStreamInputDataSource

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

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит 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, в качестве формата времени используется значение этого свойства. строка

RawStreamInputDataSource

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

JobStorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken

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

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

Свойства OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как данные сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
sizeWindow Окно размера, ограничивающее выходные данные Stream Analytics. INT
timeWindow Интервал времени для фильтрации выходных данных заданий Stream Analytics. строка
watermarkSettings Параметры, определяющие, следует ли отправлять водяные знаки нижестоящим. OutputWatermarkProperties

OutputDataSource

Имя Описание Значение
тип Установка типа объекта GatewayMessageBus
Microsoft.AzureFunction
Microsoft.DataLake/Accounts
Microsoft.DBForPostgreSQL/servers/databases
Microsoft.EventHub/EventHub
Microsoft.Kusto/clusters/databases
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Sql/Server/DataWarehouse
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI
Необработанный (обязательный)

GatewayMessageBusOutputDataSource

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

Свойства GatewayMessageBusOutputDataSource

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

AzureFunctionOutputDataSource

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

AzureFunctionOutputDataSourceProperties

Имя Описание Значение
apiKey Если нужно использовать службу "Функции Azure" из другой подписки это можно сделать, предоставив ключ для доступа к функции. строка
functionAppName Имя приложения-функции Azure. строка
functionName Имя функции в приложении-функции Azure. строка
maxBatchCount Свойство, которое позволяет указать максимальное число событий в каждом пакете, отправляемых в функции Azure. По умолчанию используется значение 100. INT
maxBatchSize Свойство, которое позволяет задать максимальный размер для каждого выходного пакета, отправляемого в функцию Azure. Объем входных данных задается в байтах. По умолчанию это значение равно 262 144 байт (256 КБ). INT

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

PostgreSQLOutputDataSource

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

PostgreSQLOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxWriterCount Максимальное число элементов записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательно для запросов PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubV2OutputDataSource

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

EventHubOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
partitionKey Ключ или столбец, используемый для определения секции, в которую следует отправлять данные о событиях. строка
propertyColumns Свойства, связанные с выходными данными концентратора событий. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

AzureDataExplorerOutputDataSource

Имя Описание Значение
тип Указывает тип выходных данных источника данных, в который будут записываться данные. Требуется для запросов PUT (CreateOrReplace). Microsoft.Kusto/clusters/databases (обязательно)
properties Свойства, связанные с выходными данными azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). AzureDataExplorerOutputDataSourceProperties

AzureDataExplorerOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
cluster Имя кластера Azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

EventHubOutputDataSource

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

ServiceBusQueueOutputDataSource

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

ServiceBusQueueOutputDataSourceProperties

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с очередью служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc. Для Bicep можно использовать функцию any().

ServiceBusTopicOutputDataSource

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

Свойства ServiceBusTopicOutputDataSourceProperties

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с выходными данными раздела служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc. ServiceBusTopicOutputDataSourcePropertiesSystemPrope...
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

Имя Описание Значение
{настраиваемое свойство} строка

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxBatchCount Максимальное число пакетных пакетов для записи в базу данных SQL, значение по умолчанию — 10 000. Необязательно для запросов PUT. INT
maxWriterCount Максимальное число элементов записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательно для запросов PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL Server, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

AzureSynapseOutputDataSource

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

AzureSynapseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных 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

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
blobPathPrefix Префикс пути к BLOB-объекту. строка
blobWriteMode Режим записи BLOB-объектов. "Append"
"Один раз"
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов 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). строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
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

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
набор данных Имя набора данных 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), которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

RawOutputDatasource

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

RawOutputDatasourceProperties

Имя Описание Значение
payloadUri URL-адрес SAS для большого двоичного объекта, в который должны быть записаны выходные данные. Если это свойство не задано, выходные данные будут записаны во временное хранилище, а URL-адрес SAS для этого временного хранилища будет включен в результат. строка

OutputWatermarkProperties

Имя Описание Значение
maxWatermarkDifferenceAcrossPartitions Описывает максимальную разницу между самыми быстрыми и медленными секциями, поэтому окно вне порядка, которое перехватывает все необходимые события в подчиненных заданиях, четко определено. строка
watermarkMode Режим выходных подложек. "Нет"
SendCurrentPartitionWatermark
SendLowestWatermarkAcrossPartitions

Sku

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

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

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

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

Имя Описание Значение
query Указывает запрос, который будет выполняться в задании потоковой передачи. Дополнительные сведения о языке запросов Stream Analytics (SAQL) см. здесь: https://msdn.microsoft.com/library/azure/dn834998 . Требуется для запросов PUT (CreateOrReplace). строка
streamingUnits Число единиц потоковой передачи, используемых заданием потоковой передачи. INT
validStreamingUnits Указывает допустимые единицы потоковой передачи, до которые может масштабироваться задание потоковой передачи. 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": "2021-10-01-preview",
  "name": "string",
  "location": "string",
  "tags": {
    "tagName1": "tagValue1",
    "tagName2": "tagValue2"
  },
  "sku": {
    "capacity": "int",
    "name": "Standard"
  },
  "identity": {
    "type": "string",
    "userAssignedIdentities": {
      "{customized property}": {}
    }
  },
  "properties": {
    "cluster": {
      "id": "string"
    },
    "compatibilityLevel": "string",
    "contentStoragePolicy": "string",
    "dataLocale": "string",
    "eventsLateArrivalMaxDelayInSeconds": "int",
    "eventsOutOfOrderMaxDelayInSeconds": "int",
    "eventsOutOfOrderPolicy": "string",
    "externals": {
      "container": "string",
      "path": "string",
      "refreshConfiguration": {
        "dateFormat": "string",
        "pathPattern": "string",
        "refreshInterval": "string",
        "refreshType": "string",
        "timeFormat": "string"
      },
      "storageAccount": {
        "accountKey": "string",
        "accountName": "string",
        "authenticationMode": "string"
      }
    },
    "functions": [
      {
        "name": "string",
        "properties": {
          "properties": {
            "binding": {
              "type": "string"
              // For remaining properties, see FunctionBinding objects
            },
            "inputs": [
              {
                "dataType": "string",
                "isConfigurationParameter": "bool"
              }
            ],
            "output": {
              "dataType": "string"
            }
          },
          "type": "string"
          // For remaining properties, see FunctionProperties objects
        }
      }
    ],
    "inputs": [
      {
        "name": "string",
        "properties": {
          "compression": {
            "type": "string"
          },
          "partitionKey": "string",
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          },
          "watermarkSettings": {
            "watermarkMode": "string"
          },
          "type": "string"
          // For remaining properties, see InputProperties objects
        }
      }
    ],
    "jobStorageAccount": {
      "accountKey": "string",
      "accountName": "string",
      "authenticationMode": "string"
    },
    "jobType": "string",
    "outputErrorPolicy": "string",
    "outputs": [
      {
        "name": "string",
        "properties": {
          "datasource": {
            "type": "string"
            // For remaining properties, see OutputDataSource objects
          },
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          },
          "sizeWindow": "int",
          "timeWindow": "string",
          "watermarkSettings": {
            "maxWatermarkDifferenceAcrossPartitions": "string",
            "watermarkMode": "string"
          }
        }
      }
    ],
    "outputStartMode": "string",
    "outputStartTime": "string",
    "sku": {
      "capacity": "int",
      "name": "Standard"
    },
    "transformation": {
      "name": "string",
      "properties": {
        "query": "string",
        "streamingUnits": "int",
        "validStreamingUnits": [ "int" ]
      }
    }
  }
}

Объекты FunctionProperties

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

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

  "type": "Aggregate"

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

  "type": "Scalar"

Объекты 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.MachineLearningServices используйте:

  "type": "Microsoft.MachineLearningServices",
  "properties": {
    "apiKey": "string",
    "batchSize": "int",
    "endpoint": "string",
    "inputRequestName": "string",
    "inputs": [
      {
        "dataType": "string",
        "mapTo": "int",
        "name": "string"
      }
    ],
    "numberOfParallelRequests": "int",
    "outputResponseName": "string",
    "outputs": [
      {
        "dataType": "string",
        "mapTo": "int",
        "name": "string"
      }
    ]
  }

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

  "type": "Microsoft.StreamAnalytics/CLRUdf",
  "properties": {
    "class": "string",
    "dllPath": "string",
    "method": "string",
    "updateMode": "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"
  }

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

  "type": "CustomClr",
  "properties": {
    "serializationClassName": "string",
    "serializationDllPath": "string"
  }

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

  "type": "Delta",
  "properties": {
    "deltaTablePath": "string",
    "partitionColumns": [ "string" ]
  }

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

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

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

  "type": "Parquet",
  "properties": {}

Объекты ReferenceInputDataSource

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

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

  "type": "File",
  "properties": {
    "path": "string"
  }

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

  "type": "Microsoft.Sql/Server/Database",
  "properties": {
    "authenticationMode": "string",
    "database": "string",
    "deltaSnapshotQuery": "string",
    "fullSnapshotQuery": "string",
    "password": "string",
    "refreshRate": "string",
    "refreshType": "string",
    "server": "string",
    "user": "string"
  }

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

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

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

  "type": "Raw",
  "properties": {
    "payload": "string",
    "payloadUri": "string"
  }

Объекты StreamInputDataSource

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

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

  "type": "GatewayMessageBus",
  "properties": {
    "topic": "string"
  }

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

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

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

  "type": "Microsoft.EventGrid/EventSubscriptions",
  "properties": {
    "eventTypes": [ "string" ],
    "schema": "string",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string",
        "authenticationMode": "string"
      }
    ],
    "subscriber": {
      "properties": {
        "authenticationMode": "string",
        "consumerGroupName": "string",
        "eventHubName": "string",
        "partitionCount": "int",
        "prefetchCount": "int",
        "serviceBusNamespace": "string",
        "sharedAccessPolicyKey": "string",
        "sharedAccessPolicyName": "string"
      },
      "type": "string"
    }
  }

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

  "type": "Microsoft.EventHub/EventHub",
  "properties": {
    "authenticationMode": "string",
    "consumerGroupName": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "prefetchCount": "int",
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

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

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

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

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

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

  "type": "Raw",
  "properties": {
    "payload": "string",
    "payloadUri": "string"
  }

Объекты OutputDataSource

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

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

  "type": "GatewayMessageBus",
  "properties": {
    "topic": "string"
  }

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

  "type": "Microsoft.AzureFunction",
  "properties": {
    "apiKey": "string",
    "functionAppName": "string",
    "functionName": "string",
    "maxBatchCount": "int",
    "maxBatchSize": "int"
  }

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

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

Для Microsoft.DBForPostgreSQL/servers/databases используйте:

  "type": "Microsoft.DBForPostgreSQL/servers/databases",
  "properties": {
    "authenticationMode": "string",
    "database": "string",
    "maxWriterCount": "int",
    "password": "string",
    "server": "string",
    "table": "string",
    "user": "string"
  }

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

  "type": "Microsoft.EventHub/EventHub",
  "properties": {
    "authenticationMode": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "partitionKey": "string",
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

Для Microsoft.Kusto/clusters/databases используйте:

  "type": "Microsoft.Kusto/clusters/databases",
  "properties": {
    "authenticationMode": "string",
    "cluster": "string",
    "database": "string",
    "table": "string"
  }

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

  "type": "Microsoft.ServiceBus/EventHub",
  "properties": {
    "authenticationMode": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "partitionKey": "string",
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  }

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

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

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

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

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

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

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

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

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

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

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

  "type": "Microsoft.Storage/DocumentDB",
  "properties": {
    "accountId": "string",
    "accountKey": "string",
    "authenticationMode": "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": {
    "authenticationMode": "string",
    "dataset": "string",
    "groupId": "string",
    "groupName": "string",
    "refreshToken": "string",
    "table": "string",
    "tokenUserDisplayName": "string",
    "tokenUserPrincipalName": "string"
  }

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

  "type": "Raw",
  "properties": {
    "payloadUri": "string"
  }

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

streamingjobs

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

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

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

Идентификация

Имя Описание Значение
тип Тип удостоверения может быть SystemAssigned или UserAssigned. строка
userAssignedIdentities Назначенные пользователем удостоверения, связанные с ресурсом задания потоковой передачи. IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

Имя Описание Значение
{настраиваемое свойство}

StreamingJobProperties

Имя Описание Значение
cluster Кластер, в котором будут выполняться задания потоковой передачи. ClusterInfo
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. '1.0'
'1.2'
contentStoragePolicy Допустимые значения: JobStorageAccount и SystemAccount. Если задано значение JobStorageAccount, пользователь также должен указать свойство jobStorageAccount. . JobStorageAccount
SystemAccount
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, доступный для отдельных входных данных. Входные данные[]
jobStorageAccount Свойства, связанные с учетной записью хранения Azure с MSI JobStorageAccount
jobType Описывает тип задания. Допустимые режимы: Cloud и "Edge". "Облако"
"Edge"
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, доступный для отдельного преобразования. Преобразование

ClusterInfo

Имя Описание Значение
идентификатор Идентификатор ресурса кластера. строка

Внешняя

Имя Описание Значение
контейнер Контейнер UserCustomCode. строка
path Путь UserCustomCode. строка
refreshConfiguration Параметры обновления для любых или всех обновляемых определяемых пользователем функций, присутствующих в конфигурации задания. RefreshConfiguration
storageAccount Свойства, связанные с учетной записью хранения Azure StorageAccount

RefreshConfiguration

Имя Описание Значение
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 . строка
refreshInterval Интервал обновления. строка
refreshType Это свойство указывает, какой параметр обновления данных следует использовать: Блокировать или Неблокировать. Блокировка
"Неблокирование"
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

StorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken

Функция

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

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

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

FunctionConfiguration

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

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

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

AzureMachineLearningStudioFunctionBinding

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

AzureMachineLearningStudioFunctionBindingProperties

Имя Описание Значение
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. AzureMachineLearningStudioInputs
outputs Список выходных данных выполнения конечной точки Студии машинного обучения Azure. AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioInputColumn

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

AzureMachineLearningStudioOutputColumn

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

AzureMachineLearningServiceFunctionBinding

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

AzureMachineLearningServiceFunctionBindingProperties

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в конечной точке Request-Response. строка
batchSize Число от 1 до 10 000, описывающее максимальное число строк для каждого запроса выполнения Azure ML RRS. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнять конечную точку веб-службы Машинного обучения Azure. строка
inputRequestName Метка для объекта входного запроса. строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests Количество параллельных запросов, которые будут отправляться в службу машинного обучения на каждую секцию задания. Значение по умолчанию: 1. INT
outputResponseName Метка для объекта выходного запроса. строка
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) входного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживаемый Машинным обучением Azure) выходного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляется входные данные. INT
name Имя выходного столбца. строка

CSharpFunctionBinding

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

CSharpFunctionBindingProperties

Имя Описание Значение
class Код Csharp, содержащий одно определение функции. строка
dllPath Код Csharp, содержащий одно определение функции. строка
method Код Csharp, содержащий одно определение функции. строка
updateMode Режимы обновления для функций Stream Analytics. "Обновляемый"
"Статический"

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 строка

AggregateFunctionProperties

Имя Описание Значение
тип Указывает тип функции. "Aggregate" (обязательно)

ScalarFunctionProperties

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

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

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

Свойства InputProperties

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

Сжатие

Имя Описание Значение
тип Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace). 'Deflate'
'GZip'
None (обязательно)

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

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

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). строка

CustomClrSerialization

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

CustomClrSerializationProperties

Имя Описание Значение
serializationClassName Имя класса сериализации. строка
serializationDllPath Путь к библиотеке сериализации. строка

DeltaSerialization

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

DeltaSerializationProperties

Имя Описание Значение
deltaTablePath Указывает путь к таблице Delta Lake, в которую будут записываться выходные данные. строка (обязательно)
partitionColumns Указывает имена столбцов, для которых будет секционирована таблица Delta Lake. Мы поддерживаем только 1 столбец секционирования, но сохраняем его в качестве массива для расширяемости. string[]

JsonSerialization

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

JsonSerializationProperties

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

ParquetSerialization

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

InputWatermarkProperties

Имя Описание Значение
watermarkMode Режим входной подложки. "Нет"
ReadWatermark

ReferenceInputProperties

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

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Файл
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Необработанный (обязательный)

FileReferenceInputDataSource

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

FileReferenceInputDataSourceProperties

Имя Описание Значение
path Путь к файлу. строка

AzureSqlReferenceInputDataSource

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

AzureSqlReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Этот элемент связан с элементом datasource. Это имя базы данных, в которую буду записаны выходные данные. строка
deltaSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения добавочных изменений из базы данных SQL. Чтобы использовать этот параметр, рекомендуется использовать темпоральные таблицы в базе данных Azure SQL. строка
fullSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения данных из базы данных SQL. строка
password Этот элемент связан с элементом datasource. Это пароль, который будет использоваться для подключения к экземпляру базы данных SQL. строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
refreshRate Этот элемент связан с элементом datasource. Это указывает, как часто данные будут извлекаться из базы данных. Имеет формат DateTime. строка
refreshType Указывает тип параметра обновления данных. RefreshPeriodicallyWithDelta
'RefreshPeriodicallyWithFull'
"Статический"
server Этот элемент связан с элементом datasource. Это имя сервера, содержащего базу данных,в которую будет выполняться запись. строка
пользователь Этот элемент связан с элементом datasource. Это имя пользователя, которое будет использоваться для подключения к экземпляру базы данных SQL. строка

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
blobName Имя входных данных большого двоичного объекта. строка
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит blob-объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
deltaPathPattern Шаблон пути для разностного snapshot. строка
deltaSnapshotRefreshRate Интервал, в который пользователь создает разностную snapshot этого источника входных данных ссылочного BLOB-объекта. строка
fullSnapshotRefreshRate Интервал обновления источника входных данных BLOB-объекта. строка
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 до 256. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени. строка

RawReferenceInputDataSource

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

RawInputDatasourceProperties

Имя Описание Значение
payload Сериализованное содержимое JSON входных данных. Необходимо задать либо payload, либо payloadUri, но не оба. строка
payloadUri URL-адрес SAS для большого двоичного объекта, содержащего сериализованное содержимое JSON входных данных. Необходимо задать либо payload, либо payloadUri, но не оба. строка

StreamInputProperties

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

StreamInputDataSource

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

GatewayMessageBusStreamInputDataSource

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

GatewayMessageBusStreamInputDataSourceProperties

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

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). строка

EventGridStreamInputDataSource

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

EventGridStreamInputDataSourceProperties

Имя Описание Значение
eventTypes Список типов событий, поддерживаемых адаптером Сетки событий. string[]
схема Указывает тип схемы Сетки событий. CloudEventSchema
EventGridEventSchema
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
подписчик Подписчики сетки событий. В настоящее время поддерживается только подписчик EventHub. EventHubV2StreamInputDataSource

EventHubV2StreamInputDataSource

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

EventHubStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
prefetchCount Количество сообщений, которые может одновременно запрашивать получатель сообщений. INT
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubStreamInputDataSource

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

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов 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, значение этого свойства используется в качестве формата времени. строка

RawStreamInputDataSource

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

JobStorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken

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

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

OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
sizeWindow Окно размера для ограничения выходных данных Stream Analytics. INT
timeWindow Временной интервал для фильтрации выходных данных заданий Stream Analytics. строка
watermarkSettings Параметры, определяющие, следует ли отправлять водяные знаки в нижестоящий поток. OutputWatermarkProperties

OutputDataSource

Имя Описание Значение
тип Установка типа объекта GatewayMessageBus
Microsoft.AzureFunction
Microsoft.DataLake/Accounts
Microsoft.DBForPostgreSQL/servers/databases
Microsoft.EventHub/EventHub
Microsoft.Kusto/clusters/databases
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Sql/Server/DataWarehouse
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI
Необработанный (обязательный)

GatewayMessageBusOutputDataSource

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

GatewayMessageBusOutputDataSourceProperties

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

AzureFunctionOutputDataSource

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

AzureFunctionOutputDataSourceProperties

Имя Описание Значение
apiKey Если нужно использовать службу "Функции Azure" из другой подписки это можно сделать, предоставив ключ для доступа к функции. строка
functionAppName Имя приложения-функции Azure. строка
functionName Имя функции в приложении-функции Azure. строка
maxBatchCount Свойство, которое позволяет указать максимальное число событий в каждом пакете, отправляемых в функции Azure. По умолчанию используется значение 100. INT
maxBatchSize Свойство, которое позволяет задать максимальный размер для каждого выходного пакета, отправляемого в функцию Azure. Объем входных данных задается в байтах. По умолчанию это значение равно 262 144 байт (256 КБ). INT

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

PostgreSQLOutputDataSource

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

PostgreSQLOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxWriterCount Максимальное число элементов записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательно для запросов PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubV2OutputDataSource

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

EventHubOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
partitionKey Ключ или столбец, используемый для определения секции, в которую следует отправлять данные о событиях. строка
propertyColumns Свойства, связанные с выходными данными концентратора событий. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

AzureDataExplorerOutputDataSource

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

AzureDataExplorerOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
cluster Имя кластера Azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных Azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

EventHubOutputDataSource

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

ServiceBusQueueOutputDataSource

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

Свойства ServiceBusQueueOutputDataSource

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с очередью служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.

ServiceBusTopicOutputDataSource

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

Свойства ServiceBusTopicOutputDataSourceProperties

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с выходными данными раздела служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc. ServiceBusTopicOutputDataSourcePropertiesSystemPrope...
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

Имя Описание Значение
{настраиваемое свойство} строка

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxBatchCount Максимальное число пакетных пакетов для записи в базу данных SQL, значение по умолчанию — 10 000. Необязательно для запросов PUT. INT
maxWriterCount Максимальное число элементов записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательно для запросов PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL Server, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

AzureSynapseOutputDataSource

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

AzureSynapseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
База данных Имя базы данных 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

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
blobPathPrefix Префикс пути к BLOB-объекту. строка
blobWriteMode Режим записи BLOB-объектов. "Добавить"
"Один раз"
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит 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). строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
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

Имя Описание Значение
authenticationMode Режим проверки подлинности. ConnectionString
Msi
UserToken
набор данных Имя набора данных 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) пользователя, который использовался для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

RawOutputDatasource

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

RawOutputDatasourceProperties

Имя Описание Значение
payloadUri URL-адрес SAS для большого двоичного объекта, в который должны быть записаны выходные данные. Если это свойство не задано, выходные данные записываются во временное хранилище, а URL-адрес SAS для этого временного хранилища будет включен в результат. строка

OutputWatermarkProperties

Имя Описание Значение
maxWatermarkDifferenceAcrossPartitions Описывает максимальную разницу между самыми быстрыми и медленными секциями, поэтому окно вне порядка, которое перехватывает все необходимые события в подчиненных заданиях, хорошо определено. строка
watermarkMode Режим выходных подложек. "Нет"
SendCurrentPartitionWatermark
SendLowestWatermarkAcrossPartitions

Sku

Имя Описание Значение
Емкость Емкость номера SKU. INT
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
validStreamingUnits Указывает допустимые единицы потоковой передачи, до которые может масштабироваться задание потоковой передачи. 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@2021-10-01-preview"
  name = "string"
  location = "string"
  parent_id = "string"
  tags = {
    tagName1 = "tagValue1"
    tagName2 = "tagValue2"
  }
  identity {
    type = "string"
    identity_ids = []
  }
  body = jsonencode({
    properties = {
      cluster = {
        id = "string"
      }
      compatibilityLevel = "string"
      contentStoragePolicy = "string"
      dataLocale = "string"
      eventsLateArrivalMaxDelayInSeconds = int
      eventsOutOfOrderMaxDelayInSeconds = int
      eventsOutOfOrderPolicy = "string"
      externals = {
        container = "string"
        path = "string"
        refreshConfiguration = {
          dateFormat = "string"
          pathPattern = "string"
          refreshInterval = "string"
          refreshType = "string"
          timeFormat = "string"
        }
        storageAccount = {
          accountKey = "string"
          accountName = "string"
          authenticationMode = "string"
        }
      }
      functions = [
        {
          name = "string"
          properties = {
            properties = {
              binding = {
                type = "string"
                // For remaining properties, see FunctionBinding objects
              }
              inputs = [
                {
                  dataType = "string"
                  isConfigurationParameter = bool
                }
              ]
              output = {
                dataType = "string"
              }
            }
            type = "string"
            // For remaining properties, see FunctionProperties objects
          }
        }
      ]
      inputs = [
        {
          name = "string"
          properties = {
            compression = {
              type = "string"
            }
            partitionKey = "string"
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
            watermarkSettings = {
              watermarkMode = "string"
            }
            type = "string"
            // For remaining properties, see InputProperties objects
          }
        }
      ]
      jobStorageAccount = {
        accountKey = "string"
        accountName = "string"
        authenticationMode = "string"
      }
      jobType = "string"
      outputErrorPolicy = "string"
      outputs = [
        {
          name = "string"
          properties = {
            datasource = {
              type = "string"
              // For remaining properties, see OutputDataSource objects
            }
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
            sizeWindow = int
            timeWindow = "string"
            watermarkSettings = {
              maxWatermarkDifferenceAcrossPartitions = "string"
              watermarkMode = "string"
            }
          }
        }
      ]
      outputStartMode = "string"
      outputStartTime = "string"
      sku = {
        capacity = int
        name = "Standard"
      }
      transformation = {
        name = "string"
        properties = {
          query = "string"
          streamingUnits = int
          validStreamingUnits = [
            int
          ]
        }
      }
    }
    sku = {
      capacity = int
      name = "Standard"
    }
  })
}

Объекты FunctionProperties

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

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

  type = "Aggregate"

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

  type = "Scalar"

Объекты 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.MachineLearningServices используйте:

  type = "Microsoft.MachineLearningServices"
  properties = {
    apiKey = "string"
    batchSize = int
    endpoint = "string"
    inputRequestName = "string"
    inputs = [
      {
        dataType = "string"
        mapTo = int
        name = "string"
      }
    ]
    numberOfParallelRequests = int
    outputResponseName = "string"
    outputs = [
      {
        dataType = "string"
        mapTo = int
        name = "string"
      }
    ]
  }

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

  type = "Microsoft.StreamAnalytics/CLRUdf"
  properties = {
    class = "string"
    dllPath = "string"
    method = "string"
    updateMode = "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"
  }

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

  type = "CustomClr"
  properties = {
    serializationClassName = "string"
    serializationDllPath = "string"
  }

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

  type = "Delta"
  properties = {
    deltaTablePath = "string"
    partitionColumns = [
      "string"
    ]
  }

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

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

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

  type = "Parquet"

Объекты ReferenceInputDataSource

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

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

  type = "File"
  properties = {
    path = "string"
  }

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

  type = "Microsoft.Sql/Server/Database"
  properties = {
    authenticationMode = "string"
    database = "string"
    deltaSnapshotQuery = "string"
    fullSnapshotQuery = "string"
    password = "string"
    refreshRate = "string"
    refreshType = "string"
    server = "string"
    user = "string"
  }

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

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

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

  type = "Raw"
  properties = {
    payload = "string"
    payloadUri = "string"
  }

Объекты StreamInputDataSource

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

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

  type = "GatewayMessageBus"
  properties = {
    topic = "string"
  }

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

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

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

  type = "Microsoft.EventGrid/EventSubscriptions"
  properties = {
    eventTypes = [
      "string"
    ]
    schema = "string"
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
        authenticationMode = "string"
      }
    ]
    subscriber = {
      properties = {
        authenticationMode = "string"
        consumerGroupName = "string"
        eventHubName = "string"
        partitionCount = int
        prefetchCount = int
        serviceBusNamespace = "string"
        sharedAccessPolicyKey = "string"
        sharedAccessPolicyName = "string"
      }
      type = "string"
    }
  }

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

  type = "Microsoft.EventHub/EventHub"
  properties = {
    authenticationMode = "string"
    consumerGroupName = "string"
    eventHubName = "string"
    partitionCount = int
    prefetchCount = int
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

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

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

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

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

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

  type = "Raw"
  properties = {
    payload = "string"
    payloadUri = "string"
  }

Объекты OutputDataSource

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

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

  type = "GatewayMessageBus"
  properties = {
    topic = "string"
  }

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

  type = "Microsoft.AzureFunction"
  properties = {
    apiKey = "string"
    functionAppName = "string"
    functionName = "string"
    maxBatchCount = int
    maxBatchSize = int
  }

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

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

Для Microsoft.DBForPostgreSQL/servers/databases используйте:

  type = "Microsoft.DBForPostgreSQL/servers/databases"
  properties = {
    authenticationMode = "string"
    database = "string"
    maxWriterCount = int
    password = "string"
    server = "string"
    table = "string"
    user = "string"
  }

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

  type = "Microsoft.EventHub/EventHub"
  properties = {
    authenticationMode = "string"
    eventHubName = "string"
    partitionCount = int
    partitionKey = "string"
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

Для Microsoft.Kusto/clusters/databases используйте:

  type = "Microsoft.Kusto/clusters/databases"
  properties = {
    authenticationMode = "string"
    cluster = "string"
    database = "string"
    table = "string"
  }

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

  type = "Microsoft.ServiceBus/EventHub"
  properties = {
    authenticationMode = "string"
    eventHubName = "string"
    partitionCount = int
    partitionKey = "string"
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }

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

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

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

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

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

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

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

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

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

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

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

  type = "Microsoft.Storage/DocumentDB"
  properties = {
    accountId = "string"
    accountKey = "string"
    authenticationMode = "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 = {
    authenticationMode = "string"
    dataset = "string"
    groupId = "string"
    groupName = "string"
    refreshToken = "string"
    table = "string"
    tokenUserDisplayName = "string"
    tokenUserPrincipalName = "string"
  }

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

  type = "Raw"
  properties = {
    payloadUri = "string"
  }

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

streamingjobs

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

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

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

Идентификация

Имя Описание Значение
тип Тип удостоверения может быть SystemAssigned или UserAssigned. строка
identity_ids Назначенные пользователем удостоверения, связанные с ресурсом задания потоковой передачи. Массив идентификаторов удостоверений пользователей.

IdentityUserAssignedIdentities

Имя Описание Значение
{настроенное свойство}

StreamingJobProperties

Имя Описание Значение
cluster Кластер, в котором будут выполняться задания потоковой передачи. ClusterInfo
compatibilityLevel Управляет отдельными аспектами поведения задания потоковой передачи во время выполнения. "1.0"
"1.2"
contentStoragePolicy Допустимые значения: JobStorageAccount и SystemAccount. Если задано значение JobStorageAccount, пользователь также должен указать свойство jobStorageAccount. . "JobStorageAccount"
"SystemAccount"
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, доступный для отдельных входных данных. Input[]
jobStorageAccount Свойства, связанные с учетной записью хранения Azure с MSI JobStorageAccount
jobType Описывает тип задания. Допустимые режимы: Cloud и "Edge". "Облако"
"Edge"
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, доступный для отдельного преобразования. Преобразование

ClusterInfo

Имя Описание Значение
идентификатор Идентификатор ресурса кластера. строка

Внешняя

Имя Описание Значение
контейнер Контейнер UserCustomCode. строка
path Путь UserCustomCode. строка
refreshConfiguration Параметры обновления для всех обновляемых пользовательских функций, присутствующих в конфигурации задания. RefreshConfiguration
storageAccount Свойства, связанные с учетной записью хранения Azure StorageAccount

RefreshConfiguration

Имя Описание Значение
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 . строка
refreshInterval Интервал обновления. строка
refreshType Это свойство указывает, какой параметр обновления данных следует использовать: Блокировать или Неблокировать. "Блокировка"
"Неблокирование"
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

StorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. "ConnectionString"
"Msi"
UserToken

Функция

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

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

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

FunctionConfiguration

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

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

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

AzureMachineLearningStudioFunctionBinding

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

AzureMachineLearningStudioFunctionBindingProperties

Имя Описание Значение
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. AzureMachineLearningStudioInputs
outputs Список выходных данных выполнения конечной точки Студии машинного обучения Azure. AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioInputColumn

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

AzureMachineLearningStudioOutputColumn

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

AzureMachineLearningServiceFunctionBinding

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

AzureMachineLearningServiceFunctionBindingProperties

Имя Описание Значение
apiKey Ключ API, используемый для проверки подлинности в Request-Response конечной точке. строка
batchSize Число от 1 до 10 000, описывающее максимальное количество строк для каждого запроса RRS azure ML. Значение по умолчанию — 1000. INT
endpoint Request-Response выполнить конечную точку веб-службы Машинного обучения Azure. строка
inputRequestName Метка для объекта входного запроса. строка
Ввод данных Входные данные для конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests Количество параллельных запросов, которые будут отправляться в службу машинного обучения для каждой секции задания. Значение по умолчанию: 1. INT
outputResponseName Метка для объекта запроса вывода. строка
outputs Список выходных данных выполнения конечной точки веб-службы Машинного обучения Azure. AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Имя Описание Значение
dataType Тип данных (поддерживается Машинным обучением Azure) входного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляются входные данные. INT
name Имя входного столбца. строка

AzureMachineLearningServiceOutputColumn

Имя Описание Значение
dataType Тип данных (поддерживается Машинным обучением Azure) выходного столбца. строка
mapTo Отсчитываемый от нуля индекс параметра функции, с который сопоставляются входные данные. INT
name Имя выходного столбца. строка

CSharpFunctionBinding

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

CSharpFunctionBindingProperties

Имя Описание Значение
class Код Csharp, содержащий одно определение функции. строка
dllPath Код Csharp, содержащий одно определение функции. строка
method Код Csharp, содержащий одно определение функции. строка
updateMode Режимы обновления для функций Stream Analytics. "Обновляемый"
"Static"

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 строка

AggregateFunctionProperties

Имя Описание Значение
тип Указывает тип функции. "Aggregate" (обязательно)

ScalarFunctionProperties

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

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

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

Свойства InputProperties

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

Сжатие

Имя Описание Значение
тип Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace). "Deflate"
"GZip"
"None" (обязательно)

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

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

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). строка

CustomClrSerialization

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

CustomClrSerializationProperties

Имя Описание Значение
serializationClassName Имя класса сериализации. строка
serializationDllPath Путь к библиотеке сериализации. строка

DeltaSerialization

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

DeltaSerializationProperties

Имя Описание Значение
deltaTablePath Указывает путь к таблице Delta Lake, в которую будут записываться выходные данные. string (обязательно)
partitionColumns Указывает имена столбцов, для которых будет секционирована таблица Delta Lake. Мы поддерживаем только 1 столбец секционирования, но сохраняем его как массив для расширяемости. string[]

JsonSerialization

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

JsonSerializationProperties

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

ParquetSerialization

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

InputWatermarkProperties

Имя Описание Значение
watermarkMode Режим входной подложки. "None"
"ReadWatermark"

ReferenceInputProperties

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

ReferenceInputDataSource

Имя Описание Значение
тип Установка типа объекта Файл
Microsoft.Sql/Server/Database
Microsoft.Storage/BLOB-объект
Необработанный (обязательный)

FileReferenceInputDataSource

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

FileReferenceInputDataSourceProperties

Имя Описание Значение
path Путь к файлу. строка

AzureSqlReferenceInputDataSource

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

AzureSqlReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
База данных Этот элемент связан с элементом datasource. Это имя базы данных, в которую буду записаны выходные данные. строка
deltaSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения добавочных изменений из базы данных SQL. Для использования этого параметра рекомендуется использовать темпоральные таблицы в базе данных Azure SQL. строка
fullSnapshotQuery Этот элемент связан с элементом datasource. Этот запрос используется для получения данных из базы данных SQL. строка
password Этот элемент связан с элементом datasource. Это пароль, который будет использоваться для подключения к экземпляру базы данных SQL. строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
refreshRate Этот элемент связан с элементом datasource. Это указывает, как часто данные будут извлекаться из базы данных. Имеет формат DateTime. строка
refreshType Указывает тип параметра обновления данных. "RefreshPeriodicallyWithDelta"
RefreshPeriodicallyWithFull
"Static"
server Этот элемент связан с элементом datasource. Это имя сервера, содержащего базу данных,в которую будет выполняться запись. строка
пользователь Этот элемент связан с элементом datasource. Это имя пользователя, которое будет использоваться для подключения к экземпляру базы данных SQL. строка

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"Msi"
UserToken
blobName Имя входных данных большого двоичного объекта. строка
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты для чтения или записи. Требуется для запросов PUT (CreateOrReplace). строка
dateFormat Формат даты. Везде, где {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты. строка
deltaPathPattern Шаблон пути разностного snapshot. строка
deltaSnapshotRefreshRate Интервал, в который пользователь создает разностный snapshot этого источника входных данных ссылочного BLOB-объекта. строка
fullSnapshotRefreshRate Интервал обновления источника входных данных BLOB-объекта. строка
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 до 256. INT
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
TimeFormat Формат времени. Везде, где {time} отображается в pathPattern, в качестве формата времени используется значение этого свойства. строка

RawReferenceInputDataSource

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

RawInputDatasourceProperties

Имя Описание Значение
payload Сериализованное содержимое json входных данных. Должны быть заданы либо полезные данные, либо полезные данныеUri, но не оба. строка
payloadUri URL-адрес SAS для большого двоичного объекта, содержащего сериализованное содержимое JSON входных данных. Должны быть заданы либо полезные данные, либо полезные данныеUri, но не оба. строка

StreamInputProperties

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

StreamInputDataSource

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

GatewayMessageBusStreamInputDataSource

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

GatewayMessageBusStreamInputDataSourceProperties

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

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). строка

EventGridStreamInputDataSource

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

EventGridStreamInputDataSourceProperties

Имя Описание Значение
eventTypes Список типов событий, поддерживаемых адаптером Сетки событий. string[]
схема Указывает тип схемы Сетки событий. CloudEventSchema
"EventGridEventSchema"
storageAccounts Список из одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace). StorageAccount[]
подписчик Подписчики сетки событий. В настоящее время поддерживается только подписчик EventHub. EventHubV2StreamInputDataSource

EventHubV2StreamInputDataSource

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

EventHubStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
consumerGroupName Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать одни и те же события из концентратора событий. Если значение не указано, входные данные используют группу потребителей концентратора событий по умолчанию. строка
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
prefetchCount Количество сообщений, которые может одновременно запрашивать получатель сообщений. INT
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubStreamInputDataSource

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

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит 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, значение этого свойства используется в качестве формата времени. строка

RawStreamInputDataSource

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

JobStorageAccount

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
accountName имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace). строка
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken

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

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

OutputProperties

Имя Описание Значение
datasource Описывает источник данных, в который будут записываться выходные данные. Требуется для запросов PUT (CreateOrReplace). OutputDataSource
сериализацию Описывает, как сериализуются данные из входных данных или как они сериализуются при записи в выходные данные. Требуется для запросов PUT (CreateOrReplace). Сериализация
sizeWindow Окно размера для ограничения выходных данных Stream Analytics. INT
timeWindow Временной интервал для фильтрации выходных данных заданий Stream Analytics. строка
watermarkSettings Параметры, определяющие, следует ли отправлять водяные знаки в нижестоящий поток. OutputWatermarkProperties

OutputDataSource

Имя Описание Значение
тип Установка типа объекта GatewayMessageBus
Microsoft.AzureFunction
Microsoft.DataLake/Accounts
Microsoft.DBForPostgreSQL/servers/databases
Microsoft.EventHub/EventHub
Microsoft.Kusto/clusters/databases
Microsoft.ServiceBus/EventHub
Microsoft.ServiceBus/Queue
Microsoft.ServiceBus/Topic
Microsoft.Sql/Server/Database
Microsoft.Sql/Server/DataWarehouse
Microsoft.Storage/BLOB-объект
Microsoft.Storage/DocumentDB
Microsoft.Storage/Table
PowerBI
Необработанный (обязательный)

GatewayMessageBusOutputDataSource

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

GatewayMessageBusOutputDataSourceProperties

Имя Описание Значение
Раздел Имя раздела служебной шины. строка

AzureFunctionOutputDataSource

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

AzureFunctionOutputDataSourceProperties

Имя Описание Значение
apiKey Если нужно использовать службу "Функции Azure" из другой подписки это можно сделать, предоставив ключ для доступа к функции. строка
functionAppName Имя приложения-функции Azure. строка
functionName Имя функции в приложении-функции Azure. строка
maxBatchCount Свойство, которое позволяет указать максимальное число событий в каждом пакете, отправляемых в функции Azure. По умолчанию используется значение 100. INT
maxBatchSize Свойство, которое позволяет задать максимальный размер для каждого выходного пакета, отправляемого в функцию Azure. Объем входных данных задается в байтах. По умолчанию это значение равно 262 144 байт (256 КБ). INT

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

PostgreSQLOutputDataSource

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

PostgreSQLOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxWriterCount Максимальное число модуля записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательный параметр в запросах PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

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

EventHubV2OutputDataSource

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

EventHubOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
eventHubName Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace). строка
partitionCount Число секций источника данных концентратора событий. Диапазон от 1 до 256. INT
partitionKey Ключ или столбец, используемый для определения секции, в которую следует отправлять данные о событиях. строка
propertyColumns Свойства, связанные с выходными данными концентратора событий. string[]
serviceBusNamespace Пространство имен, связанное с нужным концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
sharedAccessPolicyKey Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace). строка

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

AzureDataExplorerOutputDataSource

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

AzureDataExplorerOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"Msi"
UserToken
cluster Имя кластера Azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
База данных Имя базы данных Azure Data Explorer. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы Azure. Требуется для запросов PUT (CreateOrReplace). строка

EventHubOutputDataSource

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

ServiceBusQueueOutputDataSource

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

Свойства ServiceBusQueueOutputDataSource

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с очередью служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.

ServiceBusTopicOutputDataSource

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

Свойства ServiceBusTopicOutputDataSourceProperties

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

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
sharedAccessPolicyName Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace). строка
systemPropertyColumns Системные свойства, связанные с выходными данными раздела служебной шины. Поддерживаются следующие системные свойства: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc. ServiceBusTopicOutputDataSourcePropertiesSystemPrope...
topicName Имя раздела служебной шины. Требуется для запросов PUT (CreateOrReplace). строка

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

Имя Описание Значение
{настраиваемое свойство} строка

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"Msi"
UserToken
База данных Имя базы данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
maxBatchCount Максимальное число пакетных пакетов для записи в базу данных SQL, значение по умолчанию — 10 000. Необязательно для запросов PUT. INT
maxWriterCount Максимальное число элементов записи, в настоящее время доступно только 1 (один модуль записи) и 0 (на основе секции запроса). Необязательно для запросов PUT. INT
password Пароль, который будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
server Имя сервера SQL Server, содержащего базу данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
table Имя таблицы в базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка
пользователь Имя пользователя, которое будет использоваться для подключения к базе данных Azure SQL. Требуется для запросов PUT (CreateOrReplace). строка

AzureSynapseOutputDataSource

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

AzureSynapseOutputDataSourceProperties

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
База данных Имя базы данных 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

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
blobPathPrefix Префикс пути к BLOB-объекту. строка
blobWriteMode Режим записи BLOB-объектов. "Добавить"
"Один раз"
контейнер Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит 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). строка

Ограничения:
Конфиденциальное значение. Передайте в качестве безопасного параметра.
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
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

Имя Описание Значение
authenticationMode Режим проверки подлинности. "ConnectionString"
"MSI"
UserToken
набор данных Имя набора данных 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), которое использовалось для получения маркера обновления. Используйте это свойство, чтобы запомнить, какой пользователь использовался для получения маркера обновления. строка

RawOutputDatasource

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

RawOutputDatasourceProperties

Имя Описание Значение
payloadUri URL-адрес SAS для большого двоичного объекта, в который должны быть записаны выходные данные. Если это свойство не задано, выходные данные будут записаны во временное хранилище, а URL-адрес SAS для этого временного хранилища будет включен в результат. строка

OutputWatermarkProperties

Имя Описание Значение
maxWatermarkDifferenceAcrossPartitions Описывает максимальную разницу между самыми быстрыми и медленными секциями, поэтому окно вне порядка, которое перехватывает все необходимые события в подчиненных заданиях, четко определено. строка
watermarkMode Режим выходных подложек. "None"
SendCurrentPartitionWatermark
SendLowestWatermarkAcrossPartitions

Sku

Имя Описание Значение
Емкость Емкость номера SKU. INT
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
validStreamingUnits Указывает допустимые единицы потоковой передачи, до которые может масштабироваться задание потоковой передачи. int[]