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

Microsoft.StreamAnalytics streamingjobs 2016-03-01

• 最新
• 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@2016-03-01' = {
  name: 'string'
  location: 'string'
  tags: {
    tagName1: 'tagValue1'
    tagName2: 'tagValue2'
  }
  properties: {
    compatibilityLevel: '1.0'
    dataLocale: 'string'
    eventsLateArrivalMaxDelayInSeconds: int
    eventsOutOfOrderMaxDelayInSeconds: int
    eventsOutOfOrderPolicy: 'string'
    functions: [
      {
        name: 'string'
        properties: {
          type: 'string'
          // For remaining properties, see FunctionProperties objects
        }
      }
    ]
    inputs: [
      {
        name: 'string'
        properties: {
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          type: 'string'
          // For remaining properties, see InputProperties objects
        }
      }
    ]
    outputErrorPolicy: 'string'
    outputs: [
      {
        name: 'string'
        properties: {
          datasource: {
            type: 'string'
            // For remaining properties, see OutputDataSource objects
          }
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
        }
      }
    ]
    outputStartMode: 'string'
    outputStartTime: 'string'
    sku: {
      name: 'Standard'
    }
    transformation: {
      name: 'string'
      properties: {
        query: 'string'
        streamingUnits: int
      }
    }
  }
}

FunctionProperties 对象

设置 type 属性以指定对象的类型。

对于 标量，请使用：

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

FunctionBinding 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.MachineLearning/WebService，请使用：

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

对于 Microsoft.StreamAnalytics/JavascriptUdf，请使用：

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

InputProperties 对象

设置 type 属性以指定对象的类型。

对于 参考，请使用：

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

对于 Stream，请使用：

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

序列化对象

设置 type 属性以指定对象的类型。

对于 Avro，请使用：

  type: 'Avro'
  properties: any()

对于 Csv，请使用：

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

对于 Json，请使用：

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

ReferenceInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Storage/Blob，请使用：

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

StreamInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Devices/IotHubs，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

OutputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.DataLake/Accounts，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.ServiceBus/Queue，请使用：

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

对于 Microsoft.ServiceBus/Topic，请使用：

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

对于 Microsoft.Sql/Server/Database，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

对于 Microsoft.Storage/DocumentDB，请使用：

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

对于 Microsoft.Storage/Table，请使用：

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

对于 PowerBI，请使用：

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

属性值

streamingjobs

名称	说明	值
name	资源名称	字符串 (必需) 字符限制：3-63 有效字符： 字母数字、连字符和下划线。
location	资源所在的地理位置	字符串
标记	资源标记。	标记名称和值的字典。 请参阅 模板中的标记
properties	与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。	StreamingJobProperties

StreamingJobProperties

名称	说明	值
compatibilityLevel	控制流式处理作业的某些运行时行为。	'1.0'
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[]
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 请求中指定此属性时，需要转换的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。	转换

函数

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

FunctionProperties

名称	说明	Value
type	设置对象类型	需要标量 ()

ScalarFunctionProperties

名称	说明	Value
type	指示函数的类型。	“Scalar” (必需)
properties	描述标量函数的配置。	ScalarFunctionConfiguration

ScalarFunctionConfiguration

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

FunctionBinding

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

AzureMachineLearningWebServiceFunctionBinding

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

AzureMachineLearningWebServiceFunctionBindingPropert...

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

AzureMachineLearningWebServiceInputs

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

AzureMachineLearningWebServiceInputColumn

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

AzureMachineLearningWebServiceOutputColumn

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

JavaScriptFunctionBinding

名称	说明	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	字符串

输入

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

InputProperties

名称	说明	值
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求时是必需的。	序列化
类型	设置对象类型	引用 需要流 ()

序列化

名称	说明	Value
type	设置对象类型	Avro Csv 需要 json ()

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) 请求时是必需的。	字符串

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'

ReferenceInputProperties

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

