你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

Microsoft.StreamAnalytics streamingjobs

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'
  }

对于 Raw,请使用:

  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'
  }

对于 Raw,请使用:

  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'
  }

对于 Raw,请使用:

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

属性值

streamingjobs

名称 说明
name 资源名称 字符串 (必需)

字符限制:3-63

有效字符:
字母数字、连字符和下划线。
location 资源所在的地理位置 string
标记 资源标记。 标记名称和值的字典。 请参阅 模板中的标记
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求时是必需的。 Sku
标识 描述分配给此作业的托管标识,该标识可用于通过输入和输出进行身份验证。 标识
properties 与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 StreamingJobProperties

标识

名称 说明 Value
type 标识的类型可以是 SystemAssigned 或 UserAssigned。 string
userAssignedIdentities 与流式处理作业资源关联的用户分配的标识。 IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

名称 说明
{customized property} 对于 Bicep,可以使用 any () 函数。

StreamingJobProperties

名称 说明
cluster 将运行流式处理作业的群集。 ClusterInfo
compatibilityLevel 控制流式处理作业的某些运行时行为。 '1.0'
'1.2'
contentStoragePolicy 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则这要求用户同时指定 jobStorageAccount 属性。 . “JobStorageAccount”
“SystemAccount”
dataLocale 流分析作业的数据区域设置。 值应为集 https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110) .aspx 中支持的 .NET 区域性的名称。 如果未指定,则默认为“en-US”。 string
eventsLateArrivalMaxDelayInSeconds 可容忍的最大延迟(以秒为单位),其中可能包括迟到事件。 支持的范围为 -1 到 1814399(20.23:59:59 天),-1 用于指定无限期等待。 如果该属性不存在,则将其解释为具有值 -1。 int
eventsOutOfOrderMaxDelayInSeconds 可容许的最大延迟(以秒为单位),其中无序事件可重新调整为有序事件。 int
eventsOutOfOrderPolicy 指示要应用于输入事件流中未按顺序到达的事件的策略。 'Adjust'
'Drop'
外部 自定义代码项目所在的存储帐户。 外部
functions 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 Function[]
inputs 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,每个输入的名称属性是必需的。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输入的 PATCH API。 Input[]
jobStorageAccount 与具有 MSI 的 Azure 存储帐户关联的属性 JobStorageAccount
jobType 描述作业的类型。 有效模式为 Cloud 和 “Edge”。 “云”
'Edge'
outputErrorPolicy 指示要应用于到达输出但由于格式错误(缺少列值、列值类型或大小错误)而无法写入外部存储的事件的策略。 'Drop'
'Stop'
outputs 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输出的 PATCH API。 Output[]
outputStartMode 仅当需要作业在创建时立即启动时,才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示输出事件流的起点应每当作业启动时启动、从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上次事件输出时间开始。 'CustomTime'
“JobStartTime”
“LastOutputEventTime”
outputStartTime 值为采用 ISO-8601 格式的时间戳(指示输出事件流的起点),或者为 null(指示输出事件流将在每次启动流式处理作业时开始)。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 字符串
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求时是必需的。 Sku
转换 指示要用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的名称属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 转换

ClusterInfo

名称 说明 Value
id 群集的资源 ID。 字符串

外部

名称 说明
container UserCustomCode 容器。 string
path UserCustomCode 路径。 string
refreshConfiguration 作业配置中存在的任何/所有可更新用户定义函数的刷新参数。 RefreshConfiguration
storageAccount 与 Azure 存储帐户关联的属性 StorageAccount

RefreshConfiguration

名称 说明
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
refreshInterval 刷新间隔。 字符串
refreshType 此属性指示要使用的数据刷新选项,阻止或非阻止。 “阻止”
“Nonblocking”
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 字符串

StorageAccount

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”

函数

名称 说明
name 资源名称 string
properties 与函数关联的属性。 FunctionProperties

FunctionProperties

名称 说明
properties FunctionConfiguration
类型 设置对象类型 聚合
需要标 ()

FunctionConfiguration

名称 说明
binding 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的示例中,此描述终结点。 FunctionBinding
inputs FunctionInput[]
output 描述函数的输出。 FunctionOutput

FunctionBinding

名称 说明 Value
type 设置对象类型 Microsoft.MachineLearning/WebService
Microsoft.MachineLearningServices
Microsoft.StreamAnalytics/CLRUdf
需要 Microsoft.StreamAnalytics/JavascriptUdf ()

AzureMachineLearningStudioFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.MachineLearning/WebService” ()
properties 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties

AzureMachineLearningStudioFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 字符串
batchSize 数字介于 1 和 10000 之间,描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习工作室的终结点。 在此处了解详细信息: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs string
inputs Azure 机器学习工作室终结点的输入。 AzureMachineLearningStudioInputs
outputs Azure 机器学习工作室终结点执行的输出列表。 AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputs

名称 说明
columnNames Azure 机器学习工作室终结点的输入列列表。 AzureMachineLearningStudioInputColumn[]
name 输入的名称。 这是创作终结点时提供的名称。 字符串

AzureMachineLearningStudioInputColumn

名称 说明
dataType Azure 机器学习支持的 () 输入列的数据类型。 有关有效 Azure 机器学习数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn905923.aspx string
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输入列的名称。 string

AzureMachineLearningStudioOutputColumn

名称 说明
dataType Azure 机器学习支持的 () 输出列的数据类型。 有关有效 Azure 机器学习数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn905923.aspx string
name 输出列的名称。 字符串

AzureMachineLearningServiceFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.MachineLearningServices” ()
properties 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties

AzureMachineLearningServiceFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 string
batchSize 数字介于 1 和 10000 之间,描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习 Web 服务的终结点。 字符串
inputRequestName 输入请求对象的标签。 字符串
inputs Azure 机器学习 Web 服务终结点的输入。 AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests 将每个作业分区发送到机器学习服务的并行请求数。 默认值为 1。 int
outputResponseName 输出请求对象的标签。 string
outputs Azure 机器学习 Web 服务终结点执行的输出列表。 AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

名称 说明
dataType Azure 机器学习支持的 () 输入列的数据类型。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输入列的名称。 字符串

AzureMachineLearningServiceOutputColumn

名称 说明
dataType Azure 机器学习支持的 () 输出列的数据类型。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输出列的名称。 字符串

CSharpFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/CLRUdf” ()
properties 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties

CSharpFunctionBindingProperties

名称 说明
class 包含单个函数定义的 Csharp 代码。 string
dllPath 包含单个函数定义的 Csharp 代码。 string
method 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 “可刷新”
“Static”

JavaScriptFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/JavascriptUdf” ()
properties 与 JavaScript 函数关联的绑定属性。 JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

名称 说明
脚本 包含单个函数定义的 JavaScript 代码。 例如:'function (x, y) { return x + y; }' string

FunctionInput

名称 说明
dataType (Azure 流分析支持) 函数输入参数的数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx string
isConfigurationParameter 指示参数是否为配置参数的标志。 如果此输入参数应为常量,则为 True。 默认值为 false。 bool

FunctionOutput

名称 说明
dataType (Azure 流分析支持的函数输出) 数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx string

AggregateFunctionProperties

名称 说明 Value
type 指示函数的类型。 需要“聚合” ()

ScalarFunctionProperties

名称 说明 Value
type 指示函数的类型。 需要“标量” ()

输入

名称 说明
name 资源名称 string
properties 与输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 InputProperties

InputProperties

名称 说明
compression 介绍如何压缩输入数据 压缩
partitionKey partitionKey 描述输入数据中用于对输入数据进行分区的键 字符串
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求时是必需的。 序列化
watermarkSettings 确定是否读取水印事件的设置。 InputWatermarkProperties
类型 设置对象类型 引用
需要 ()

压缩

名称 说明 Value
type 指示输入使用的压缩类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Deflate”
“GZip”
“None” (必需)

序列化

名称 说明 Value
type 设置对象类型 Avro
Csv
CustomClr
增量
Json
需要 Parquet ()

AvroSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Avro” ()
properties 与 Avro 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 对于 Bicep,可以使用 any () 函数。

CsvSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Csv” ()
properties 与 CSV 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 CsvSerializationProperties

CsvSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求时是必需的。 'UTF8'
fieldDelimiter 指定用于分隔 CSV) 记录 (逗号分隔值的分隔符。 有关支持值的列表,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

CustomClrSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“CustomClr” ()
properties 与 CustomClr 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 CustomClrSerializationProperties

CustomClrSerializationProperties

名称 说明
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Delta” (必需)
properties 与 Delta Lake 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 DeltaSerializationProperties

DeltaSerializationProperties

名称 说明
deltaTablePath 指定输出将写入到的 Delta Lake 表的路径。 字符串 (必需)
partitionColumns 指定要为其分区 Delta Lake 表的列的名称。 我们仅支持 1 个分区列,但为了扩展性,请将其保留为数组。 string[]

JsonSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Json” ()
properties 与 JSON 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 JsonSerializationProperties

JsonSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求时是必需的。 'UTF8'
format 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定将写入输出的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出的格式将由新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果左为 null,则默认值为“lineSeparated”。 'Array'
'LineSeparated'

ParquetSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Parquet” (必需)
properties 与 Parquet 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 对于 Bicep,可以使用 any () 函数。

InputWatermarkProperties

名称 说明
watermarkMode 输入水印模式。 “None”
“ReadWatermark”

ReferenceInputProperties

名称 说明 Value
type 指示输入是引用数据还是流数据的源。 在 PUT (CreateOrReplace) 请求时是必需的。 “Reference” (必需)
datasource 描述包含引用数据的输入数据源。 在 PUT (CreateOrReplace) 请求时是必需的。 ReferenceInputDataSource

ReferenceInputDataSource

名称 说明 Value
type 设置对象类型 File
Microsoft.Sql/Server/Database
Microsoft.Storage/Blob
需要原始 ()

FileReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “File” (必需)
properties 与包含引用数据的文件输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 FileReferenceInputDataSourceProperties

FileReferenceInputDataSourceProperties

名称 说明 Value
path 文件的路径。 string

AzureSqlReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与包含引用数据的 SQL DB 输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSqlReferenceInputDataSourceProperties

AzureSqlReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database 此元素与 datasource 元素相关联。 这是要将输出写入到的数据库的名称。 字符串
deltaSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 string
fullSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 sql 数据库提取数据。 字符串
password 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的密码。 字符串

约束:
敏感值。 作为安全参数传入。
refreshRate 此元素与 datasource 元素相关联。 这表示从数据库提取数据的频率。 它采用 DateTime 格式。 string
refreshType 指示数据刷新选项的类型。 “RefreshPeriodicallyWithDelta”
'RefreshPeriodicallyWithFull'
“Static”
server 此元素与 datasource 元素相关联。 这是要写入到的数据库所在的服务器的名称。 字符串
user 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的用户名。 字符串

BlobReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Storage/Blob” ()
properties 与包含引用数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobName Blob 输入的名称。 字符串
container 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值都改为用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 blob 输入数据源快照增量的间隔。 字符串
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,将针对该模式匹配 Blob 名称,以确定它们是否应作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。 StorageAccount[]
timeFormat 时间格式。 无论 {time} 出现在 pathPattern 中的位置,此属性的值都改为用作时间格式。 字符串

RawReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“原始” ()
properties 与包含引用数据的原始输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 RawInputDatasourceProperties

RawInputDatasourceProperties

名称 说明
payload 输入数据的 JSON 序列化内容。 必须设置有效负载或 payloadUri,但不能同时设置两者。 string
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串

StreamInputProperties

名称 说明 Value
type 指示输入是引用数据源还是流数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 “Stream” (必需)
datasource 描述包含流数据的输入数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 StreamInputDataSource

StreamInputDataSource

名称 说明 Value
type 设置对象类型 GatewayMessageBus
Microsoft.Devices/IotHubs
Microsoft.EventGrid/EventSubscriptions
Microsoft.EventHub/EventHub
Microsoft.ServiceBus/EventHub
Microsoft.Storage/Blob
需要原始 ()

GatewayMessageBusStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “GatewayMessageBus” (必需)
properties 与包含流数据的网关消息总线输入关联的属性。 GatewayMessageBusStreamInputDataSourceProperties

GatewayMessageBusStreamInputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 字符串

IoTHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Devices/IotHubs” ()
properties 与包含流数据的IoT 中心输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

名称 说明
consumerGroupName 应用于从IoT 中心读取事件的IoT 中心使用者组的名称。 如果未指定,则输入将使用 Iot 中心的默认使用者组。 string
endpoint 用于连接到 (即 messages/events、messages/operationsMonitoringEvents 等IoT 中心终结点 ) 。 字符串
iotHubNamespace IoT 中心的名称或 URI。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

EventGridStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.EventGrid/EventSubscriptions” ()
properties 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties

EventGridStreamInputDataSourceProperties

名称 说明
eventTypes 事件网格适配器支持的事件类型列表。 string[]
schema 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。 StorageAccount[]
subscriber 事件网格的订阅服务器。 目前仅支持 EventHub 订阅服务器。 EventHubV2StreamInputDataSource

EventHubV2StreamInputDataSource

名称 说明
properties 与包含流数据的事件中心输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 EventHubStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串 (必需)

EventHubStreamInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
consumerGroupName 应用于从事件中心读取事件的事件中心使用者组的名称。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入将使用事件中心的默认使用者组。 字符串
eventHubName 事件中心的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
prefetchCount 消息接收方可以同时请求的消息数。 int
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求上是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。 字符串

EventHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.ServiceBus/EventHub” ()
properties 与包含流数据的事件中心输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 EventHubStreamInputDataSourceProperties

BlobStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Storage/Blob” ()
properties 与包含流数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
container 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求上是必需的。 string
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值都改为用作日期格式。 string
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,将针对该模式匹配 Blob 名称,以确定它们是否应作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 1024。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。 StorageAccount[]
timeFormat 时间格式。 无论 {time} 出现在 pathPattern 中的位置,此属性的值都改为用作时间格式。 字符串

RawStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“原始” ()
properties 与原始输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 RawInputDatasourceProperties

JobStorageAccount

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”

输出

名称 说明
name 资源名称 string
properties 与输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 OutputProperties

OutputProperties

名称 说明
datasource 描述将写入输出的数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 OutputDataSource
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。 序列化
sizeWindow 将流分析输出约束到的大小窗口。 int
timeWindow 筛选流分析作业输出的时间范围。 字符串
watermarkSettings 确定是否将水印发送到下游的设置。 OutputWatermarkProperties

OutputDataSource

名称 说明 Value
type 设置对象类型 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

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “GatewayMessageBus” (必需)
properties 与网关消息总线输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 GatewayMessageBusOutputDataSourceProperties

GatewayMessageBusOutputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 string

AzureFunctionOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.AzureFunction” ()
properties 与 Azure 函数输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureFunctionOutputDataSourceProperties

AzureFunctionOutputDataSourceProperties

名称 说明
apiKey 若要使用其他订阅中的 Azure 函数,可提供用于访问该函数的密钥。 字符串
functionAppName Azure Functions 应用的名称。 字符串
functionName Azure Functions 应用中的函数的名称。 字符串
maxBatchCount 一个用于指定发送到 Azure Functions 的每个批中的最大事件数的属性。 默认值为 100。 int
maxBatchSize 此属性可用于设置将发送到 Azure 函数的每个输出批的最大大小。 输入单元以字节为单位。 默认情况下,此值为 262,144 字节 (256 KB)。 int

AzureDataLakeStoreOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.DataLake/Accounts” ()
properties 与 Azure Data Lake Store 输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

名称 说明
accountName Azure Data Lake Store 帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dateFormat 日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值都改为用作日期格式。 字符串
filePathPrefix 输出应写入到的文件的位置。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
refreshToken 一个刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求上是必需的。 string
tenantId 用于获取刷新令牌的用户的租户 ID。 在 PUT (CreateOrReplace) 请求上是必需的。 string
timeFormat 时间格式。 无论 {time} 出现在 filePathPrefix 中的位置,此属性的值都改为用作时间格式。 string
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 字符串
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 字符串

PostgreSQLOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.DBForPostgreSQL/servers/databases” ()
properties 与 PostgreSQL 输出数据源关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 PostgreSQLOutputDataSourceProperties

PostgreSQLOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
server 包含Azure SQL数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

EventHubV2OutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Microsoft.EventHub/EventHub” (必需)
properties 与事件中心输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 EventHubOutputDataSourceProperties

EventHubOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
eventHubName 事件中心的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
partitionKey 用于确定将事件数据发送到哪个分区的键/列。 string
propertyColumns 与此事件中心输出关联的属性。 string[]
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求上是必需的。 字符串
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。 字符串

AzureDataExplorerOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Microsoft.Kusto/clusters/databases” (必需)
properties 与 Azure 数据资源管理器输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureDataExplorerOutputDataSourceProperties

AzureDataExplorerOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
cluster Azure 数据资源管理器群集的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
database Azure 数据资源管理器数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
Azure 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

EventHubOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.ServiceBus/EventHub” ()
properties 与事件中心输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 EventHubOutputDataSourceProperties

ServiceBusQueueOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.ServiceBus/Topic” ()
properties 与服务总线主题输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 ServiceBusTopicOutputDataSourceProperties

ServiceBusTopicOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
propertyColumns 要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 string[]
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。 字符串
systemPropertyColumns 与服务总线主题输出关联的系统属性。 支持以下系统属性:ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。 ServiceBusTopicOutputDataSourcePropertiesSystemPrope...
topicName 服务总线主题的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

名称 说明
{customized property} string

AzureSqlDatabaseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与Azure SQL数据库输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
maxBatchCount 写入 Sql 数据库的最大批处理计数,默认值为 10,000。 在 PUT 请求上是可选的。 int
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

AzureSynapseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Sql/Server/DataWarehouse” ()
properties 与Azure Synapse输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties

AzureSynapseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

BlobOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/Blob” (必需)
properties 与 Blob 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobPathPrefix Blob 路径前缀。 string
blobWriteMode Blob 写入模式。 “Append”
“一次”
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 string

DocumentDbOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Storage/DocumentDB” ()
properties 与 DocumentDB 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

名称 说明
accountId DocumentDB 帐户名称或 ID。 在 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) 请求时是必需的。 字符串
database DocumentDB 数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
documentId 输出事件中的字段的名称,该字段用于指定插入或更新操作所基于的主键。 string
partitionKey 输出事件中的字段的名称,该字段用于指定跨集合分区输出的键。 如果“collectionNamePattern”包含 {partition} 令牌,则需要指定此属性。 string

AzureTableOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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) 请求时是必需的。 string
Azure 表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string

PowerBIOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“PowerBI” ()
properties 与 Power BI 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 PowerBIOutputDataSourceProperties

PowerBIOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dataset Power BI 数据集的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
groupId Power BI 组的 ID。 字符串
groupName Power BI 组的名称。 使用此属性有助于记住使用了哪个特定的 Power BI 组 ID。 字符串
refreshToken 一个刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求上是必需的。 string
指定数据集下的 Power BI 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 string
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 字符串

RawOutputDatasource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“原始” ()
properties 与原始输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 RawOutputDatasourceProperties

RawOutputDatasourceProperties

名称 说明
payloadUri 应在其中写入输出的 Blob 的 SAS URL。 如果未设置此属性,输出数据将写入临时存储,结果中将包含该临时存储的 SAS URL。 字符串

OutputWatermarkProperties

名称 说明
maxWatermarkDifferenceAcrossPartitions 描述最快和最慢分区之间的最大增量,以便正确定义捕获下游作业中所有必要事件的无序窗口。 string
watermarkMode 输出水印模式。 “None”
“SendCurrentPartitionWatermark”
“SendLowestWatermarkAcrossPartitions”

SKU

名称 说明
容量 SKU 的容量。 int
name SKU 的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 “Standard”

转换

名称 说明
name 资源名称 string
properties 与转换关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 TransformationProperties

TransformationProperties

名称 说明
query 指定将在流式处理作业中运行的查询。 可以在此处详细了解流分析查询语言 (SAQL) : https://msdn.microsoft.com/library/azure/dn834998 。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
streamingUnits 指定流式处理作业使用的流单元数。 int
validStreamingUnits 指定流式处理作业可以缩放到的有效流单元。 int[]

快速入门模板

以下快速入门模板部署此资源类型。

模板 说明
创建标准流分析作业

部署到 Azure
此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一种实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)提取的信息中识别模式和关系。 这些模式可用于触发操作和启动工作流,例如创建警报、向报告工具馈送信息或存储转换后的数据以供以后使用。 此外,流分析可在 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"
  }

对于 Raw,请使用:

  "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"
  }

对于 Raw,请使用:

  "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"
  }

对于 Raw,请使用:

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

属性值

streamingjobs

名称 说明 Value
type 资源类型 “Microsoft.StreamAnalytics/streamingjobs”
apiVersion 资源 API 版本 “2021-10-01-preview”
name 资源名称 字符串 (必需)

字符限制:3-63

有效字符:
字母数字、连字符和下划线字符。
location 资源所在的地理位置 string
标记 资源标记。 标记名称和值的字典。 请参阅 模板中的标记
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求时是必需的。 Sku
标识 描述分配给此作业的托管标识,该标识可用于通过输入和输出进行身份验证。 标识
properties 与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 StreamingJobProperties

标识

名称 说明 Value
type 标识的类型可以是 SystemAssigned 或 UserAssigned。 string
userAssignedIdentities 与流式处理作业资源关联的用户分配的标识。 IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

名称 说明
{customized property}

StreamingJobProperties

名称 说明
cluster 将运行流式处理作业的群集。 ClusterInfo
compatibilityLevel 控制流式处理作业的某些运行时行为。 '1.0'
'1.2'
contentStoragePolicy 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则这要求用户同时指定 jobStorageAccount 属性。 . “JobStorageAccount”
“SystemAccount”
dataLocale 流分析作业的数据区域设置。 值应为集 https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110) .aspx 中支持的 .NET 区域性的名称。 如果未指定,则默认为“en-US”。 字符串
eventsLateArrivalMaxDelayInSeconds 可容忍的最大延迟(以秒为单位),其中可能包括迟到事件。 支持的范围为 -1 到 1814399(20.23:59:59 天),-1 用于指定无限期等待。 如果该属性不存在,则将其解释为具有值 -1。 int
eventsOutOfOrderMaxDelayInSeconds 可容许的最大延迟(以秒为单位),其中无序事件可重新调整为有序事件。 int
eventsOutOfOrderPolicy 指示要应用于输入事件流中未按顺序到达的事件的策略。 'Adjust'
'Drop'
外部 自定义代码项目所在的存储帐户。 外部
functions 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 Function[]
inputs 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,每个输入的名称属性是必需的。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输入的 PATCH API。 Input[]
jobStorageAccount 与具有 MSI 的 Azure 存储帐户关联的属性 JobStorageAccount
jobType 描述作业的类型。 有效模式为 Cloud 和 “Edge”。 “云”
'Edge'
outputErrorPolicy 指示要应用于到达输出但由于格式错误(缺少列值、列值类型或大小错误)而无法写入外部存储的事件的策略。 'Drop'
'Stop'
outputs 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输出的 PATCH API。 Output[]
outputStartMode 仅当需要作业在创建时立即启动时,才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示输出事件流的起点应每当作业启动时启动、从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上次事件输出时间开始。 'CustomTime'
“JobStartTime”
“LastOutputEventTime”
outputStartTime 值为采用 ISO-8601 格式的时间戳(指示输出事件流的起点),或者为 null(指示输出事件流将在每次启动流式处理作业时开始)。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 string
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求上是必需的。 Sku
转换 指示用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 转换

ClusterInfo

名称 说明 Value
id 群集的资源 ID。 字符串

外部

名称 说明
container UserCustomCode 容器。 字符串
path UserCustomCode 路径。 字符串
refreshConfiguration 作业配置中存在的任何/所有可更新用户定义函数的刷新参数。 RefreshConfiguration
storageAccount 与 Azure 存储帐户关联的属性 StorageAccount

RefreshConfiguration

名称 说明
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值都改为用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,将针对该模式匹配 Blob 名称,以确定它们是否应作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
refreshInterval 刷新间隔。 字符串
refreshType 此属性指示要使用的数据刷新选项“阻止”或“非阻止”。 “阻止”
“非阻止”
timeFormat 时间格式。 无论 {time} 出现在 pathPattern 中的位置,此属性的值都改为用作时间格式。 字符串

