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

Microsoft.StreamAnalytics streamingjobs

• 最新
• 2021-10-01-preview
• 2020-03-01
• 2017-04-01-preview
• 2016-03-01

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-input 或 https://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-input 或 https://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-input 或 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。	字符串
sourcePartitionCount	Blob 输入数据源的分区计数。 范围 1 - 256。	int
storageAccounts	一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。	StorageAccount[]
timeFormat	时间格式。 无论 {time} 出现在 pathPattern 中的位置，此属性的值都改为用作时间格式。	字符串

RawReferenceInputDataSource

名称	说明	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-input 或 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。	字符串
sourcePartitionCount	Blob 输入数据源的分区计数。 范围 1 - 1024。	int
storageAccounts	一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求上是必需的。	StorageAccount[]
timeFormat	时间格式。 无论 {time} 出现在 pathPattern 中的位置，此属性的值都改为用作时间格式。	字符串

RawStreamInputDataSource

名称	说明	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-input 或 https://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 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-input 或 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。	字符串
refreshInterval	刷新间隔。	字符串
refreshType	此属性指示要使用的数据刷新选项“阻止”或“非阻止”。	“阻止” “非阻止”
timeFormat	时间格式。 无论 {time} 出现在 pathPattern 中的位置，此属性的值都改为用作时间格式。	字符串

StorageAccount

名称	说明	值
accountKey	Azure 存储帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串 约束： 敏感值。 作为安全参数传入。
accountName	Azure 存储帐户的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	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-input 或 https://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-input 或 https://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-input 或 https://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-input 或 https://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 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-input 或 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。	字符串
refreshInterval	刷新间隔。	字符串
refreshType	此属性指示要使用的数据刷新选项，阻止或非阻止。	“阻止” “非阻止”
timeFormat	时间格式。 只要 {time} 出现在 pathPattern 中，此属性的值将改为用作时间格式。	字符串

StorageAccount

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

函数

名称	说明	值
name	资源名称	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-input 或 https://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-input 或 https://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-input 或 https://docs.microsoft.com/rest/api/streamanalytics/stream-analytics-output 。	字符串
sourcePartitionCount	Blob 输入数据源的分区计数。 范围 1 - 1024。	int
storageAccounts	一个或多个 Azure 存储帐户的列表。 在 PUT (CreateOrReplace) 请求时是必需的。	StorageAccount[]
timeFormat	时间格式。 只要 {time} 出现在 pathPattern 中，此属性的值将改为用作时间格式。	字符串

RawStreamInputDataSource

名称	说明	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-input 或 https://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[]