ReferenceInputDataSource

名称	说明	Value
type	设置对象类型	需要 Microsoft.Storage/Blob ()

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

名称	说明	值
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 中，此属性的值将改为用作时间格式。	字符串

StorageAccount

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

StreamInputProperties

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

StreamInputDataSource

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

IoTHubStreamInputDataSource

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

IoTHubStreamInputDataSourceProperties

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

EventHubStreamInputDataSource

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

EventHubStreamInputDataSourceProperties

名称	说明	值
consumerGroupName	应用于从事件中心读取事件的事件中心使用者组的名称。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定，则输入将使用事件中心的默认使用者组。	字符串
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。	字符串

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

名称	说明	值
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 中，此属性的值将改为用作时间格式。	字符串

输出

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

OutputProperties

名称	说明	值
datasource	描述将写入输出的数据源。 在 PUT (CreateOrReplace) 请求上是必需的。	OutputDataSource
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。	序列化

OutputDataSource

名称	说明	Value
type	设置对象类型	Microsoft.DataLake/Accounts Microsoft.ServiceBus/EventHub Microsoft.ServiceBus/Queue Microsoft.ServiceBus/Topic Microsoft.Sql/Server/Database Microsoft.Storage/Blob Microsoft.Storage/DocumentDB Microsoft.Storage/Table 需要 PowerBI ()

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

EventHubOutputDataSource

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

EventHubOutputDataSourceProperties

名称	说明	值
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	string
partitionKey	用于确定将事件数据发送到哪个分区的键/列。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求上是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。	字符串

ServiceBusQueueOutputDataSource

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

ServiceBusQueueOutputDataSourceProperties

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

ServiceBusTopicOutputDataSource

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

ServiceBusTopicOutputDataSourceProperties

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

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

名称	说明	值
database	Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
password	将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
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

名称	说明	值
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) 请求上是必需的。	字符串
accountKey	DocumentDB 帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
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) 请求上是必需的。	字符串
rowKey	此元素指示查询中 SELECT 语句中的列的名称，该列将用作 Azure 表的行键。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
表	Azure 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串

PowerBIOutputDataSource

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

PowerBIOutputDataSourceProperties

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

SKU

名称	说明	值
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

快速入门模板

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

模板	说明
创建标准流分析作业	此模板创建标准流分析作业。 有关详细信息，Azure 流分析是一种实时分析和复杂的事件处理引擎，旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源（包括设备、传感器、点击流、社交媒体源和应用程序）提取的信息中识别模式和关系。 这些模式可用于触发操作和启动工作流，例如创建警报、向报告工具馈送信息或存储转换后的数据以供以后使用。 此外，流分析可在 Azure IoT Edge 运行时上使用，并支持与云完全相同的语言或语法。

ARM 模板资源定义

streamingjobs 资源类型可以通过针对以下操作进行部署：

• 资源组 - 请参阅 资源组部署命令

有关每个 API 版本中更改的属性的列表，请参阅 更改日志。

资源格式

若要创建 Microsoft.StreamAnalytics/streamingjobs 资源，请将以下 JSON 添加到模板。

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

FunctionProperties 对象

设置 type 属性以指定对象的类型。

对于 标量，请使用：

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

FunctionBinding 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.MachineLearning/WebService，请使用：

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

对于 Microsoft.StreamAnalytics/JavascriptUdf，请使用：

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

InputProperties 对象

设置 type 属性以指定对象的类型。

对于 参考，请使用：

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

对于 Stream，请使用：

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

序列化对象

设置 type 属性以指定对象的类型。

对于 Avro，请使用：

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

对于 Csv，请使用：

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

对于 Json，请使用：

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

ReferenceInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Storage/Blob，请使用：

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

StreamInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Devices/IotHubs，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

OutputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.DataLake/Accounts，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.ServiceBus/Queue，请使用：

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

对于 Microsoft.ServiceBus/Topic，请使用：

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