StorageAccount

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”

函数

名称 说明
name 资源名称 string
properties 与函数关联的属性。 FunctionProperties

FunctionProperties

名称 说明
properties FunctionConfiguration
类型 设置对象类型 聚合
需要标 ()

FunctionConfiguration

名称 说明
binding 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的示例中,此描述终结点。 FunctionBinding
inputs FunctionInput[]
输出 描述函数的输出。 FunctionOutput

FunctionBinding

名称 说明 Value
type 设置对象类型 Microsoft.MachineLearning/WebService
Microsoft.MachineLearningServices
Microsoft.StreamAnalytics/CLRUdf
Microsoft.StreamAnalytics/JavascriptUdf (必需)

AzureMachineLearningStudioFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 “Microsoft.MachineLearning/WebService” (必需)
properties 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties

AzureMachineLearningStudioFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 字符串
batchSize 介于 1 到 10000 之间的数字,用于描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习工作室的终结点。 在此处了解详细信息: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs string
inputs Azure 机器学习工作室终结点的输入。 AzureMachineLearningStudioInputs
outputs Azure 机器学习工作室终结点执行的输出列表。 AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputs

名称 说明
columnNames Azure 机器学习工作室终结点的输入列列表。 AzureMachineLearningStudioInputColumn[]
name 输入的名称。 这是创作终结点时提供的名称。 字符串

AzureMachineLearningStudioInputColumn

名称 说明
dataType (Azure 机器学习支持的) 输入列的数据类型。 有关有效 Azure 机器学习数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn905923.aspx string
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输入列的名称。 字符串

AzureMachineLearningStudioOutputColumn

名称 说明
dataType azure 机器学习支持的 () 输出列的数据类型。 有关有效 Azure 机器学习数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn905923.aspx string
name 输出列的名称。 字符串

AzureMachineLearningServiceFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 “Microsoft.MachineLearningServices” (必需)
properties 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties

AzureMachineLearningServiceFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 字符串
batchSize 介于 1 到 10000 之间的数字,用于描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习 Web 服务的终结点。 字符串
inputRequestName 输入请求对象的标签。 string
inputs Azure 机器学习 Web 服务终结点的输入。 AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests 将每个作业分区发送到机器学习服务的并行请求数。 默认值为 1。 int
outputResponseName 输出请求对象的标签。 string
outputs Azure 机器学习 Web 服务终结点执行的输出列表。 AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

名称 说明
dataType (Azure 机器学习支持的) 输入列的数据类型。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输入列的名称。 string

AzureMachineLearningServiceOutputColumn

名称 说明
dataType azure 机器学习支持的 () 输出列的数据类型。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输出列的名称。 字符串

CSharpFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/CLRUdf” ()
properties 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties

CSharpFunctionBindingProperties

名称 说明
class 包含单个函数定义的 Csharp 代码。 string
dllPath 包含单个函数定义的 Csharp 代码。 string
method 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 'Refreshable'
'Static'

JavaScriptFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/JavascriptUdf” ()
properties 与 JavaScript 函数关联的绑定属性。 JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

名称 说明
脚本 包含单个函数定义的 JavaScript 代码。 例如:'function (x, y) { return x + y; }' 字符串

FunctionInput

名称 说明
dataType (Azure 流分析支持) 函数输入参数的数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx 字符串
isConfigurationParameter 指示参数是否为配置参数的标志。 如果此输入参数应为常量,则其值为 True。 默认值为 false。 bool

FunctionOutput

名称 说明
dataType (支持的 Azure 流分析) 函数输出的数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx string

AggregateFunctionProperties

名称 说明 Value
type 指示函数的类型。 “聚合” (必需)

ScalarFunctionProperties

名称 说明 Value
type 指示函数的类型。 “Scalar” (必需)

输入

名称 说明
name 资源名称 string
properties 与输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 InputProperties

InputProperties

名称 说明
compression 介绍如何压缩输入数据 压缩
partitionKey partitionKey 描述输入数据中用于对输入数据进行分区的键 字符串
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。 序列化
watermarkSettings 用于确定是否读取水印事件的设置。 InputWatermarkProperties
类型 设置对象类型 引用
所需的 ()

压缩

名称 说明 Value
type 指示输入使用的压缩类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Deflate”
“GZip”
“None” (必需)

序列化

名称 说明 Value
type 设置对象类型 Avro
Csv
CustomClr
增量
Json
需要 Parquet ()

AvroSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Avro” (必需)
properties 与 Avro 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。

CsvSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Csv” (必需)
properties 与 CSV 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 CsvSerializationProperties

CsvSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求上是必需的。 “UTF8”
fieldDelimiter 指定用于分隔 CSV) 记录 (逗号分隔值的分隔符。 有关支持值的列表,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

CustomClrSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “CustomClr” (必需)
properties 与 CustomClr 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 CustomClrSerializationProperties

CustomClrSerializationProperties

名称 说明
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Delta” (必需)
properties 与 Delta Lake 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 DeltaSerializationProperties

DeltaSerializationProperties

名称 说明
deltaTablePath 指定要写入输出的 Delta Lake 表的路径。 字符串 (必需)
partitionColumns 指定要为其分区 Delta Lake 表的列的名称。 我们仅支持 1 个分区列,但为了扩展性,请将其保留为数组。 string[]

JsonSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Json” (必需)
properties 与 JSON 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 JsonSerializationProperties

JsonSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求上是必需的。 “UTF8”
format 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定将写入输出的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出的格式将由新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果为 null,则默认值为“lineSeparated”。 “Array”
“LineSeparated”

ParquetSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Parquet” (必需)
properties 与 Parquet 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。

InputWatermarkProperties

名称 说明
watermarkMode 输入水印模式。 “None”
“ReadWatermark”

ReferenceInputProperties

名称 说明 Value
type 指示输入是引用数据源还是流数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 “Reference” (必需)
datasource 描述包含引用数据的输入数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 ReferenceInputDataSource

ReferenceInputDataSource

名称 说明 Value
type 设置对象类型 File
Microsoft.Sql/Server/Database
Microsoft.Storage/Blob
需要原始 ()

FileReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “File” (必需)
properties 与包含引用数据的文件输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 FileReferenceInputDataSourceProperties

FileReferenceInputDataSourceProperties

名称 说明 Value
path 文件的路径。 字符串

AzureSqlReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与包含引用数据的 SQL DB 输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureSqlReferenceInputDataSourceProperties

AzureSqlReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database 此元素与 datasource 元素相关联。 这是要将输出写入到的数据库的名称。 string
deltaSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 字符串
fullSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 sql 数据库提取数据。 字符串
password 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的密码。 字符串

约束:
敏感值。 作为安全参数传入。
refreshRate 此元素与 datasource 元素相关联。 这表示从数据库提取数据的频率。 它采用 DateTime 格式。 字符串
refreshType 指示数据刷新选项的类型。 “RefreshPeriodicallyWithDelta”
'RefreshPeriodicallyWithFull'
'Static'
server 此元素与 datasource 元素相关联。 这是要写入到的数据库所在的服务器的名称。 字符串
user 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的用户名。 字符串

BlobReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/Blob” (必需)
properties 与包含引用数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobName Blob 输入的名称。 string
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 blob 输入数据源的增量快照的时间间隔。 string
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output string
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 string

RawReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“原始” ()
properties 与包含引用数据的原始输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties

RawInputDatasourceProperties

名称 说明
payload 输入数据的 JSON 序列化内容。 必须设置 payload 或 payloadUri,但不能同时设置两者。 string
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置 payload 或 payloadUri,但不能同时设置两者。 string

StreamInputProperties

名称 说明 Value
type 指示输入是引用数据还是流数据的源。 在 PUT (CreateOrReplace) 请求时是必需的。 “Stream” (必需)
datasource 描述包含流数据的输入数据源。 在 PUT (CreateOrReplace) 请求时是必需的。 StreamInputDataSource

StreamInputDataSource

名称 说明 Value
type 设置对象类型 GatewayMessageBus
Microsoft.Devices/IotHubs
Microsoft.EventGrid/EventSubscriptions
Microsoft.EventHub/EventHub
Microsoft.ServiceBus/EventHub
Microsoft.Storage/Blob
需要原始 ()

GatewayMessageBusStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“GatewayMessageBus” ()
properties 与包含流数据的网关消息总线输入关联的属性。 GatewayMessageBusStreamInputDataSourceProperties

GatewayMessageBusStreamInputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 string

IoTHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Devices/IotHubs” ()
properties 与包含流数据的IoT 中心输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

名称 说明
consumerGroupName 应用于从IoT 中心读取事件的IoT 中心使用者组的名称。 如果未指定,则输入将使用 IoT 中心的默认使用者组。 string
endpoint 用于连接到 (的IoT 中心终结点,即 messages/events、messages/operationsMonitoringEvents 等 ) 。 string
iotHubNamespace IoT 中心的名称或 URI。 在 PUT (CreateOrReplace) 请求时是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 在 PUT (CreateOrReplace) 请求时是必需的。 string

EventGridStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.EventGrid/EventSubscriptions” (必需)
properties 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties

EventGridStreamInputDataSourceProperties

名称 说明
eventTypes 事件网格适配器支持的事件类型列表。 string[]
schema 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
subscriber 事件网格的订阅服务器。 目前仅支持 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) 请求时是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。 字符串

EventHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub” (必需)
properties 与包含流数据的事件中心输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 EventHubStreamInputDataSourceProperties

BlobStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/Blob” (必需)
properties 与包含流数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 string
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 1024。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 string

RawStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“原始” ()
properties 与原始输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties

JobStorageAccount

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”

输出

名称 说明
name 资源名称 string
properties 与输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 OutputProperties

OutputProperties

名称 说明
datasource 描述输出将写入到的数据源。 在 PUT (CreateOrReplace) 请求时是必需的。 OutputDataSource
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求时是必需的。 序列化
sizeWindow 要限制流分析输出的大小窗口。 int
timeWindow 筛选流分析作业输出的时间范围。 字符串
watermarkSettings 确定是否将水印发送到下游的设置。 OutputWatermarkProperties

OutputDataSource

名称 说明 Value
type 设置对象类型 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

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “GatewayMessageBus” (必需)
properties 与网关消息总线输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 GatewayMessageBusOutputDataSourceProperties

GatewayMessageBusOutputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 字符串

AzureFunctionOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.AzureFunction” ()
properties 与 Azure 函数输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureFunctionOutputDataSourceProperties

AzureFunctionOutputDataSourceProperties

名称 说明
apiKey 若要使用其他订阅中的 Azure 函数,可提供用于访问该函数的密钥。 字符串
functionAppName Azure Functions 应用的名称。 字符串
functionName Azure Functions 应用中的函数的名称。 字符串
maxBatchCount 一个用于指定发送到 Azure Functions 的每个批中的最大事件数的属性。 默认值为 100。 int
maxBatchSize 此属性可用于设置将发送到 Azure 函数的每个输出批的最大大小。 输入单元以字节为单位。 默认情况下,此值为 262,144 字节 (256 KB)。 int

AzureDataLakeStoreOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.DataLake/Accounts” ()
properties 与 Azure Data Lake Store 输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

名称 说明
accountName Azure Data Lake Store 帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dateFormat 日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值都改为用作日期格式。 字符串
filePathPrefix 输出应写入到的文件的位置。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
refreshToken 一个刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求上是必需的。 string
tenantId 用于获取刷新令牌的用户的租户 ID。 在 PUT (CreateOrReplace) 请求时是必需的。 string
timeFormat 时间格式。 只要 {time} 出现在 filePathPrefix 中,此属性的值就用作时间格式。 字符串
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住使用哪个用户获取刷新令牌。 string
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性有助于记住使用哪个用户获取刷新令牌。 字符串

PostgreSQLOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DBForPostgreSQL/servers/databases” (必需)
properties 与 PostgreSQL 输出数据源关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 PostgreSQLOutputDataSourceProperties

PostgreSQLOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

EventHubV2OutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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) 请求上是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。 string

AzureDataExplorerOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Microsoft.Kusto/clusters/databases” (必需)
properties 与 Azure 数据资源管理器输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureDataExplorerOutputDataSourceProperties

AzureDataExplorerOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
cluster Azure 数据资源管理器群集的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
database Azure 数据资源管理器数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
Azure 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

EventHubOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.ServiceBus/EventHub” ()
properties 与事件中心输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 EventHubOutputDataSourceProperties

ServiceBusQueueOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.ServiceBus/Queue” ()
properties 与服务总线队列输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 ServiceBusQueueOutputDataSourceProperties

ServiceBusQueueOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
propertyColumns 要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 string[]
queueName 服务总线队列的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求上是必需的。 字符串
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。 字符串
systemPropertyColumns 与服务总线队列关联的系统属性。 支持以下系统属性:ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。

ServiceBusTopicOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.ServiceBus/Topic” ()
properties 与服务总线主题输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 ServiceBusTopicOutputDataSourceProperties

ServiceBusTopicOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
propertyColumns 要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 string[]
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。 string
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。 字符串
systemPropertyColumns 与服务总线主题输出关联的系统属性。 支持以下系统属性:ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。 ServiceBusTopicOutputDataSourcePropertiesSystemPrope...
topicName 服务总线主题的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

名称 说明
{customized property} 字符串

AzureSqlDatabaseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与Azure SQL数据库输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxBatchCount 写入 Sql 数据库的最大批处理计数,默认值为 10,000。 在 PUT 请求上是可选的。 int
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

AzureSynapseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Sql/Server/DataWarehouse” ()
properties 与Azure Synapse输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties

AzureSynapseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

BlobOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/Blob” (必需)
properties 与 Blob 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobPathPrefix Blob 路径前缀。 字符串
blobWriteMode Blob 写入模式。 “Append”
“一次”
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 字符串

DocumentDbOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Storage/DocumentDB” ()
properties 与 DocumentDB 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

名称 说明
accountId DocumentDB 帐户名称或 ID。 在 PUT (CreateOrReplace) 请求时是必需的。 string
accountKey DocumentDB 帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
collectionNamePattern 要使用的集合的集合名称模式。 可以使用可选的 {partition} 令牌(其中分区从 0 开始)构造集合名称格式。 有关详细信息,请参阅 的 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output DocumentDB 部分。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
database DocumentDB 数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
documentId 输出事件中的字段的名称,该字段用于指定插入或更新操作所基于的主键。 string
partitionKey 输出事件中的字段的名称,该字段用于指定跨集合分区输出的键。 如果“collectionNamePattern”包含 {partition} 令牌,则需要指定此属性。 字符串

AzureTableOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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) 请求时是必需的。 string
rowKey 此元素指示查询中 SELECT 语句中的列名称,该列将用作 Azure 表的行键。 在 PUT (CreateOrReplace) 请求时是必需的。 string
Azure 表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

PowerBIOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“PowerBI” ()
properties 与 Power BI 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 PowerBIOutputDataSourceProperties

PowerBIOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dataset Power BI 数据集的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
groupId Power BI 组的 ID。 string
groupName Power BI 组的名称。 使用此属性有助于记住使用的特定 Power BI 组 ID。 string
refreshToken 刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
指定数据集下的 Power BI 表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住使用哪个用户获取刷新令牌。 字符串
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性有助于记住使用哪个用户获取刷新令牌。 字符串

RawOutputDatasource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“原始” ()
properties 与原始输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 RawOutputDatasourceProperties

RawOutputDatasourceProperties

名称 说明
payloadUri 应在其中写入输出的 Blob 的 SAS URL。 如果未设置此属性,输出数据将写入临时存储,结果中将包含该临时存储的 SAS URL。 字符串

OutputWatermarkProperties

名称 说明
maxWatermarkDifferenceAcrossPartitions 描述最快和最慢分区之间的最大增量,以便很好地定义了捕获下游作业中所有必要事件的无序窗口。 字符串
watermarkMode 输出水印模式。 “None”
'SendCurrentPartitionWatermark'
“SendLowestWatermarkAcrossPartitions”

SKU

名称 说明
容量 SKU 的容量。 int
name SKU 的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 'Standard'

转换

名称 说明
name 资源名称 string
properties 与转换关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 TransformationProperties

TransformationProperties

名称 说明
查询 指定将在流式处理作业中运行的查询。 可在此处详细了解流分析查询语言 (SAQL) : https://msdn.microsoft.com/library/azure/dn834998 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
streamingUnits 指定流式处理作业使用的流单元数。 int
validStreamingUnits 指定流式处理作业可以缩放到的有效流单元。 int[]

