你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
Microsoft.StreamAnalytics streamingjobs 2020-03-01
Bicep 资源定义
可以使用目标操作部署流式处理作业资源类型:
- 资源组 - 请参阅 资源组部署命令
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
资源格式
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 Bicep 添加到模板。
resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2020-03-01' = {
identity: {
type: 'string'
}
location: 'string'
name: 'string'
properties: {
cluster: {
id: 'string'
}
compatibilityLevel: 'string'
contentStoragePolicy: 'string'
dataLocale: 'string'
eventsLateArrivalMaxDelayInSeconds: int
eventsOutOfOrderMaxDelayInSeconds: int
eventsOutOfOrderPolicy: '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
}
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'
}
}
]
outputStartMode: 'string'
outputStartTime: 'string'
sku: {
name: 'string'
}
transformation: {
name: 'string'
properties: {
query: 'string'
streamingUnits: int
validStreamingUnits: [
int
]
}
}
}
tags: {
{customized property}: 'string'
}
}
StreamInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
properties: {
topic: 'string'
}
type: 'GatewayMessageBus'
}
对于 Microsoft.Devices/IotHubs,请使用:
{
properties: {
consumerGroupName: 'string'
endpoint: 'string'
iotHubNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.Devices/IotHubs'
}
对于 Microsoft.EventHub/EventHub,请使用:
{
properties: {
authenticationMode: 'string'
consumerGroupName: 'string'
eventHubName: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.EventHub/EventHub'
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties: {
authenticationMode: 'string'
consumerGroupName: 'string'
eventHubName: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.ServiceBus/EventHub'
}
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
authenticationMode: 'string'
container: 'string'
dateFormat: 'string'
pathPattern: 'string'
sourcePartitionCount: int
storageAccounts: [
{
accountKey: 'string'
accountName: 'string'
}
]
timeFormat: 'string'
}
type: 'Microsoft.Storage/Blob'
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
properties: {
topic: 'string'
}
type: 'GatewayMessageBus'
}
对于 Microsoft.AzureFunction,请使用:
{
properties: {
apiKey: 'string'
functionAppName: 'string'
functionName: 'string'
maxBatchCount: int
maxBatchSize: int
}
type: 'Microsoft.AzureFunction'
}
对于 Microsoft.DataLake/Accounts,请使用:
{
properties: {
accountName: 'string'
authenticationMode: 'string'
dateFormat: 'string'
filePathPrefix: 'string'
refreshToken: 'string'
tenantId: 'string'
timeFormat: 'string'
tokenUserDisplayName: 'string'
tokenUserPrincipalName: 'string'
}
type: 'Microsoft.DataLake/Accounts'
}
对于 Microsoft.EventHub/EventHub,请使用:
{
properties: {
authenticationMode: 'string'
eventHubName: 'string'
partitionKey: 'string'
propertyColumns: [
'string'
]
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.EventHub/EventHub'
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties: {
authenticationMode: 'string'
eventHubName: 'string'
partitionKey: 'string'
propertyColumns: [
'string'
]
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.ServiceBus/EventHub'
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
properties: {
authenticationMode: 'string'
propertyColumns: [
'string'
]
queueName: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
systemPropertyColumns: any(Azure.Bicep.Types.Concrete.AnyType)
}
type: 'Microsoft.ServiceBus/Queue'
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
properties: {
authenticationMode: 'string'
propertyColumns: [
'string'
]
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
systemPropertyColumns: {
{customized property}: 'string'
}
topicName: 'string'
}
type: 'Microsoft.ServiceBus/Topic'
}
对于 Microsoft.Sql/Server/DataWarehouse,请使用:
{
properties: {
database: 'string'
password: 'string'
server: 'string'
table: 'string'
user: 'string'
}
type: 'Microsoft.Sql/Server/DataWarehouse'
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties: {
authenticationMode: 'string'
database: 'string'
maxBatchCount: int
maxWriterCount: int
password: 'string'
server: 'string'
table: 'string'
user: 'string'
}
type: 'Microsoft.Sql/Server/Database'
}
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
authenticationMode: 'string'
blobPathPrefix: 'string'
container: 'string'
dateFormat: 'string'
pathPattern: 'string'
storageAccounts: [
{
accountKey: 'string'
accountName: 'string'
}
]
timeFormat: 'string'
}
type: 'Microsoft.Storage/Blob'
}
对于 Microsoft.Storage/DocumentDB,请使用:
{
properties: {
accountId: 'string'
accountKey: 'string'
collectionNamePattern: 'string'
database: 'string'
documentId: 'string'
partitionKey: 'string'
}
type: 'Microsoft.Storage/DocumentDB'
}
对于 Microsoft.Storage/Table,请使用:
{
properties: {
accountKey: 'string'
accountName: 'string'
batchSize: int
columnsToRemove: [
'string'
]
partitionKey: 'string'
rowKey: 'string'
table: 'string'
}
type: 'Microsoft.Storage/Table'
}
对于 PowerBI,请使用:
{
properties: {
authenticationMode: 'string'
dataset: 'string'
groupId: 'string'
groupName: 'string'
refreshToken: 'string'
table: 'string'
tokenUserDisplayName: 'string'
tokenUserPrincipalName: 'string'
}
type: 'PowerBI'
}
InputProperties 对象
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
datasource: {
type: 'string'
// For remaining properties, see ReferenceInputDataSource objects
}
type: 'Reference'
}
对于 Stream,请使用:
{
datasource: {
type: 'string'
// For remaining properties, see StreamInputDataSource objects
}
type: 'Stream'
}
序列化对象
设置 类型 属性以指定对象的类型。
对于 Avro,请使用:
{
properties: any(Azure.Bicep.Types.Concrete.AnyType)
type: 'Avro'
}
对于 Csv,请使用:
{
properties: {
encoding: 'string'
fieldDelimiter: 'string'
}
type: 'Csv'
}
对于 Json,请使用:
{
properties: {
encoding: 'string'
format: 'string'
}
type: 'Json'
}
对于 Parquet,请使用:
{
properties: any(Azure.Bicep.Types.Concrete.AnyType)
type: 'Parquet'
}
ReferenceInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 文件,请使用:
{
properties: {
path: 'string'
}
type: 'File'
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties: {
database: 'string'
deltaSnapshotQuery: 'string'
fullSnapshotQuery: 'string'
password: 'string'
refreshRate: 'string'
refreshType: 'string'
server: 'string'
table: 'string'
user: 'string'
}
type: 'Microsoft.Sql/Server/Database'
}
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
authenticationMode: 'string'
container: 'string'
dateFormat: 'string'
pathPattern: 'string'
storageAccounts: [
{
accountKey: 'string'
accountName: 'string'
}
]
timeFormat: 'string'
}
type: 'Microsoft.Storage/Blob'
}
FunctionBinding 对象
设置 类型 属性以指定对象的类型。
对于 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'
}
]
}
type: 'Microsoft.MachineLearning/WebService'
}
对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:
{
properties: {
script: 'string'
}
type: 'Microsoft.StreamAnalytics/JavascriptUdf'
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 聚合,请使用:
{
type: 'Aggregate'
}
对于 标量,请使用:
{
type: 'Scalar'
}
属性值
AggregateFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “Aggregate”(必需) |
AvroSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Avro”(必需) |
AzureDataLakeStoreOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Data Lake Store 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureDataLakeStoreOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.DataLake/Accounts”(必需) |
AzureDataLakeStoreOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountName | Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
dateFormat | 日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 | 字符串 |
filePathPrefix | 输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
refreshToken | 一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
tenantId | 用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
timeFormat | 时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 | 字符串 |
tokenUserDisplayName | 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
tokenUserPrincipalName | 用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
AzureFunctionOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Function 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureFunctionOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.AzureFunction”(必需) |
AzureFunctionOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 如果想要从另一个订阅使用 Azure 函数,可以通过提供用于访问函数的密钥来执行此操作。 | 字符串 |
functionAppName | Azure Functions 应用的名称。 | 字符串 |
functionName | Azure Functions 应用中函数的名称。 | 字符串 |
maxBatchCount | 一个属性,可用于指定发送到 Azure Functions 的每个批处理中的最大事件数。 默认值为 100。 | int |
maxBatchSize | 一个属性,可用于设置发送到 Azure 函数的每个输出批处理的最大大小。 输入单位为字节。 默认情况下,此值为 262,144 字节(256 KB)。 | int |
AzureMachineLearningWebServiceFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 机器学习 Web 服务关联的绑定属性。 | AzureMachineLearningWebServiceFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.MachineLearning/WebService”(必需) |
AzureMachineLearningWebServiceFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 用于对 Request-Response 终结点进行身份验证的 API 密钥。 | 字符串 |
batchSize | 描述每个 Azure ML RRS 执行请求的最大行数的 1 到 10000 之间的数字。 默认值为 1000。 | int |
端点 | Request-Response Azure 机器学习 Web 服务的执行终结点。 在此处了解详细信息:/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs | 字符串 |
输入 | Azure 机器学习 Web 服务终结点的输入。 | AzureMachineLearningWebServiceInputs |
输出 | Azure 机器学习 Web 服务终结点执行的输出列表。 | AzureMachineLearningWebServiceOutputColumn[] |
AzureMachineLearningWebServiceInputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
mapTo | 此输入映射到的函数参数的从零开始的索引。 | int |
名字 | 输入列的名称。 | 字符串 |
AzureMachineLearningWebServiceInputs
名字 | 描述 | 价值 |
---|---|---|
columnNames | Azure 机器学习 Web 服务终结点的输入列列表。 | AzureMachineLearningWebServiceInputColumn[] |
名字 | 输入的名称。 这是创作终结点时提供的名称。 | 字符串 |
AzureMachineLearningWebServiceOutputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输出列的 (Azure 机器学习支持的)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
名字 | 输出列的名称。 | 字符串 |
AzureSqlDatabaseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure SQL 数据库输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlDatabaseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlDatabaseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
maxBatchCount | 写入 Sql 数据库的最大 Batch 计数,默认值为 10,000。 PUT 请求可选。 | int |
maxWriterCount | 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 | int |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureSqlReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 SQL DB 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | 此元素与数据源元素相关联。 这是输出将写入到的数据库的名称。 | 字符串 |
deltaSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 | 字符串 |
fullSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 sql 数据库提取数据。 | 字符串 |
密码 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的密码。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
refreshRate | 此元素与数据源元素相关联。 这表示从数据库提取数据的频率。 它采用 DateTime 格式。 | 字符串 |
refreshType | 指示数据刷新选项的类型。 | “RefreshPeriodicallyWithDelta” “RefreshPeriodicallyWithFull” “Static” |
服务器 | 此元素与数据源元素相关联。 这是包含要写入的数据库的服务器的名称。 | 字符串 |
桌子 | 此元素与数据源元素相关联。 Azure SQL 数据库中表的名称。 | 字符串 |
用户 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的用户名。 | 字符串 |
AzureSynapseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSynapseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/DataWarehouse”(必需) |
AzureSynapseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureTableOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 表输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureTableOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Table”(必需) |
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) 请求时是必需的。 | 字符串 |
BlobOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Blob 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
blobPathPrefix | Blob 路径前缀。 | 字符串 |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
sourcePartitionCount | Blob 输入数据源的分区计数。 范围 1 - 1024。 | int |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
ClusterInfo
名字 | 描述 | 价值 |
---|---|---|
id | 群集的资源 ID。 | 字符串 |
压缩
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示输入使用的压缩类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Deflate” “GZip” “无”(必需) |
CsvSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | CsvSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Csv”(必需) |
CsvSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
fieldDelimiter | 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
DocumentDbOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | DocumentDbOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/DocumentDB”(必需) |
DocumentDbOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountId | DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountKey | DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
collectionNamePattern | 要使用的集合的集合名称模式。 可以使用可选的 {partition} 标记构造集合名称格式,其中分区从 0 开始。 有关详细信息,请参阅 /rest/api/streamanalytics/stream-analytics-output 的 DocumentDB 部分。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
数据库 | DocumentDB 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
documentId | 输出事件中用于指定插入或更新操作所基于的主键的字段的名称。 | 字符串 |
partitionKey | 输出事件中用于指定键以跨集合对输出进行分区的字段的名称。 如果“collectionNamePattern”包含 {partition} 标记,则需要指定此属性。 | 字符串 |
EventHubOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
partitionKey | 用于确定要发送事件数据的分区的键/列。 | 字符串 |
propertyColumns | 与此事件中心输出关联的属性。 | string[] |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
consumerGroupName | 事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 | 字符串 |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubV2OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
EventHubV2StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
FileReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | FileReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “File”(必需) |
FileReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
路径 | 文件的路径。 | 字符串 |
功能
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与函数关联的属性。 | FunctionProperties |
FunctionBinding
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AzureMachineLearningWebServiceFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 | “Microsoft.MachineLearning/WebService” “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
FunctionConfiguration
名字 | 描述 | 价值 |
---|---|---|
捆绑 | 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的情况下,这描述了终结点。 | FunctionBinding |
输入 | FunctionInput[] | |
输出 | 描述函数的输出。 | FunctionOutput |
FunctionInput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输入参数的(支持 Azure 流分析)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
isConfigurationParameter | 指示参数是否为配置参数的标志。 如此 如果此输入参数应为常量。 默认值为 false。 | bool |
FunctionOutput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输出的 (Azure 流分析支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
FunctionProperties
名字 | 描述 | 价值 |
---|---|---|
性能 | FunctionConfiguration | |
类型 | 对于 type AggregateFunctionProperties,设置为“Aggregate”。 对于 ScalarFunctionProperties类型,设置为“Scalar Scalar”。 | “Aggregate” “标量”(必需) |
GatewayMessageBusOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与网关消息总线输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | GatewayMessageBusOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
GatewayMessageBusStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的网关消息总线输入关联的属性。 | GatewayMessageBusStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
身份
名字 | 描述 | 价值 |
---|---|---|
类型 | 标识类型 | 字符串 |
输入
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | InputProperties |
InputProperties
名字 | 描述 | 价值 |
---|---|---|
压缩 | 描述如何压缩输入数据 | 压缩 |
partitionKey | partitionKey 描述用于对输入数据进行分区的输入数据中的键 | 字符串 |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
类型 | 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 | “Reference” “Stream”(必需) |
IoTHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | IoTHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Devices/IotHubs”(必需) |
IoTHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
consumerGroupName | 应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 | 字符串 |
端点 | 要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 | 字符串 |
iotHubNamespace | IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
JavaScriptFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JavaScript 函数关联的绑定属性。 | JavaScriptFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
JavaScriptFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
脚本 | 包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' | 字符串 |
JobStorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
JsonSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JSON 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | JsonSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Json”(必需) |
JsonSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
格式 | 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定输出将写入的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出将设置格式,方法是让每个 JSON 对象用新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果为 null,则默认值为“lineSeparated”。 | “Array” “LineSeparated” |
Microsoft.StreamAnalytics/streamingjobs
名字 | 描述 | 价值 |
---|---|---|
身份 | 描述分配给此作业的系统分配的托管标识,该标识可用于通过输入和输出进行身份验证。 | 标识 |
位置 | 资源所在的地理位置 | 字符串 |
名字 | 资源名称 | string (必需) |
性能 | 与流式处理作业关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | StreamingJobProperties |
标签 | 资源标记 | 标记名称和值的字典。 请参阅模板 中的 |
输出
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | OutputProperties |
OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubOutputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 ServiceBusQueueOutputDataSource类型,设置为“Microsoft.ServiceBus/Queue”。 对于 ServiceBusTopicOutputDataSource,请设置为“Microsoft.ServiceBus/Topic”。 对于 AzureSynapseOutputDataSource,请设置为“Microsoft.Sql/Server/DataWarehouse”。 对于 AzureSqlDatabaseOutputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobOutputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 DocumentDbOutputDataSource,请设置为“Microsoft.Storage/DocumentDB”。 对于 AzureTableOutputDataSource,请设置为“Microsoft.Storage/Table”。 对于 PowerBIOutputDataSource,请设置为“PowerBI”。 | “GatewayMessageBus” “Microsoft.AzureFunction” “Microsoft.DataLake/Accounts” “Microsoft.EventHub/EventHub” “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”(必需) |
OutputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 | OutputDataSource |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
sizeWindow | 要限制流分析输出的大小窗口。 | int |
timeWindow | 筛选流分析作业输出的时间范围。 | 字符串 |
ParquetSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Parquet”(必需) |
PowerBIOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Power BI 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | PowerBIOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “PowerBI”(必需) |
PowerBIOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据 | 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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
ReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 | “File” “Microsoft.Sql/Server/Database” “Microsoft.Storage/Blob”(必需) |
ReferenceInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | ReferenceInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Reference”(必需) |
ScalarFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “标量”(必需) |
序列化
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 | “Avro” “Csv” “Json” “Parquet”(必需) |
ServiceBusQueueOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线队列输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusQueueOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Queue”(必需) |
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。 | 任何 |
ServiceBusTopicOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线主题输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusTopicOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Topic”(必需) |
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。 | ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns |
topicName | 服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
名字 | 描述 | 价值 |
---|
Sku
名字 | 描述 | 价值 |
---|---|---|
名字 | SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | “Standard” |
StorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
StreamingJobProperties
名字 | 描述 | 价值 |
---|---|---|
簇 | 将运行流式处理作业的群集。 | ClusterInfo |
compatibilityLevel | 控制流式处理作业的某些运行时行为。 | '1.0' '1.2' |
contentStoragePolicy | 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则这要求用户也指定 jobStorageAccount 属性。 . | “JobStorageAccount” “SystemAccount” |
dataLocale | 流分析作业的数据区域设置。 值应是集 https://msdn.microsoft.com/en-us/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' |
功能 | 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 函数[] |
输入 | 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,需要每个输入的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输入的 PATCH API。 | 输入[] |
jobStorageAccount | 与 MSI 的 Azure 存储帐户关联的属性 | JobStorageAccount |
jobType | 描述作业的类型。 有效模式 Cloud 和“Edge”。 |
“Cloud” “Edge” |
outputErrorPolicy | 指示要应用于到达输出的事件的策略,并且由于格式不正确(缺少列值、类型错误或大小的列值缺失)而无法写入外部存储。 | 'Drop' “Stop” |
输出 | 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输出的 PATCH API。 | 输出[] |
outputStartMode | 仅当需要创建作业时立即启动该作业时,才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示在启动作业时,输出事件流的起始点是否应启动,从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上一个事件输出时间开始。 | “CustomTime” “JobStartTime” “LastOutputEventTime” |
outputStartTime | 值是一个 ISO-8601 格式的时间戳,指示输出事件流的起始点,或为 null,以指示每当启动流式处理作业时输出事件流将启动。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 | 字符串 |
sku | 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 | Sku |
转型 | 指示要用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 转换 |
StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusStreamInputDataSource,请设置为“GatewayMessageBus”。 对于 IoTHubStreamInputDataSource,请设置为“Microsoft.Devices/IotHubs”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 | “GatewayMessageBus” “Microsoft.Devices/IotHubs” “Microsoft.EventHub/EventHub” “Microsoft.ServiceBus/EventHub” “Microsoft.Storage/Blob”(必需) |
StreamInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | StreamInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Stream”(必需) |
TrackedResourceTags
名字 | 描述 | 价值 |
---|
转型
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与转换关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | TransformationProperties |
TransformationProperties
名字 | 描述 | 价值 |
---|---|---|
查询 | 指定将在流式处理作业中运行的查询。 可以在此处了解有关流分析查询语言(SAQL)的详细信息:https://msdn.microsoft.com/library/azure/dn834998。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
streamingUnits | 指定流式处理作业使用的流单元数。 | int |
validStreamingUnits | 指定流式处理作业可缩放到的有效流单元。 | int[] |
快速入门示例
以下快速入门示例部署此资源类型。
Bicep 文件 | 描述 |
---|---|
创建标准流分析作业 | 此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)中提取的信息中识别模式和关系。 这些模式可用于触发操作并启动工作流,例如创建警报、将信息馈送给报告工具,或存储转换后的数据供以后使用。 此外,流分析在 Azure IoT Edge 运行时上可用,并支持与云相同的确切语言或语法。 |
ARM 模板资源定义
可以使用目标操作部署流式处理作业资源类型:
- 资源组 - 请参阅 资源组部署命令
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
资源格式
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 JSON 添加到模板。
{
"type": "Microsoft.StreamAnalytics/streamingjobs",
"apiVersion": "2020-03-01",
"name": "string",
"identity": {
"type": "string"
},
"location": "string",
"properties": {
"cluster": {
"id": "string"
},
"compatibilityLevel": "string",
"contentStoragePolicy": "string",
"dataLocale": "string",
"eventsLateArrivalMaxDelayInSeconds": "int",
"eventsOutOfOrderMaxDelayInSeconds": "int",
"eventsOutOfOrderPolicy": "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
},
"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"
}
}
],
"outputStartMode": "string",
"outputStartTime": "string",
"sku": {
"name": "string"
},
"transformation": {
"name": "string",
"properties": {
"query": "string",
"streamingUnits": "int",
"validStreamingUnits": [ "int" ]
}
}
},
"tags": {
"{customized property}": "string"
}
}
StreamInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
"properties": {
"topic": "string"
},
"type": "GatewayMessageBus"
}
对于 Microsoft.Devices/IotHubs,请使用:
{
"properties": {
"consumerGroupName": "string",
"endpoint": "string",
"iotHubNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.Devices/IotHubs"
}
对于 Microsoft.EventHub/EventHub,请使用:
{
"properties": {
"authenticationMode": "string",
"consumerGroupName": "string",
"eventHubName": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.EventHub/EventHub"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
"properties": {
"authenticationMode": "string",
"consumerGroupName": "string",
"eventHubName": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"authenticationMode": "string",
"container": "string",
"dateFormat": "string",
"pathPattern": "string",
"sourcePartitionCount": "int",
"storageAccounts": [
{
"accountKey": "string",
"accountName": "string"
}
],
"timeFormat": "string"
},
"type": "Microsoft.Storage/Blob"
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
"properties": {
"topic": "string"
},
"type": "GatewayMessageBus"
}
对于 Microsoft.AzureFunction,请使用:
{
"properties": {
"apiKey": "string",
"functionAppName": "string",
"functionName": "string",
"maxBatchCount": "int",
"maxBatchSize": "int"
},
"type": "Microsoft.AzureFunction"
}
对于 Microsoft.DataLake/Accounts,请使用:
{
"properties": {
"accountName": "string",
"authenticationMode": "string",
"dateFormat": "string",
"filePathPrefix": "string",
"refreshToken": "string",
"tenantId": "string",
"timeFormat": "string",
"tokenUserDisplayName": "string",
"tokenUserPrincipalName": "string"
},
"type": "Microsoft.DataLake/Accounts"
}
对于 Microsoft.EventHub/EventHub,请使用:
{
"properties": {
"authenticationMode": "string",
"eventHubName": "string",
"partitionKey": "string",
"propertyColumns": [ "string" ],
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.EventHub/EventHub"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
"properties": {
"authenticationMode": "string",
"eventHubName": "string",
"partitionKey": "string",
"propertyColumns": [ "string" ],
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
"properties": {
"authenticationMode": "string",
"propertyColumns": [ "string" ],
"queueName": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string",
"systemPropertyColumns": {}
},
"type": "Microsoft.ServiceBus/Queue"
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
"properties": {
"authenticationMode": "string",
"propertyColumns": [ "string" ],
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string",
"systemPropertyColumns": {
"{customized property}": "string"
},
"topicName": "string"
},
"type": "Microsoft.ServiceBus/Topic"
}
对于 Microsoft.Sql/Server/DataWarehouse,请使用:
{
"properties": {
"database": "string",
"password": "string",
"server": "string",
"table": "string",
"user": "string"
},
"type": "Microsoft.Sql/Server/DataWarehouse"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
"properties": {
"authenticationMode": "string",
"database": "string",
"maxBatchCount": "int",
"maxWriterCount": "int",
"password": "string",
"server": "string",
"table": "string",
"user": "string"
},
"type": "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"authenticationMode": "string",
"blobPathPrefix": "string",
"container": "string",
"dateFormat": "string",
"pathPattern": "string",
"storageAccounts": [
{
"accountKey": "string",
"accountName": "string"
}
],
"timeFormat": "string"
},
"type": "Microsoft.Storage/Blob"
}
对于 Microsoft.Storage/DocumentDB,请使用:
{
"properties": {
"accountId": "string",
"accountKey": "string",
"collectionNamePattern": "string",
"database": "string",
"documentId": "string",
"partitionKey": "string"
},
"type": "Microsoft.Storage/DocumentDB"
}
对于 Microsoft.Storage/Table,请使用:
{
"properties": {
"accountKey": "string",
"accountName": "string",
"batchSize": "int",
"columnsToRemove": [ "string" ],
"partitionKey": "string",
"rowKey": "string",
"table": "string"
},
"type": "Microsoft.Storage/Table"
}
对于 PowerBI,请使用:
{
"properties": {
"authenticationMode": "string",
"dataset": "string",
"groupId": "string",
"groupName": "string",
"refreshToken": "string",
"table": "string",
"tokenUserDisplayName": "string",
"tokenUserPrincipalName": "string"
},
"type": "PowerBI"
}
InputProperties 对象
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
"datasource": {
"type": "string"
// For remaining properties, see ReferenceInputDataSource objects
},
"type": "Reference"
}
对于 Stream,请使用:
{
"datasource": {
"type": "string"
// For remaining properties, see StreamInputDataSource objects
},
"type": "Stream"
}
序列化对象
设置 类型 属性以指定对象的类型。
对于 Avro,请使用:
{
"properties": {},
"type": "Avro"
}
对于 Csv,请使用:
{
"properties": {
"encoding": "string",
"fieldDelimiter": "string"
},
"type": "Csv"
}
对于 Json,请使用:
{
"properties": {
"encoding": "string",
"format": "string"
},
"type": "Json"
}
对于 Parquet,请使用:
{
"properties": {},
"type": "Parquet"
}
ReferenceInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 文件,请使用:
{
"properties": {
"path": "string"
},
"type": "File"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
"properties": {
"database": "string",
"deltaSnapshotQuery": "string",
"fullSnapshotQuery": "string",
"password": "string",
"refreshRate": "string",
"refreshType": "string",
"server": "string",
"table": "string",
"user": "string"
},
"type": "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"authenticationMode": "string",
"container": "string",
"dateFormat": "string",
"pathPattern": "string",
"storageAccounts": [
{
"accountKey": "string",
"accountName": "string"
}
],
"timeFormat": "string"
},
"type": "Microsoft.Storage/Blob"
}
FunctionBinding 对象
设置 类型 属性以指定对象的类型。
对于 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"
}
]
},
"type": "Microsoft.MachineLearning/WebService"
}
对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:
{
"properties": {
"script": "string"
},
"type": "Microsoft.StreamAnalytics/JavascriptUdf"
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 聚合,请使用:
{
"type": "Aggregate"
}
对于 标量,请使用:
{
"type": "Scalar"
}
属性值
AggregateFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “Aggregate”(必需) |
AvroSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Avro”(必需) |
AzureDataLakeStoreOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Data Lake Store 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureDataLakeStoreOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.DataLake/Accounts”(必需) |
AzureDataLakeStoreOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountName | Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
dateFormat | 日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 | 字符串 |
filePathPrefix | 输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
refreshToken | 一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
tenantId | 用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
timeFormat | 时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 | 字符串 |
tokenUserDisplayName | 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
tokenUserPrincipalName | 用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
AzureFunctionOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Function 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureFunctionOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.AzureFunction”(必需) |
AzureFunctionOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 如果想要从另一个订阅使用 Azure 函数,可以通过提供用于访问函数的密钥来执行此操作。 | 字符串 |
functionAppName | Azure Functions 应用的名称。 | 字符串 |
functionName | Azure Functions 应用中函数的名称。 | 字符串 |
maxBatchCount | 一个属性,可用于指定发送到 Azure Functions 的每个批处理中的最大事件数。 默认值为 100。 | int |
maxBatchSize | 一个属性,可用于设置发送到 Azure 函数的每个输出批处理的最大大小。 输入单位为字节。 默认情况下,此值为 262,144 字节(256 KB)。 | int |
AzureMachineLearningWebServiceFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 机器学习 Web 服务关联的绑定属性。 | AzureMachineLearningWebServiceFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.MachineLearning/WebService”(必需) |
AzureMachineLearningWebServiceFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 用于对 Request-Response 终结点进行身份验证的 API 密钥。 | 字符串 |
batchSize | 描述每个 Azure ML RRS 执行请求的最大行数的 1 到 10000 之间的数字。 默认值为 1000。 | int |
端点 | Request-Response Azure 机器学习 Web 服务的执行终结点。 在此处了解详细信息:/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs | 字符串 |
输入 | Azure 机器学习 Web 服务终结点的输入。 | AzureMachineLearningWebServiceInputs |
输出 | Azure 机器学习 Web 服务终结点执行的输出列表。 | AzureMachineLearningWebServiceOutputColumn[] |
AzureMachineLearningWebServiceInputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
mapTo | 此输入映射到的函数参数的从零开始的索引。 | int |
名字 | 输入列的名称。 | 字符串 |
AzureMachineLearningWebServiceInputs
名字 | 描述 | 价值 |
---|---|---|
columnNames | Azure 机器学习 Web 服务终结点的输入列列表。 | AzureMachineLearningWebServiceInputColumn[] |
名字 | 输入的名称。 这是创作终结点时提供的名称。 | 字符串 |
AzureMachineLearningWebServiceOutputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输出列的 (Azure 机器学习支持的)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
名字 | 输出列的名称。 | 字符串 |
AzureSqlDatabaseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure SQL 数据库输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlDatabaseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlDatabaseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
maxBatchCount | 写入 Sql 数据库的最大 Batch 计数,默认值为 10,000。 PUT 请求可选。 | int |
maxWriterCount | 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 | int |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureSqlReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 SQL DB 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | 此元素与数据源元素相关联。 这是输出将写入到的数据库的名称。 | 字符串 |
deltaSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 | 字符串 |
fullSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 sql 数据库提取数据。 | 字符串 |
密码 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的密码。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
refreshRate | 此元素与数据源元素相关联。 这表示从数据库提取数据的频率。 它采用 DateTime 格式。 | 字符串 |
refreshType | 指示数据刷新选项的类型。 | “RefreshPeriodicallyWithDelta” “RefreshPeriodicallyWithFull” “Static” |
服务器 | 此元素与数据源元素相关联。 这是包含要写入的数据库的服务器的名称。 | 字符串 |
桌子 | 此元素与数据源元素相关联。 Azure SQL 数据库中表的名称。 | 字符串 |
用户 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的用户名。 | 字符串 |
AzureSynapseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSynapseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/DataWarehouse”(必需) |
AzureSynapseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureTableOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 表输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureTableOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Table”(必需) |
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) 请求时是必需的。 | 字符串 |
BlobOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Blob 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
blobPathPrefix | Blob 路径前缀。 | 字符串 |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
sourcePartitionCount | Blob 输入数据源的分区计数。 范围 1 - 1024。 | int |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
ClusterInfo
名字 | 描述 | 价值 |
---|---|---|
id | 群集的资源 ID。 | 字符串 |
压缩
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示输入使用的压缩类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Deflate” “GZip” “无”(必需) |
CsvSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | CsvSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Csv”(必需) |
CsvSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
fieldDelimiter | 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
DocumentDbOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | DocumentDbOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/DocumentDB”(必需) |
DocumentDbOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountId | DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountKey | DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
collectionNamePattern | 要使用的集合的集合名称模式。 可以使用可选的 {partition} 标记构造集合名称格式,其中分区从 0 开始。 有关详细信息,请参阅 /rest/api/streamanalytics/stream-analytics-output 的 DocumentDB 部分。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
数据库 | DocumentDB 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
documentId | 输出事件中用于指定插入或更新操作所基于的主键的字段的名称。 | 字符串 |
partitionKey | 输出事件中用于指定键以跨集合对输出进行分区的字段的名称。 如果“collectionNamePattern”包含 {partition} 标记,则需要指定此属性。 | 字符串 |
EventHubOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
partitionKey | 用于确定要发送事件数据的分区的键/列。 | 字符串 |
propertyColumns | 与此事件中心输出关联的属性。 | string[] |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
consumerGroupName | 事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 | 字符串 |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubV2OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
EventHubV2StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
FileReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | FileReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “File”(必需) |
FileReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
路径 | 文件的路径。 | 字符串 |
功能
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与函数关联的属性。 | FunctionProperties |
FunctionBinding
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AzureMachineLearningWebServiceFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 | “Microsoft.MachineLearning/WebService” “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
FunctionConfiguration
名字 | 描述 | 价值 |
---|---|---|
捆绑 | 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的情况下,这描述了终结点。 | FunctionBinding |
输入 | FunctionInput[] | |
输出 | 描述函数的输出。 | FunctionOutput |
FunctionInput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输入参数的(支持 Azure 流分析)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
isConfigurationParameter | 指示参数是否为配置参数的标志。 如此 如果此输入参数应为常量。 默认值为 false。 | bool |
FunctionOutput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输出的 (Azure 流分析支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
FunctionProperties
名字 | 描述 | 价值 |
---|---|---|
性能 | FunctionConfiguration | |
类型 | 对于 type AggregateFunctionProperties,设置为“Aggregate”。 对于 ScalarFunctionProperties类型,设置为“Scalar Scalar”。 | “Aggregate” “标量”(必需) |
GatewayMessageBusOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与网关消息总线输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | GatewayMessageBusOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
GatewayMessageBusStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的网关消息总线输入关联的属性。 | GatewayMessageBusStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
身份
名字 | 描述 | 价值 |
---|---|---|
类型 | 标识类型 | 字符串 |
输入
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | InputProperties |
InputProperties
名字 | 描述 | 价值 |
---|---|---|
压缩 | 描述如何压缩输入数据 | 压缩 |
partitionKey | partitionKey 描述用于对输入数据进行分区的输入数据中的键 | 字符串 |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
类型 | 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 | “Reference” “Stream”(必需) |
IoTHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | IoTHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Devices/IotHubs”(必需) |
IoTHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
consumerGroupName | 应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 | 字符串 |
端点 | 要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 | 字符串 |
iotHubNamespace | IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
JavaScriptFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JavaScript 函数关联的绑定属性。 | JavaScriptFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
JavaScriptFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
脚本 | 包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' | 字符串 |
JobStorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
JsonSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JSON 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | JsonSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Json”(必需) |
JsonSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
格式 | 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定输出将写入的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出将设置格式,方法是让每个 JSON 对象用新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果为 null,则默认值为“lineSeparated”。 | “Array” “LineSeparated” |
Microsoft.StreamAnalytics/streamingjobs
名字 | 描述 | 价值 |
---|---|---|
apiVersion | API 版本 | '2020-03-01' |
身份 | 描述分配给此作业的系统分配的托管标识,该标识可用于通过输入和输出进行身份验证。 | 标识 |
位置 | 资源所在的地理位置 | 字符串 |
名字 | 资源名称 | string (必需) |
性能 | 与流式处理作业关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | StreamingJobProperties |
标签 | 资源标记 | 标记名称和值的字典。 请参阅模板 中的 |
类型 | 资源类型 | “Microsoft.StreamAnalytics/streamingjobs” |
输出
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | OutputProperties |
OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubOutputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 ServiceBusQueueOutputDataSource类型,设置为“Microsoft.ServiceBus/Queue”。 对于 ServiceBusTopicOutputDataSource,请设置为“Microsoft.ServiceBus/Topic”。 对于 AzureSynapseOutputDataSource,请设置为“Microsoft.Sql/Server/DataWarehouse”。 对于 AzureSqlDatabaseOutputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobOutputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 DocumentDbOutputDataSource,请设置为“Microsoft.Storage/DocumentDB”。 对于 AzureTableOutputDataSource,请设置为“Microsoft.Storage/Table”。 对于 PowerBIOutputDataSource,请设置为“PowerBI”。 | “GatewayMessageBus” “Microsoft.AzureFunction” “Microsoft.DataLake/Accounts” “Microsoft.EventHub/EventHub” “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”(必需) |
OutputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 | OutputDataSource |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
sizeWindow | 要限制流分析输出的大小窗口。 | int |
timeWindow | 筛选流分析作业输出的时间范围。 | 字符串 |
ParquetSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Parquet”(必需) |
PowerBIOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Power BI 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | PowerBIOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “PowerBI”(必需) |
PowerBIOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据 | 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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
ReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 | “File” “Microsoft.Sql/Server/Database” “Microsoft.Storage/Blob”(必需) |
ReferenceInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | ReferenceInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Reference”(必需) |
ScalarFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “标量”(必需) |
序列化
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 | “Avro” “Csv” “Json” “Parquet”(必需) |
ServiceBusQueueOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线队列输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusQueueOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Queue”(必需) |
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。 | 任何 |
ServiceBusTopicOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线主题输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusTopicOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Topic”(必需) |
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。 | ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns |
topicName | 服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
名字 | 描述 | 价值 |
---|
Sku
名字 | 描述 | 价值 |
---|---|---|
名字 | SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | “Standard” |
StorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
StreamingJobProperties
名字 | 描述 | 价值 |
---|---|---|
簇 | 将运行流式处理作业的群集。 | ClusterInfo |
compatibilityLevel | 控制流式处理作业的某些运行时行为。 | '1.0' '1.2' |
contentStoragePolicy | 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则这要求用户也指定 jobStorageAccount 属性。 . | “JobStorageAccount” “SystemAccount” |
dataLocale | 流分析作业的数据区域设置。 值应是集 https://msdn.microsoft.com/en-us/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' |
功能 | 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 函数[] |
输入 | 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,需要每个输入的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输入的 PATCH API。 | 输入[] |
jobStorageAccount | 与 MSI 的 Azure 存储帐户关联的属性 | JobStorageAccount |
jobType | 描述作业的类型。 有效模式 Cloud 和“Edge”。 |
“Cloud” “Edge” |
outputErrorPolicy | 指示要应用于到达输出的事件的策略,并且由于格式不正确(缺少列值、类型错误或大小的列值缺失)而无法写入外部存储。 | 'Drop' “Stop” |
输出 | 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输出的 PATCH API。 | 输出[] |
outputStartMode | 仅当需要创建作业时立即启动该作业时,才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示在启动作业时,输出事件流的起始点是否应启动,从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上一个事件输出时间开始。 | “CustomTime” “JobStartTime” “LastOutputEventTime” |
outputStartTime | 值是一个 ISO-8601 格式的时间戳,指示输出事件流的起始点,或为 null,以指示每当启动流式处理作业时输出事件流将启动。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 | 字符串 |
sku | 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 | Sku |
转型 | 指示要用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 转换 |
StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusStreamInputDataSource,请设置为“GatewayMessageBus”。 对于 IoTHubStreamInputDataSource,请设置为“Microsoft.Devices/IotHubs”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 | “GatewayMessageBus” “Microsoft.Devices/IotHubs” “Microsoft.EventHub/EventHub” “Microsoft.ServiceBus/EventHub” “Microsoft.Storage/Blob”(必需) |
StreamInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | StreamInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Stream”(必需) |
TrackedResourceTags
名字 | 描述 | 价值 |
---|
转型
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与转换关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | TransformationProperties |
TransformationProperties
名字 | 描述 | 价值 |
---|---|---|
查询 | 指定将在流式处理作业中运行的查询。 可以在此处了解有关流分析查询语言(SAQL)的详细信息:https://msdn.microsoft.com/library/azure/dn834998。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
streamingUnits | 指定流式处理作业使用的流单元数。 | int |
validStreamingUnits | 指定流式处理作业可缩放到的有效流单元。 | int[] |
快速入门模板
以下快速入门模板部署此资源类型。
模板 | 描述 |
---|---|
创建标准流分析作业 |
此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)中提取的信息中识别模式和关系。 这些模式可用于触发操作并启动工作流,例如创建警报、将信息馈送给报告工具,或存储转换后的数据供以后使用。 此外,流分析在 Azure IoT Edge 运行时上可用,并支持与云相同的确切语言或语法。 |
Terraform (AzAPI 提供程序)资源定义
可以使用目标操作部署流式处理作业资源类型:
- 资源组
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
资源格式
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 Terraform 添加到模板。
resource "azapi_resource" "symbolicname" {
type = "Microsoft.StreamAnalytics/streamingjobs@2020-03-01"
name = "string"
identity = {
type = "string"
}
location = "string"
tags = {
{customized property} = "string"
}
body = jsonencode({
properties = {
cluster = {
id = "string"
}
compatibilityLevel = "string"
contentStoragePolicy = "string"
dataLocale = "string"
eventsLateArrivalMaxDelayInSeconds = int
eventsOutOfOrderMaxDelayInSeconds = int
eventsOutOfOrderPolicy = "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
}
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"
}
}
]
outputStartMode = "string"
outputStartTime = "string"
sku = {
name = "string"
}
transformation = {
name = "string"
properties = {
query = "string"
streamingUnits = int
validStreamingUnits = [
int
]
}
}
}
})
}
StreamInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
properties = {
topic = "string"
}
type = "GatewayMessageBus"
}
对于 Microsoft.Devices/IotHubs,请使用:
{
properties = {
consumerGroupName = "string"
endpoint = "string"
iotHubNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.Devices/IotHubs"
}
对于 Microsoft.EventHub/EventHub,请使用:
{
properties = {
authenticationMode = "string"
consumerGroupName = "string"
eventHubName = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.EventHub/EventHub"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties = {
authenticationMode = "string"
consumerGroupName = "string"
eventHubName = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
authenticationMode = "string"
container = "string"
dateFormat = "string"
pathPattern = "string"
sourcePartitionCount = int
storageAccounts = [
{
accountKey = "string"
accountName = "string"
}
]
timeFormat = "string"
}
type = "Microsoft.Storage/Blob"
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 GatewayMessageBus,请使用:
{
properties = {
topic = "string"
}
type = "GatewayMessageBus"
}
对于 Microsoft.AzureFunction,请使用:
{
properties = {
apiKey = "string"
functionAppName = "string"
functionName = "string"
maxBatchCount = int
maxBatchSize = int
}
type = "Microsoft.AzureFunction"
}
对于 Microsoft.DataLake/Accounts,请使用:
{
properties = {
accountName = "string"
authenticationMode = "string"
dateFormat = "string"
filePathPrefix = "string"
refreshToken = "string"
tenantId = "string"
timeFormat = "string"
tokenUserDisplayName = "string"
tokenUserPrincipalName = "string"
}
type = "Microsoft.DataLake/Accounts"
}
对于 Microsoft.EventHub/EventHub,请使用:
{
properties = {
authenticationMode = "string"
eventHubName = "string"
partitionKey = "string"
propertyColumns = [
"string"
]
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.EventHub/EventHub"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties = {
authenticationMode = "string"
eventHubName = "string"
partitionKey = "string"
propertyColumns = [
"string"
]
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
properties = {
authenticationMode = "string"
propertyColumns = [
"string"
]
queueName = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
systemPropertyColumns = ?
}
type = "Microsoft.ServiceBus/Queue"
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
properties = {
authenticationMode = "string"
propertyColumns = [
"string"
]
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
systemPropertyColumns = {
{customized property} = "string"
}
topicName = "string"
}
type = "Microsoft.ServiceBus/Topic"
}
对于 Microsoft.Sql/Server/DataWarehouse,请使用:
{
properties = {
database = "string"
password = "string"
server = "string"
table = "string"
user = "string"
}
type = "Microsoft.Sql/Server/DataWarehouse"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties = {
authenticationMode = "string"
database = "string"
maxBatchCount = int
maxWriterCount = int
password = "string"
server = "string"
table = "string"
user = "string"
}
type = "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
authenticationMode = "string"
blobPathPrefix = "string"
container = "string"
dateFormat = "string"
pathPattern = "string"
storageAccounts = [
{
accountKey = "string"
accountName = "string"
}
]
timeFormat = "string"
}
type = "Microsoft.Storage/Blob"
}
对于 Microsoft.Storage/DocumentDB,请使用:
{
properties = {
accountId = "string"
accountKey = "string"
collectionNamePattern = "string"
database = "string"
documentId = "string"
partitionKey = "string"
}
type = "Microsoft.Storage/DocumentDB"
}
对于 Microsoft.Storage/Table,请使用:
{
properties = {
accountKey = "string"
accountName = "string"
batchSize = int
columnsToRemove = [
"string"
]
partitionKey = "string"
rowKey = "string"
table = "string"
}
type = "Microsoft.Storage/Table"
}
对于 PowerBI,请使用:
{
properties = {
authenticationMode = "string"
dataset = "string"
groupId = "string"
groupName = "string"
refreshToken = "string"
table = "string"
tokenUserDisplayName = "string"
tokenUserPrincipalName = "string"
}
type = "PowerBI"
}
InputProperties 对象
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
datasource = {
type = "string"
// For remaining properties, see ReferenceInputDataSource objects
}
type = "Reference"
}
对于 Stream,请使用:
{
datasource = {
type = "string"
// For remaining properties, see StreamInputDataSource objects
}
type = "Stream"
}
序列化对象
设置 类型 属性以指定对象的类型。
对于 Avro,请使用:
{
properties = ?
type = "Avro"
}
对于 Csv,请使用:
{
properties = {
encoding = "string"
fieldDelimiter = "string"
}
type = "Csv"
}
对于 Json,请使用:
{
properties = {
encoding = "string"
format = "string"
}
type = "Json"
}
对于 Parquet,请使用:
{
properties = ?
type = "Parquet"
}
ReferenceInputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 文件,请使用:
{
properties = {
path = "string"
}
type = "File"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties = {
database = "string"
deltaSnapshotQuery = "string"
fullSnapshotQuery = "string"
password = "string"
refreshRate = "string"
refreshType = "string"
server = "string"
table = "string"
user = "string"
}
type = "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
authenticationMode = "string"
container = "string"
dateFormat = "string"
pathPattern = "string"
storageAccounts = [
{
accountKey = "string"
accountName = "string"
}
]
timeFormat = "string"
}
type = "Microsoft.Storage/Blob"
}
FunctionBinding 对象
设置 类型 属性以指定对象的类型。
对于 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"
}
]
}
type = "Microsoft.MachineLearning/WebService"
}
对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:
{
properties = {
script = "string"
}
type = "Microsoft.StreamAnalytics/JavascriptUdf"
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 聚合,请使用:
{
type = "Aggregate"
}
对于 标量,请使用:
{
type = "Scalar"
}
属性值
AggregateFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “Aggregate”(必需) |
AvroSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Avro”(必需) |
AzureDataLakeStoreOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Data Lake Store 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureDataLakeStoreOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.DataLake/Accounts”(必需) |
AzureDataLakeStoreOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountName | Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
dateFormat | 日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 | 字符串 |
filePathPrefix | 输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
refreshToken | 一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
tenantId | 用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
timeFormat | 时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 | 字符串 |
tokenUserDisplayName | 用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
tokenUserPrincipalName | 用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
AzureFunctionOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Function 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureFunctionOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.AzureFunction”(必需) |
AzureFunctionOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 如果想要从另一个订阅使用 Azure 函数,可以通过提供用于访问函数的密钥来执行此操作。 | 字符串 |
functionAppName | Azure Functions 应用的名称。 | 字符串 |
functionName | Azure Functions 应用中函数的名称。 | 字符串 |
maxBatchCount | 一个属性,可用于指定发送到 Azure Functions 的每个批处理中的最大事件数。 默认值为 100。 | int |
maxBatchSize | 一个属性,可用于设置发送到 Azure 函数的每个输出批处理的最大大小。 输入单位为字节。 默认情况下,此值为 262,144 字节(256 KB)。 | int |
AzureMachineLearningWebServiceFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 机器学习 Web 服务关联的绑定属性。 | AzureMachineLearningWebServiceFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.MachineLearning/WebService”(必需) |
AzureMachineLearningWebServiceFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
apiKey | 用于对 Request-Response 终结点进行身份验证的 API 密钥。 | 字符串 |
batchSize | 描述每个 Azure ML RRS 执行请求的最大行数的 1 到 10000 之间的数字。 默认值为 1000。 | int |
端点 | Request-Response Azure 机器学习 Web 服务的执行终结点。 在此处了解详细信息:/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs | 字符串 |
输入 | Azure 机器学习 Web 服务终结点的输入。 | AzureMachineLearningWebServiceInputs |
输出 | Azure 机器学习 Web 服务终结点执行的输出列表。 | AzureMachineLearningWebServiceOutputColumn[] |
AzureMachineLearningWebServiceInputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
mapTo | 此输入映射到的函数参数的从零开始的索引。 | int |
名字 | 输入列的名称。 | 字符串 |
AzureMachineLearningWebServiceInputs
名字 | 描述 | 价值 |
---|---|---|
columnNames | Azure 机器学习 Web 服务终结点的输入列列表。 | AzureMachineLearningWebServiceInputColumn[] |
名字 | 输入的名称。 这是创作终结点时提供的名称。 | 字符串 |
AzureMachineLearningWebServiceOutputColumn
名字 | 描述 | 价值 |
---|---|---|
dataType | 输出列的 (Azure 机器学习支持的)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 | 字符串 |
名字 | 输出列的名称。 | 字符串 |
AzureSqlDatabaseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure SQL 数据库输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlDatabaseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlDatabaseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
maxBatchCount | 写入 Sql 数据库的最大 Batch 计数,默认值为 10,000。 PUT 请求可选。 | int |
maxWriterCount | 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 | int |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureSqlReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 SQL DB 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSqlReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/Database”(必需) |
AzureSqlReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | 此元素与数据源元素相关联。 这是输出将写入到的数据库的名称。 | 字符串 |
deltaSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 SQL 数据库提取增量更改。 若要使用此选项,建议在 Azure SQL 数据库中使用临时表。 | 字符串 |
fullSnapshotQuery | 此元素与数据源元素相关联。 此查询用于从 sql 数据库提取数据。 | 字符串 |
密码 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的密码。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
refreshRate | 此元素与数据源元素相关联。 这表示从数据库提取数据的频率。 它采用 DateTime 格式。 | 字符串 |
refreshType | 指示数据刷新选项的类型。 | “RefreshPeriodicallyWithDelta” “RefreshPeriodicallyWithFull” “Static” |
服务器 | 此元素与数据源元素相关联。 这是包含要写入的数据库的服务器的名称。 | 字符串 |
桌子 | 此元素与数据源元素相关联。 Azure SQL 数据库中表的名称。 | 字符串 |
用户 | 此元素与数据源元素相关联。 这是用于连接到 SQL 数据库实例的用户名。 | 字符串 |
AzureSynapseOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureSynapseOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Sql/Server/DataWarehouse”(必需) |
AzureSynapseOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
数据库 | Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
密码 | 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 约束: 敏感值。 以安全参数的形式传入。 |
服务器 | 包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
桌子 | Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
用户 | 将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
AzureTableOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Azure 表输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | AzureTableOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Table”(必需) |
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) 请求时是必需的。 | 字符串 |
BlobOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Blob 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
blobPathPrefix | Blob 路径前缀。 | 字符串 |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
BlobStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | BlobStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/Blob”(必需) |
BlobStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
容器 | 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
dateFormat | 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 | 字符串 |
pathPattern | Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 | 字符串 |
sourcePartitionCount | Blob 输入数据源的分区计数。 范围 1 - 1024。 | int |
storageAccounts | 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 | StorageAccount[] |
timeFormat | 时间格式。 无论 {time} 出现在 pathPattern 中,此属性的值将改为用作时间格式。 | 字符串 |
ClusterInfo
名字 | 描述 | 价值 |
---|---|---|
id | 群集的资源 ID。 | 字符串 |
压缩
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示输入使用的压缩类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Deflate” “GZip” “无”(必需) |
CsvSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | CsvSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Csv”(必需) |
CsvSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
fieldDelimiter | 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
DocumentDbOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | DocumentDbOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Storage/DocumentDB”(必需) |
DocumentDbOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
accountId | DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountKey | DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
collectionNamePattern | 要使用的集合的集合名称模式。 可以使用可选的 {partition} 标记构造集合名称格式,其中分区从 0 开始。 有关详细信息,请参阅 /rest/api/streamanalytics/stream-analytics-output 的 DocumentDB 部分。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
数据库 | DocumentDB 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
documentId | 输出事件中用于指定插入或更新操作所基于的主键的字段的名称。 | 字符串 |
partitionKey | 输出事件中用于指定键以跨集合对输出进行分区的字段的名称。 如果“collectionNamePattern”包含 {partition} 标记,则需要指定此属性。 | 字符串 |
EventHubOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
partitionKey | 用于确定要发送事件数据的分区的键/列。 | 字符串 |
propertyColumns | 与此事件中心输出关联的属性。 | string[] |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/EventHub”(必需) |
EventHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
consumerGroupName | 事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 | 字符串 |
eventHubName | 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
serviceBusNamespace | 与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | 事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
EventHubV2OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
EventHubV2StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | EventHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.EventHub/EventHub”(必需) |
FileReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | FileReferenceInputDataSourceProperties |
类型 | 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “File”(必需) |
FileReferenceInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
路径 | 文件的路径。 | 字符串 |
功能
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与函数关联的属性。 | FunctionProperties |
FunctionBinding
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AzureMachineLearningWebServiceFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 | “Microsoft.MachineLearning/WebService” “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
FunctionConfiguration
名字 | 描述 | 价值 |
---|---|---|
捆绑 | 函数的物理绑定。 例如,在 Azure 机器学习 Web 服务的情况下,这描述了终结点。 | FunctionBinding |
输入 | FunctionInput[] | |
输出 | 描述函数的输出。 | FunctionOutput |
FunctionInput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输入参数的(支持 Azure 流分析)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
isConfigurationParameter | 指示参数是否为配置参数的标志。 如此 如果此输入参数应为常量。 默认值为 false。 | bool |
FunctionOutput
名字 | 描述 | 价值 |
---|---|---|
dataType | 函数输出的 (Azure 流分析支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx 介绍了有效的 Azure 流分析数据类型列表 | 字符串 |
FunctionProperties
名字 | 描述 | 价值 |
---|---|---|
性能 | FunctionConfiguration | |
类型 | 对于 type AggregateFunctionProperties,设置为“Aggregate”。 对于 ScalarFunctionProperties类型,设置为“Scalar Scalar”。 | “Aggregate” “标量”(必需) |
GatewayMessageBusOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与网关消息总线输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | GatewayMessageBusOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
GatewayMessageBusStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的网关消息总线输入关联的属性。 | GatewayMessageBusStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “GatewayMessageBus”(必需) |
GatewayMessageBusStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
主题 | 服务总线主题的名称。 | 字符串 |
身份
名字 | 描述 | 价值 |
---|---|---|
类型 | 标识类型 | 字符串 |
输入
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | InputProperties |
InputProperties
名字 | 描述 | 价值 |
---|---|---|
压缩 | 描述如何压缩输入数据 | 压缩 |
partitionKey | partitionKey 描述用于对输入数据进行分区的输入数据中的键 | 字符串 |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
类型 | 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 | “Reference” “Stream”(必需) |
IoTHubStreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | IoTHubStreamInputDataSourceProperties |
类型 | 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.Devices/IotHubs”(必需) |
IoTHubStreamInputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
consumerGroupName | 应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 | 字符串 |
端点 | 要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 | 字符串 |
iotHubNamespace | IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyKey | 指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
sharedAccessPolicyName | IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
JavaScriptFunctionBinding
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JavaScript 函数关联的绑定属性。 | JavaScriptFunctionBindingProperties |
类型 | 指示函数绑定类型。 | “Microsoft.StreamAnalytics/JavascriptUdf”(必需) |
JavaScriptFunctionBindingProperties
名字 | 描述 | 价值 |
---|---|---|
脚本 | 包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' | 字符串 |
JobStorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
JsonSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 JSON 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | JsonSerializationProperties |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Json”(必需) |
JsonSerializationProperties
名字 | 描述 | 价值 |
---|---|---|
编码 | 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 | “UTF8” |
格式 | 此属性仅适用于输出的 JSON 序列化。 它不适用于输入。 此属性指定输出将写入的 JSON 的格式。 当前支持的值是“lineSeparated”,指示输出将设置格式,方法是让每个 JSON 对象用新行分隔,“array”指示输出将格式化为 JSON 对象的数组。 如果为 null,则默认值为“lineSeparated”。 | “Array” “LineSeparated” |
Microsoft.StreamAnalytics/streamingjobs
名字 | 描述 | 价值 |
---|---|---|
身份 | 描述分配给此作业的系统分配的托管标识,该标识可用于通过输入和输出进行身份验证。 | 标识 |
位置 | 资源所在的地理位置 | 字符串 |
名字 | 资源名称 | string (必需) |
性能 | 与流式处理作业关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | StreamingJobProperties |
标签 | 资源标记 | 标记名称和值的字典。 |
类型 | 资源类型 | “Microsoft.StreamAnalytics/streamingjobs@2020-03-01” |
输出
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | OutputProperties |
OutputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubOutputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 ServiceBusQueueOutputDataSource类型,设置为“Microsoft.ServiceBus/Queue”。 对于 ServiceBusTopicOutputDataSource,请设置为“Microsoft.ServiceBus/Topic”。 对于 AzureSynapseOutputDataSource,请设置为“Microsoft.Sql/Server/DataWarehouse”。 对于 AzureSqlDatabaseOutputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobOutputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 DocumentDbOutputDataSource,请设置为“Microsoft.Storage/DocumentDB”。 对于 AzureTableOutputDataSource,请设置为“Microsoft.Storage/Table”。 对于 PowerBIOutputDataSource,请设置为“PowerBI”。 | “GatewayMessageBus” “Microsoft.AzureFunction” “Microsoft.DataLake/Accounts” “Microsoft.EventHub/EventHub” “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”(必需) |
OutputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 | OutputDataSource |
序列化 | 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 | 序列化 |
sizeWindow | 要限制流分析输出的大小窗口。 | int |
timeWindow | 筛选流分析作业输出的时间范围。 | 字符串 |
ParquetSerialization
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | 任何 |
类型 | 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Parquet”(必需) |
PowerBIOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与 Power BI 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | PowerBIOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “PowerBI”(必需) |
PowerBIOutputDataSourceProperties
名字 | 描述 | 价值 |
---|---|---|
authenticationMode | 身份验证模式。 | “ConnectionString” “Msi” “UserToken” |
数据 | 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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 | 字符串 |
ReferenceInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 | “File” “Microsoft.Sql/Server/Database” “Microsoft.Storage/Blob”(必需) |
ReferenceInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | ReferenceInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Reference”(必需) |
ScalarFunctionProperties
名字 | 描述 | 价值 |
---|---|---|
类型 | 指示函数的类型。 | “标量”(必需) |
序列化
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 | “Avro” “Csv” “Json” “Parquet”(必需) |
ServiceBusQueueOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线队列输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusQueueOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Queue”(必需) |
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。 | 任何 |
ServiceBusTopicOutputDataSource
名字 | 描述 | 价值 |
---|---|---|
性能 | 与服务总线主题输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | ServiceBusTopicOutputDataSourceProperties |
类型 | 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 | “Microsoft.ServiceBus/Topic”(必需) |
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。 | ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns |
topicName | 服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
名字 | 描述 | 价值 |
---|
Sku
名字 | 描述 | 价值 |
---|---|---|
名字 | SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 | “Standard” |
StorageAccount
名字 | 描述 | 价值 |
---|---|---|
accountKey | Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
accountName | Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
StreamingJobProperties
名字 | 描述 | 价值 |
---|---|---|
簇 | 将运行流式处理作业的群集。 | ClusterInfo |
compatibilityLevel | 控制流式处理作业的某些运行时行为。 | '1.0' '1.2' |
contentStoragePolicy | 有效值为 JobStorageAccount 和 SystemAccount。 如果设置为 JobStorageAccount,则这要求用户也指定 jobStorageAccount 属性。 . | “JobStorageAccount” “SystemAccount” |
dataLocale | 流分析作业的数据区域设置。 值应是集 https://msdn.microsoft.com/en-us/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' |
功能 | 流式处理作业的一个或多个函数的列表。 在 PUT 请求中指定此属性时,需要每个函数的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 函数[] |
输入 | 流式处理作业的一个或多个输入的列表。 在 PUT 请求中指定此属性时,需要每个输入的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输入的 PATCH API。 | 输入[] |
jobStorageAccount | 与 MSI 的 Azure 存储帐户关联的属性 | JobStorageAccount |
jobType | 描述作业的类型。 有效模式 Cloud 和“Edge”。 |
“Cloud” “Edge” |
outputErrorPolicy | 指示要应用于到达输出的事件的策略,并且由于格式不正确(缺少列值、类型错误或大小的列值缺失)而无法写入外部存储。 | 'Drop' “Stop” |
输出 | 流式处理作业的一个或多个输出的列表。 在 PUT 请求中指定此属性时,需要每个输出的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个输出的 PATCH API。 | 输出[] |
outputStartMode | 仅当需要创建作业时立即启动该作业时,才应使用此属性。 值可以是 JobStartTime、CustomTime 或 LastOutputEventTime,以指示在启动作业时,输出事件流的起始点是否应启动,从通过 outputStartTime 属性指定的自定义用户时间戳开始,还是从上一个事件输出时间开始。 | “CustomTime” “JobStartTime” “LastOutputEventTime” |
outputStartTime | 值是一个 ISO-8601 格式的时间戳,指示输出事件流的起始点,或为 null,以指示每当启动流式处理作业时输出事件流将启动。 如果 outputStartMode 设置为 CustomTime,此属性必须具有值。 | 字符串 |
sku | 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 | Sku |
转型 | 指示要用于流式处理作业的查询和流单元数。 在 PUT 请求中指定此属性时,需要转换的名称属性。 此属性不能通过 PATCH 操作进行修改。 必须使用可用于单个转换的 PATCH API。 | 转换 |
StreamInputDataSource
名字 | 描述 | 价值 |
---|---|---|
类型 | 对于 GatewayMessageBusStreamInputDataSource,请设置为“GatewayMessageBus”。 对于 IoTHubStreamInputDataSource,请设置为“Microsoft.Devices/IotHubs”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 | “GatewayMessageBus” “Microsoft.Devices/IotHubs” “Microsoft.EventHub/EventHub” “Microsoft.ServiceBus/EventHub” “Microsoft.Storage/Blob”(必需) |
StreamInputProperties
名字 | 描述 | 价值 |
---|---|---|
数据源 | 描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 | StreamInputDataSource |
类型 | 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 | “Stream”(必需) |
TrackedResourceTags
名字 | 描述 | 价值 |
---|
转型
名字 | 描述 | 价值 |
---|---|---|
名字 | 资源名称 | 字符串 |
性能 | 与转换关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 | TransformationProperties |
TransformationProperties
名字 | 描述 | 价值 |
---|---|---|
查询 | 指定将在流式处理作业中运行的查询。 可以在此处了解有关流分析查询语言(SAQL)的详细信息:https://msdn.microsoft.com/library/azure/dn834998。 PUT (CreateOrReplace) 请求时是必需的。 | 字符串 |
streamingUnits | 指定流式处理作业使用的流单元数。 | int |
validStreamingUnits | 指定流式处理作业可缩放到的有效流单元。 | int[] |