对于 Microsoft.Sql/Server/Database，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

对于 Microsoft.Storage/DocumentDB，请使用：

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

对于 Microsoft.Storage/Table，请使用：

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

对于 PowerBI，请使用：

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

属性值

streamingjobs

名称	说明	Value
type	资源类型	“Microsoft.StreamAnalytics/streamingjobs”
apiVersion	资源 API 版本	'2016-03-01'
name	资源名称	字符串 (必需) 字符限制：3-63 有效字符： 字母数字、连字符和下划线字符。
location	资源所在的地理位置	字符串
标记	资源标记。	标记名称和值的字典。 请参阅 模板中的标记
properties	与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。	StreamingJobProperties

StreamingJobProperties

名称	说明	值
compatibilityLevel	控制流式处理作业的某些运行时行为。	'1.0'
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[]
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。	转换

函数

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

FunctionProperties

名称	说明	Value
type	设置对象类型	需要标量 ()

ScalarFunctionProperties

名称	说明	Value
type	指示函数的类型。	需要“标量” ()
properties	描述标量函数的配置。	ScalarFunctionConfiguration

ScalarFunctionConfiguration

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

FunctionBinding

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

AzureMachineLearningWebServiceFunctionBinding

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

AzureMachineLearningWebServiceFunctionBindingPropert...

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

AzureMachineLearningWebServiceInputs

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

AzureMachineLearningWebServiceInputColumn

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

AzureMachineLearningWebServiceOutputColumn

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

JavaScriptFunctionBinding

名称	说明	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	字符串

输入

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

InputProperties

名称	说明	值
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。	序列化
类型	设置对象类型	引用 所需的流 ()

序列化

名称	说明	Value
type	设置对象类型	Avro Csv 需要 json ()

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) 请求上是必需的。	字符串

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'

ReferenceInputProperties

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

ReferenceInputDataSource

名称	说明	Value
type	设置对象类型	需要 Microsoft.Storage/Blob ()

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

名称	说明	值
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 中，此属性的值将改为用作时间格式。	字符串

StorageAccount

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

StreamInputProperties

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

StreamInputDataSource

名称	说明	Value
type	设置对象类型	Microsoft.Devices/IotHubs Microsoft.ServiceBus/EventHub Microsoft.Storage/Blob (必需)

IoTHubStreamInputDataSource

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

IoTHubStreamInputDataSourceProperties

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

EventHubStreamInputDataSource

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

EventHubStreamInputDataSourceProperties

名称	说明	值
consumerGroupName	应用于从事件中心读取事件的事件中心使用者组的名称。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定，则输入将使用事件中心的默认使用者组。	字符串
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求上是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求上是必需的。	字符串

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

名称	说明	值
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 中，此属性的值将改为用作时间格式。	字符串

输出

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

OutputProperties

名称	说明	值
datasource	描述输出将写入到的数据源。 在 PUT (CreateOrReplace) 请求时是必需的。	OutputDataSource
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求时是必需的。	序列化

OutputDataSource

名称	说明	Value
type	设置对象类型	Microsoft.DataLake/Accounts Microsoft.ServiceBus/EventHub Microsoft.ServiceBus/Queue Microsoft.ServiceBus/Topic Microsoft.Sql/Server/Database Microsoft.Storage/Blob Microsoft.Storage/DocumentDB Microsoft.Storage/Table 需要 PowerBI ()

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

EventHubOutputDataSource

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

EventHubOutputDataSourceProperties

名称	说明	值
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	string
partitionKey	用于确定将事件数据发送到哪个分区的键/列。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。	字符串

ServiceBusQueueOutputDataSource

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

ServiceBusQueueOutputDataSourceProperties

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

ServiceBusTopicOutputDataSource

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

ServiceBusTopicOutputDataSourceProperties

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

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

名称	说明	值
database	Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
password	将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
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