快速入门模板

以下快速入门模板部署此资源类型。

模板 说明
创建标准流分析作业

部署到 Azure
此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流式处理数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)提取的信息中识别模式和关系。 这些模式可用于触发操作和启动工作流,例如创建警报、向报告工具馈送信息或存储转换后的数据以供以后使用。 此外,流分析可在 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"
  }

对于 Raw,请使用:

  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"
  }

对于 Raw,请使用:

  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"
  }

对于 Raw,请使用:

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

属性值

streamingjobs

名称 说明 Value
type 资源类型 “Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview”
name 资源名称 字符串 (必需)

字符限制:3-63

有效字符:
字母数字、连字符和下划线字符。
location 资源所在的地理位置 string
parent_id 若要部署到资源组,请使用该资源组的 ID。 字符串 (必需)
标记 资源标记。 标记名称和值的字典。
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求上是必需的。 Sku
标识 描述分配给此作业的托管标识,该标识可用于通过输入和输出进行身份验证。 标识
properties 与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 StreamingJobProperties

标识

名称 说明 Value
type 标识的类型可以是 SystemAssigned 或 UserAssigned。 字符串
identity_ids 用户分配的标识与流式处理作业资源相关联。 用户标识 ID 数组。

IdentityUserAssignedIdentities

名称 说明
{customized property}

StreamingJobProperties

名称 说明
cluster 将运行流式处理作业的群集。 ClusterInfo
compatibilityLevel 控制流式处理作业的某些运行时行为。 "1.0"
"1.2"
contentStoragePolicy 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则要求用户同时指定 jobStorageAccount 属性。 . “JobStorageAccount”
“SystemAccount”
dataLocale 流分析作业的数据区域设置。 值应为集 https://msdn.microsoft.com/library/system.globalization.culturetypes(v=vs.110) .aspx 中支持的 .NET 区域性的名称。 如果未指定,则默认为“en-US”。 字符串
eventsLateArrivalMaxDelayInSeconds 可容忍的最大延迟(以秒为单位),其中可能包括迟到事件。 支持的范围为 -1 到 1814399(20.23:59:59 天),-1 用于指定无限期等待。 如果该属性不存在,则将其解释为具有值 -1。 int
eventsOutOfOrderMaxDelayInSeconds 可容许的最大延迟(以秒为单位),其中无序事件可重新调整为有序事件。 int
eventsOutOfOrderPolicy 指示要应用于输入事件流中未按顺序到达的事件的策略。 “Adjust”
“Drop”
外部 自定义代码项目所在的存储帐户。 外部
functions 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 Function[]
inputs 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,每个输入的名称属性是必需的。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输入的 PATCH API。 Input[]
jobStorageAccount 与具有 MSI 的 Azure 存储帐户关联的属性 JobStorageAccount
jobType 描述作业的类型。 有效模式为 Cloud 和 “Edge”。 “云”
“Edge”
outputErrorPolicy 指示要应用于到达输出但由于格式错误(缺少列值、列值类型或大小错误)而无法写入外部存储的事件的策略。 “Drop”
"Stop"
outputs 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个输出的 PATCH API。 Output[]
outputStartMode 仅当需要作业在创建时立即启动时才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示输出事件流的起点应在作业每次启动时启动、从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上次事件输出时间开始。 “CustomTime”
“JobStartTime”
“LastOutputEventTime”
outputStartTime 值为采用 ISO-8601 格式的时间戳(指示输出事件流的起点),或者为 null(指示输出事件流将在每次启动流式处理作业时开始)。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 字符串
sku 描述流式处理作业的 SKU。 在 PUT (CreateOrReplace) 请求时是必需的。 Sku
转换 指示要用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的名称属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。 转换

ClusterInfo

名称 说明 Value
id 群集的资源 ID。 字符串

外部

名称 说明
container UserCustomCode 容器。 string
path UserCustomCode 路径。 字符串
refreshConfiguration 作业配置中存在的任何/所有可更新用户定义函数的刷新参数。 RefreshConfiguration
storageAccount 与 Azure 存储帐户关联的属性 StorageAccount

RefreshConfiguration

名称 说明
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://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 资源名称 string
properties 与函数关联的属性。 FunctionProperties

FunctionProperties

名称 说明
properties FunctionConfiguration
类型 设置对象类型 聚合
需要标 ()

FunctionConfiguration

名称 说明
binding 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的情况下,它描述了终结点。 FunctionBinding
inputs FunctionInput[]
output 描述函数的输出。 FunctionOutput

FunctionBinding

名称 说明 Value
type 设置对象类型 Microsoft.MachineLearning/WebService
Microsoft.MachineLearningServices
Microsoft.StreamAnalytics/CLRUdf
需要 Microsoft.StreamAnalytics/JavascriptUdf ()

AzureMachineLearningStudioFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 “Microsoft.MachineLearning/WebService” (必需)
properties 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties

AzureMachineLearningStudioFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 字符串
batchSize 数字介于 1 和 10000 之间,描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习工作室的终结点。 在此处了解详细信息: https://docs.microsoft.com/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs string
inputs 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 输入列的名称。 string

AzureMachineLearningStudioOutputColumn

名称 说明
dataType Azure 机器学习支持的 () 输出列的数据类型。 有关有效 Azure 机器学习数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn905923.aspx string
name 输出列的名称。 字符串

AzureMachineLearningServiceFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 “Microsoft.MachineLearningServices” (必需)
properties 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties

AzureMachineLearningServiceFunctionBindingProperties

名称 说明
apiKey 用于对 Request-Response 终结点进行身份验证的 API 密钥。 字符串
batchSize 介于 1 到 10000 之间的数字,用于描述每个 Azure ML RRS 执行请求的最大行数。 默认值为 1000。 int
endpoint Request-Response 执行 Azure 机器学习 Web 服务的终结点。 字符串
inputRequestName 输入请求对象的标签。 字符串
inputs Azure 机器学习 Web 服务终结点的输入。 AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests 将每个作业分区发送到机器学习服务的并行请求数。 默认值为 1。 int
outputResponseName 输出请求对象的标签。 string
outputs Azure 机器学习 Web 服务终结点执行的输出列表。 AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

名称 说明
dataType (Azure 机器学习支持的) 输入列的数据类型。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输入列的名称。 字符串

AzureMachineLearningServiceOutputColumn

名称 说明
dataType azure 机器学习支持的 () 输出列的数据类型。 string
mapTo 此输入映射到的函数参数的从零开始的索引。 int
name 输出列的名称。 字符串

CSharpFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/CLRUdf” ()
properties 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties

CSharpFunctionBindingProperties

名称 说明
class 包含单个函数定义的 Csharp 代码。 字符串
dllPath 包含单个函数定义的 Csharp 代码。 string
method 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 “Refreshable”
“Static”

JavaScriptFunctionBinding

名称 说明 Value
type 指示函数绑定类型。 需要“Microsoft.StreamAnalytics/JavascriptUdf” ()
properties 与 JavaScript 函数关联的绑定属性。 JavaScriptFunctionBindingProperties

JavaScriptFunctionBindingProperties

名称 说明
脚本 包含单个函数定义的 JavaScript 代码。 例如:'function (x, y) { return x + y; }' 字符串

FunctionInput

名称 说明
dataType (Azure 流分析支持) 函数输入参数的数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx string
isConfigurationParameter 指示参数是否为配置参数的标志。 如果此输入参数应为常量,则其值为 True。 默认值为 false。 bool

FunctionOutput

名称 说明
dataType (支持的 Azure 流分析) 函数输出的数据类型。 有关有效 Azure 流分析数据类型的列表,请参阅 https://msdn.microsoft.com/library/azure/dn835065.aspx string

AggregateFunctionProperties

名称 说明 Value
type 指示函数的类型。 “聚合” (必需)

ScalarFunctionProperties

名称 说明 Value
type 指示函数的类型。 需要“标量” ()

输入

名称 说明
name 资源名称 string
properties 与输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 InputProperties

InputProperties