名称	说明	值
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) 请求时是必需的。	字符串
accountKey	DocumentDB 帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
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) 请求上是必需的。	字符串
rowKey	此元素指示查询中 SELECT 语句中的列的名称，该列将用作 Azure 表的行键。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
表	Azure 表的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串

PowerBIOutputDataSource

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

PowerBIOutputDataSourceProperties

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

SKU

名称	说明	值
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

快速入门模板

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

模板	说明
创建标准流分析作业	此模板创建标准流分析作业。 有关详细信息，Azure 流分析是一个实时分析和复杂的事件处理引擎，旨在同时分析和处理来自多个源的大量快速流式处理数据。 可以在从许多输入源（包括设备、传感器、点击流、社交媒体源和应用程序）提取的信息中识别模式和关系。 这些模式可用于触发操作和启动工作流，例如创建警报、向报告工具馈送信息或存储转换后的数据以供以后使用。 此外，流分析可在 Azure IoT Edge 运行时上使用，并支持与云完全相同的语言或语法。

Terraform (AzAPI 提供程序) 资源定义

可以使用面向以下操作部署 streamingjobs 资源类型：

• 资源组

有关每个 API 版本中已更改属性的列表，请参阅 更改日志。

资源格式

若要创建 Microsoft.StreamAnalytics/streamingjobs 资源，请将以下 Terraform 添加到模板。

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

FunctionProperties 对象

设置 type 属性以指定对象的类型。

对于 标量，请使用：

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

FunctionBinding 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.MachineLearning/WebService，请使用：

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

对于 Microsoft.StreamAnalytics/JavascriptUdf，请使用：

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

InputProperties 对象

设置 type 属性以指定对象的类型。

有关 参考，请使用：

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

对于 Stream，请使用：

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

序列化对象

设置 type 属性以指定对象的类型。

对于 Avro，请使用：

  type = "Avro"

对于 Csv，请使用：

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

对于 Json，请使用：

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

ReferenceInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Storage/Blob，请使用：

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

StreamInputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.Devices/IotHubs，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

OutputDataSource 对象

设置 type 属性以指定对象的类型。

对于 Microsoft.DataLake/Accounts，请使用：

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

对于 Microsoft.ServiceBus/EventHub，请使用：

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

对于 Microsoft.ServiceBus/Queue，请使用：

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

对于 Microsoft.ServiceBus/Topic，请使用：

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

对于 Microsoft.Sql/Server/Database，请使用：

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

对于 Microsoft.Storage/Blob，请使用：

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

对于 Microsoft.Storage/DocumentDB，请使用：

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

对于 Microsoft.Storage/Table，请使用：

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

对于 PowerBI，请使用：

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

属性值

streamingjobs

名称	说明	Value
type	资源类型	“Microsoft.StreamAnalytics/streamingjobs@2016-03-01”
name	资源名称	字符串 (必需) 字符限制：3-63 有效字符： 字母数字、连字符和下划线。
location	资源所在的地理位置	字符串
parent_id	若要部署到资源组，请使用该资源组的 ID。	字符串 (必需)
标记	资源标记。	标记名称和值的字典。
properties	与流式处理作业关联的属性。 在 PUT (CreateOrReplace) 请求上是必需的。	StreamingJobProperties

StreamingJobProperties

名称	说明	值
compatibilityLevel	控制流式处理作业的某些运行时行为。	"1.0"
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[]
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 请求中指定此属性时，需要转换的 name 属性。 无法通过 PATCH 操作修改此属性。 必须使用可用于单个转换的 PATCH API。	转换

函数

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

FunctionProperties

名称	说明	Value
type	设置对象类型	需要标量 ()

ScalarFunctionProperties

名称	说明	Value
type	指示函数的类型。	需要“标量” ()
properties	描述标量函数的配置。	ScalarFunctionConfiguration

ScalarFunctionConfiguration

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

FunctionBinding

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

AzureMachineLearningWebServiceFunctionBinding

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