名称 说明
compression 介绍如何压缩输入数据 压缩
partitionKey partitionKey 描述输入数据中用于对输入数据进行分区的键 字符串
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。 序列化
watermarkSettings 用于确定是否读取水印事件的设置。 InputWatermarkProperties
类型 设置对象类型 引用
所需的 ()

压缩

名称 说明 Value
type 指示输入使用的压缩类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Deflate”
“GZip”
“None” (必需)

序列化

名称 说明 Value
type 设置对象类型 Avro
Csv
CustomClr
增量
Json
需要 Parquet ()

AvroSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Avro” ()
properties 与 Avro 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。

CsvSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Csv” (必需)
properties 与 CSV 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 CsvSerializationProperties

CsvSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求时是必需的。 “UTF8”
fieldDelimiter 指定用于分隔 CSV) 记录 (逗号分隔值的分隔符。 有关支持值的列表,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

CustomClrSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “CustomClr” (必需)
properties 与 CustomClr 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 CustomClrSerializationProperties

CustomClrSerializationProperties

名称 说明
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Delta” (必需)
properties 与 Delta Lake 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 DeltaSerializationProperties

DeltaSerializationProperties

名称 说明
deltaTablePath 指定输出将写入到的 Delta Lake 表的路径。 字符串 (必需)
partitionColumns 指定要为其分区 Delta Lake 表的列的名称。 我们仅支持 1 个分区列,但为了扩展性,请将其保留为数组。 string[]

JsonSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Json” (必需)
properties 与 JSON 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 JsonSerializationProperties

JsonSerializationProperties

名称 说明
encoding 指定输入时传入数据的编码,在输出的情况下指定传出数据的编码。 在 PUT (CreateOrReplace) 请求时是必需的。 “UTF8”
format 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定将写入输出的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出的格式将由新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果为 null,则默认值为“lineSeparated”。 “Array”
“LineSeparated”

ParquetSerialization

名称 说明 Value
type 指示输入或输出使用的序列化类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Parquet” (必需)
properties 与 Parquet 序列化类型关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。

InputWatermarkProperties

名称 说明
watermarkMode 输入水印模式。 "None"
“ReadWatermark”

ReferenceInputProperties

名称 说明 Value
type 指示输入是引用数据源还是流数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 “参考” (必需)
datasource 描述包含引用数据的输入数据源。 在 PUT (CreateOrReplace) 请求上是必需的。 ReferenceInputDataSource

ReferenceInputDataSource

名称 说明 Value
type 设置对象类型 File
Microsoft.Sql/Server/Database
Microsoft.Storage/Blob
需要原始 ()

FileReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “文件” (必需)
properties 与包含引用数据的文件输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 FileReferenceInputDataSourceProperties

FileReferenceInputDataSourceProperties

名称 说明 Value
path 文件的路径。 string

AzureSqlReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与包含引用数据的 SQL DB 输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureSqlReferenceInputDataSourceProperties

AzureSqlReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database 此元素与 datasource 元素相关联。 这是要将输出写入到的数据库的名称。 字符串
deltaSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 string
fullSnapshotQuery 此元素与 datasource 元素相关联。 此查询用于从 sql 数据库提取数据。 字符串
password 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的密码。 字符串

约束:
敏感值。 作为安全参数传入。
refreshRate 此元素与 datasource 元素相关联。 这表示从数据库提取数据的频率。 它是 DateTime 格式。 string
refreshType 指示数据刷新选项的类型。 “RefreshPeriodicallyWithDelta”
“RefreshPeriodicallyWithFull”
“Static”
server 此元素与 datasource 元素相关联。 这是要写入到的数据库所在的服务器的名称。 字符串
user 此元素与 datasource 元素相关联。 这是用于连接 SQL Database 实例的用户名。 字符串

BlobReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Microsoft.Storage/Blob” (必需)
properties 与包含引用数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 BlobReferenceInputDataSourceProperties

BlobReferenceInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobName Blob 输入的名称。 string
container 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值都改为用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 blob 输入数据源快照增量的间隔。 字符串
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,将针对该模式匹配 Blob 名称,以确定它们是否应作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output string
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。 StorageAccount[]
timeFormat 时间格式。 无论 {time} 出现在 pathPattern 中的位置,此属性的值都改为用作时间格式。 string

RawReferenceInputDataSource

名称 说明 Value
type 指示包含引用数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 所需的“原始” ()
properties 与包含引用数据的原始输入关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 RawInputDatasourceProperties

RawInputDatasourceProperties

名称 说明
payload 输入数据的 JSON 序列化内容。 必须设置 payload 或 payloadUri,但不能同时设置两者。 字符串
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置 payload 或 payloadUri,但不能同时设置两者。 string

StreamInputProperties

名称 说明 Value
type 指示输入是引用数据还是流数据的源。 在 PUT (CreateOrReplace) 请求时是必需的。 “Stream” (必需)
datasource 描述包含流数据的输入数据源。 在 PUT (CreateOrReplace) 请求时是必需的。 StreamInputDataSource

StreamInputDataSource

名称 说明 Value
type 设置对象类型 GatewayMessageBus
Microsoft.Devices/IotHubs
Microsoft.EventGrid/EventSubscriptions
Microsoft.EventHub/EventHub
Microsoft.ServiceBus/EventHub
Microsoft.Storage/Blob
需要原始 ()

GatewayMessageBusStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“GatewayMessageBus” ()
properties 与包含流数据的网关消息总线输入关联的属性。 GatewayMessageBusStreamInputDataSourceProperties

GatewayMessageBusStreamInputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 string

IoTHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Devices/IotHubs” ()
properties 与包含流数据的IoT 中心输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 IoTHubStreamInputDataSourceProperties

IoTHubStreamInputDataSourceProperties

名称 说明
consumerGroupName 应用于从IoT 中心读取事件的IoT 中心使用者组的名称。 如果未指定,则输入将使用 IoT 中心的默认使用者组。 string
endpoint 用于连接到 (的IoT 中心终结点,即 messages/events、messages/operationsMonitoringEvents 等 ) 。 字符串
iotHubNamespace IoT 中心的名称或 URI。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 在 PUT (CreateOrReplace) 请求时是必需的。 string

EventGridStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.EventGrid/EventSubscriptions” ()
properties 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties

EventGridStreamInputDataSourceProperties

名称 说明
eventTypes 事件网格适配器支持的事件类型列表。 string[]
schema 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
subscriber 事件网格的订阅服务器。 目前仅支持 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) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。 string

EventHubStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub” (必需)
properties 与包含流数据的事件中心输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 EventHubStreamInputDataSourceProperties

BlobStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Storage/Blob” ()
properties 与包含流数据的 Blob 输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobStreamInputDataSourceProperties

BlobStreamInputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 1024。 int
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 只要 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 字符串

RawStreamInputDataSource

名称 说明 Value
type 指示包含流数据的输入数据源的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“原始” ()
properties 与原始输入关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties

JobStorageAccount

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”

输出

名称 说明
name 资源名称 string
properties 与输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 OutputProperties

OutputProperties

名称 说明
datasource 描述输出将写入到的数据源。 在 PUT (CreateOrReplace) 请求时是必需的。 OutputDataSource
序列化 描述如何序列化输入中的数据,或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求时是必需的。 序列化
sizeWindow 要限制流分析输出的大小窗口。 int
timeWindow 筛选流分析作业输出的时间范围。 字符串
watermarkSettings 确定是否将水印发送到下游的设置。 OutputWatermarkProperties

OutputDataSource

名称 说明 Value
type 设置对象类型 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

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“GatewayMessageBus” ()
properties 与网关消息总线输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 GatewayMessageBusOutputDataSourceProperties

GatewayMessageBusOutputDataSourceProperties

名称 说明
主题 服务总线主题的名称。 字符串

AzureFunctionOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.AzureFunction” (必需)
properties 与 Azure 函数输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureFunctionOutputDataSourceProperties

AzureFunctionOutputDataSourceProperties

名称 说明
apiKey 若要使用其他订阅中的 Azure 函数,可提供用于访问该函数的密钥。 字符串
functionAppName Azure Functions 应用的名称。 字符串
functionName Azure Functions 应用中的函数的名称。 字符串
maxBatchCount 一个用于指定发送到 Azure Functions 的每个批中的最大事件数的属性。 默认值为 100。 int
maxBatchSize 此属性可用于设置将发送到 Azure 函数的每个输出批的最大大小。 输入单元以字节为单位。 默认情况下,此值为 262,144 字节 (256 KB)。 int

AzureDataLakeStoreOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DataLake/Accounts” (必需)
properties 与 Azure Data Lake Store 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureDataLakeStoreOutputDataSourceProperties

AzureDataLakeStoreOutputDataSourceProperties

名称 说明
accountName Azure Data Lake Store 帐户的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dateFormat 日期格式。 只要 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 字符串
filePathPrefix 输出应写入到的文件的位置。 在 PUT (CreateOrReplace) 请求时是必需的。 string
refreshToken 刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求时是必需的。 string
tenantId 用于获取刷新令牌的用户的租户 ID。 在 PUT (CreateOrReplace) 请求时是必需的。 string
timeFormat 时间格式。 只要 {time} 出现在 filePathPrefix 中,此属性的值就用作时间格式。 字符串
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住使用哪个用户获取刷新令牌。 string
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性有助于记住使用哪个用户获取刷新令牌。 string

PostgreSQLOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DBForPostgreSQL/servers/databases” (必需)
properties 与 PostgreSQL 输出数据源关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 PostgreSQLOutputDataSourceProperties

PostgreSQLOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 string

EventHubV2OutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.EventHub/EventHub” ()
properties 与事件中心输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 EventHubOutputDataSourceProperties

EventHubOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
eventHubName 事件中心的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
partitionKey 用于确定将事件数据发送到哪个分区的键/列。 string
propertyColumns 与此事件中心输出关联的属性。 string[]
serviceBusNamespace 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。 字符串
sharedAccessPolicyKey 指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。 string

AzureDataExplorerOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Kusto/clusters/databases” ()
properties 与 Azure 数据资源管理器输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureDataExplorerOutputDataSourceProperties

AzureDataExplorerOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
cluster Azure 数据资源管理器群集的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
database Azure 数据资源管理器 数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
Azure 表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

EventHubOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub” (必需)
properties 与事件中心输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 EventHubOutputDataSourceProperties

ServiceBusQueueOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
sharedAccessPolicyName 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。 字符串
systemPropertyColumns 与服务总线队列关联的系统属性。 支持以下系统属性:ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。

ServiceBusTopicOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 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) 请求上是必需的。 string

ServiceBusTopicOutputDataSourcePropertiesSystemPrope...

名称 说明
{customized property} 字符串

AzureSqlDatabaseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Sql/Server/Database” ()
properties 与Azure SQL数据库输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureSqlDatabaseOutputDataSourceProperties

AzureSqlDatabaseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
maxBatchCount 写入 Sql 数据库的最大批处理计数,默认值为 10,000。 在 PUT 请求上是可选的。 int
maxWriterCount 最大编写器计数,目前只有 1 个 (个编写器) 和 0 个基于查询分区) 的 (可用。 在 PUT 请求上是可选的。 int
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
server 包含Azure SQL数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 string

AzureSynapseOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Sql/Server/DataWarehouse” (必需)
properties 与Azure Synapse输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties

AzureSynapseOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
database Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 string
password 将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。 string

约束:
敏感值。 作为安全参数传入。
server 包含 Azure SQL 数据库的 SQL 服务器的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
Azure SQL 数据库中表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
user 将用于连接到Azure SQL数据库的用户名。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串

BlobOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求时是必需的。 需要“Microsoft.Storage/Blob” ()
properties 与 Blob 输出关联的属性。 在 PUT (CreateOrReplace) 请求时是必需的。 BlobOutputDataSourceProperties

BlobOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
blobPathPrefix Blob 路径前缀。 字符串
blobWriteMode Blob 写入模式。 “Append”
“一次”
container 关联存储帐户中容器的名称。 此容器包含要读取或写入的 blob () 。 在 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 只要 {date} 出现在 pathPattern 中,此属性的值就用作日期格式。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示一种模式,根据该模式匹配 Blob 名称,以确定是否应将其作为输入或输出包含在作业中。 有关更详细的说明和示例,请参阅 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-inputhttps://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 字符串
storageAccounts 一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
timeFormat 时间格式。 无论 {time} 出现在 pathPattern 中的位置,此属性的值都改为用作时间格式。 字符串

DocumentDbOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“Microsoft.Storage/DocumentDB” ()
properties 与 DocumentDB 输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 DocumentDbOutputDataSourceProperties

DocumentDbOutputDataSourceProperties

名称 说明
accountId DocumentDB 帐户名称或 ID。 在 PUT (CreateOrReplace) 请求上是必需的。 string
accountKey DocumentDB 帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
collectionNamePattern 要使用的集合的集合名称模式。 可以使用可选的 {partition} 令牌(其中分区从 0 开始)构造集合名称格式。 有关详细信息,请参阅 的 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output DocumentDB 部分。 在 PUT (CreateOrReplace) 请求上是必需的。 string
database DocumentDB 数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
documentId 输出事件中的字段的名称,该字段用于指定插入或更新操作所基于的主键。 string
partitionKey 输出事件中的字段的名称,该字段用于指定跨集合分区输出的键。 如果“collectionNamePattern”包含 {partition} 令牌,则需要指定此属性。 string

AzureTableOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 “Microsoft.Storage/Table” (必需)
properties 与 Azure 表输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 AzureTableOutputDataSourceProperties

AzureTableOutputDataSourceProperties

名称 说明
accountKey Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

约束:
敏感值。 作为安全参数传入。
accountName Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 string
batchSize 一次写入 Azure 表的行数。 int
columnsToRemove 如果已指定,则数组中的每个项将是要从输出事件实体中删除的列(如果存在)的名称。 string[]
partitionKey 此元素指示查询中 SELECT 语句中的列的名称,该列将用作 Azure 表的分区键。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
rowKey 此元素指示查询中 SELECT 语句中的列的名称,该列将用作 Azure 表的行键。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
Azure 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串

PowerBIOutputDataSource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 需要“PowerBI” ()
properties 与 Power BI 输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 PowerBIOutputDataSourceProperties

PowerBIOutputDataSourceProperties

名称 说明
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
dataset Power BI 数据集的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
groupId Power BI 组的 ID。 字符串
groupName Power BI 组的名称。 使用此属性有助于记住使用了哪个特定的 Power BI 组 ID。 string
refreshToken 一个刷新令牌,可用于获取有效的访问令牌,然后可用于对数据源进行身份验证。 有效的刷新令牌目前只能通过 Azure 门户获取。 建议在创建数据源时在此处放置一个虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
指定数据集下的 Power BI 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
tokenUserDisplayName 用于获取刷新令牌的用户的用户显示名称。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 字符串
tokenUserPrincipalName 用户主体名称 (用于获取刷新令牌的用户的 UPN) 。 使用此属性可帮助记住使用哪个用户获取刷新令牌。 字符串

RawOutputDatasource

名称 说明 Value
type 指示将写入数据源输出的类型。 在 PUT (CreateOrReplace) 请求上是必需的。 所需的“原始” ()
properties 与原始输出关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 RawOutputDatasourceProperties

RawOutputDatasourceProperties

名称 说明
payloadUri 应在其中写入输出的 Blob 的 SAS URL。 如果未设置此属性,输出数据将写入临时存储,结果中将包含该临时存储的 SAS URL。 string

OutputWatermarkProperties

名称 说明
maxWatermarkDifferenceAcrossPartitions 描述最快和最慢分区之间的最大增量,以便正确定义捕获下游作业中所有必要事件的无序窗口。 string
watermarkMode 输出水印模式。 "None"
“SendCurrentPartitionWatermark”
“SendLowestWatermarkAcrossPartitions”

SKU

名称 说明
容量 SKU 的容量。 int
name SKU 的名称。 在 PUT (CreateOrReplace) 请求上是必需的。 “Standard”

转换

名称 说明
name 资源名称 string
properties 与转换关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。 TransformationProperties

TransformationProperties

名称 说明
查询 指定将在流式处理作业中运行的查询。 可以在此处详细了解流分析查询语言 (SAQL) : https://msdn.microsoft.com/library/azure/dn834998 。 在 PUT (CreateOrReplace) 请求上是必需的。 字符串
streamingUnits 指定流式处理作业使用的流单元数。 int
validStreamingUnits 指定流式处理作业可以缩放到的有效流单元。 int[]