AzureMachineLearningWebServiceFunctionBindingPropert...

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

AzureMachineLearningWebServiceInputs

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

AzureMachineLearningWebServiceInputColumn

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

AzureMachineLearningWebServiceOutputColumn

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

JavaScriptFunctionBinding

名称	说明	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	字符串

输入

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

InputProperties

名称	说明	值
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。	序列化
类型	设置对象类型	引用 所需的流 ()

序列化

名称	说明	Value
type	设置对象类型	Avro Csv 需要 json ()

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) 请求上是必需的。	字符串

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”

ReferenceInputProperties

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

ReferenceInputDataSource

名称	说明	Value
type	设置对象类型	Microsoft.Storage/Blob (必需)

BlobReferenceInputDataSource

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

BlobReferenceInputDataSourceProperties

名称	说明	值
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 中的位置，此属性的值都改为用作时间格式。	字符串

StorageAccount

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

StreamInputProperties

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

StreamInputDataSource

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

IoTHubStreamInputDataSource

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

IoTHubStreamInputDataSourceProperties

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

EventHubStreamInputDataSource

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

EventHubStreamInputDataSourceProperties

名称	说明	值
consumerGroupName	应用于从事件中心读取事件的事件中心使用者组的名称。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定，则输入将使用事件中心的默认使用者组。	字符串
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。	字符串

BlobStreamInputDataSource

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

BlobStreamInputDataSourceProperties

名称	说明	值
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 中的位置，此属性的值都改为用作时间格式。	字符串

输出

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

OutputProperties

名称	说明	值
datasource	描述将写入输出的数据源。 在 PUT (CreateOrReplace) 请求上是必需的。	OutputDataSource
序列化	描述如何序列化输入中的数据，或者在写入输出时如何序列化数据。 在 PUT (CreateOrReplace) 请求上是必需的。	序列化

OutputDataSource

名称	说明	Value
type	设置对象类型	Microsoft.DataLake/Accounts Microsoft.ServiceBus/EventHub Microsoft.ServiceBus/Queue Microsoft.ServiceBus/Topic Microsoft.Sql/Server/Database Microsoft.Storage/Blob Microsoft.Storage/DocumentDB Microsoft.Storage/Table 需要 PowerBI ()

AzureDataLakeStoreOutputDataSource

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

AzureDataLakeStoreOutputDataSourceProperties

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

EventHubOutputDataSource

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

EventHubOutputDataSourceProperties

名称	说明	值
eventHubName	事件中心的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	string
partitionKey	用于确定将事件数据发送到哪个分区的键/列。	字符串
serviceBusNamespace	与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyKey	指定共享访问策略的共享访问策略密钥。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
sharedAccessPolicyName	事件中心、服务总线队列、服务总线主题等的共享访问策略名称。在 PUT (CreateOrReplace) 请求时是必需的。	字符串

ServiceBusQueueOutputDataSource

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

ServiceBusQueueOutputDataSourceProperties

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

ServiceBusTopicOutputDataSource

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

ServiceBusTopicOutputDataSourceProperties

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

AzureSqlDatabaseOutputDataSource

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

AzureSqlDatabaseOutputDataSourceProperties

名称	说明	值
database	Azure SQL数据库的名称。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
password	将用于连接到 Azure SQL 数据库的密码。 在 PUT (CreateOrReplace) 请求上是必需的。	字符串
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

名称	说明	值
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) 请求时是必需的。	字符串
accountKey	DocumentDB 帐户的帐户密钥。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
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) 请求时是必需的。	字符串
rowKey	此元素指示查询中 SELECT 语句中的列名称，该列将用作 Azure 表的行键。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串
表	Azure 表的名称。 在 PUT (CreateOrReplace) 请求时是必需的。	字符串

PowerBIOutputDataSource

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

PowerBIOutputDataSourceProperties

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

SKU

名称	说明	值
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