你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
Microsoft.StreamAnalytics streamingjobs 2016-03-01
Bicep 资源定义
可以使用目标操作部署流式处理作业资源类型:
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 Bicep 添加到模板。
resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2016-03-01' = {
location: 'string'
name: 'string'
properties: {
compatibilityLevel: 'string'
dataLocale: 'string'
eventsLateArrivalMaxDelayInSeconds: int
eventsOutOfOrderMaxDelayInSeconds: int
eventsOutOfOrderPolicy: 'string'
functions: [
{
name: 'string'
properties: {
type: 'string'
// For remaining properties, see FunctionProperties objects
}
}
]
inputs: [
{
name: 'string'
properties: {
serialization: {
type: 'string'
// For remaining properties, see Serialization objects
}
type: 'string'
// For remaining properties, see InputProperties objects
}
}
]
outputErrorPolicy: 'string'
outputs: [
{
name: 'string'
properties: {
datasource: {
type: 'string'
// For remaining properties, see OutputDataSource objects
}
serialization: {
type: 'string'
// For remaining properties, see Serialization objects
}
}
}
]
outputStartMode: 'string'
outputStartTime: 'string'
sku: {
name: 'string'
}
transformation: {
name: 'string'
properties: {
query: 'string'
streamingUnits: int
}
}
}
tags: {
{customized property}: 'string'
}
}
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'
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Devices/IotHubs,请使用:
{
properties: {
consumerGroupName: 'string'
endpoint: 'string'
iotHubNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.Devices/IotHubs'
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties: {
consumerGroupName: 'string'
eventHubName: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.ServiceBus/EventHub'
}
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
container: 'string'
dateFormat: 'string'
pathPattern: 'string'
sourcePartitionCount: int
storageAccounts: [
{
accountKey: 'string'
accountName: 'string'
}
]
timeFormat: 'string'
}
type: 'Microsoft.Storage/Blob'
}
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
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'
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 标量,请使用:
{
properties: {
binding: {
type: 'string'
// For remaining properties, see FunctionBinding objects
}
inputs: [
{
dataType: 'string'
isConfigurationParameter: bool
}
]
output: {
dataType: 'string'
}
}
type: 'Scalar'
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 Microsoft.DataLake/Accounts,请使用:
{
properties: {
accountName: 'string'
dateFormat: 'string'
filePathPrefix: 'string'
refreshToken: 'string'
tenantId: 'string'
timeFormat: 'string'
tokenUserDisplayName: 'string'
tokenUserPrincipalName: 'string'
}
type: 'Microsoft.DataLake/Accounts'
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties: {
eventHubName: 'string'
partitionKey: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.ServiceBus/EventHub'
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
properties: {
propertyColumns: [
'string'
]
queueName: 'string'
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
}
type: 'Microsoft.ServiceBus/Queue'
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
properties: {
propertyColumns: [
'string'
]
serviceBusNamespace: 'string'
sharedAccessPolicyKey: 'string'
sharedAccessPolicyName: 'string'
topicName: 'string'
}
type: 'Microsoft.ServiceBus/Topic'
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties: {
database: 'string'
password: 'string'
server: 'string'
table: 'string'
user: 'string'
}
type: 'Microsoft.Sql/Server/Database'
}
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
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: {
dataset: 'string'
groupId: 'string'
groupName: 'string'
refreshToken: 'string'
table: 'string'
tokenUserDisplayName: 'string'
tokenUserPrincipalName: 'string'
}
type: 'PowerBI'
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Storage/Blob,请使用:
{
properties: {
container: 'string'
dateFormat: 'string'
pathPattern: 'string'
storageAccounts: [
{
accountKey: 'string'
accountName: 'string'
}
]
timeFormat: 'string'
}
type: 'Microsoft.Storage/Blob'
}
属性值
AvroSerialization
名字 |
描述 |
价值 |
性能 |
与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
任何 |
类型 |
指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Avro”(必需) |
AzureDataLakeStoreOutputDataSource
AzureDataLakeStoreOutputDataSourceProperties
名字 |
描述 |
价值 |
accountName |
Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
dateFormat |
日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 |
字符串 |
filePathPrefix |
输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
refreshToken |
一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
tenantId |
用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
timeFormat |
时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 |
字符串 |
tokenUserDisplayName |
用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
tokenUserPrincipalName |
用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
AzureMachineLearningWebServiceFunctionBinding
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[] |
AzureMachineLearningWebServiceOutputColumn
AzureSqlDatabaseOutputDataSource
AzureSqlDatabaseOutputDataSourceProperties
名字 |
描述 |
价值 |
数据库 |
Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
密码 |
将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
服务器 |
包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
桌子 |
Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
用户 |
将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
AzureTableOutputDataSource
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
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
BlobStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Storage/Blob”(必需) |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
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
名字 |
描述 |
价值 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
partitionKey |
用于确定要发送事件数据的分区的键/列。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
名字 |
描述 |
价值 |
consumerGroupName |
事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 |
字符串 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
功能
FunctionBinding
FunctionOutput
FunctionProperties
名字 |
描述 |
价值 |
名字 |
资源名称 |
字符串 |
性能 |
与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
InputProperties |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
IoTHubStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Devices/IotHubs”(必需) |
名字 |
描述 |
价值 |
consumerGroupName |
应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 |
字符串 |
端点 |
要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 |
字符串 |
iotHubNamespace |
IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
JavaScriptFunctionBinding
JavaScriptFunctionBindingProperties
名字 |
描述 |
价值 |
脚本 |
包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' |
字符串 |
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
OutputProperties
名字 |
描述 |
价值 |
数据源 |
描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
OutputDataSource |
序列化 |
描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 |
序列化 |
PowerBIOutputDataSource
PowerBIOutputDataSourceProperties
名字 |
描述 |
价值 |
数据 |
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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
名字 |
描述 |
价值 |
数据源 |
描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
ReferenceInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Reference”(必需) |
ScalarFunctionConfiguration
ScalarFunctionProperties
序列化
ServiceBusQueueOutputDataSource
ServiceBusQueueOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
queueName |
服务总线队列的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
ServiceBusTopicOutputDataSource
ServiceBusTopicOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
topicName |
服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
Sku
名字 |
描述 |
价值 |
名字 |
SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
“Standard” |
StorageAccount
名字 |
描述 |
价值 |
accountKey |
Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
accountName |
Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
StreamingJobProperties
名字 |
描述 |
价值 |
compatibilityLevel |
控制流式处理作业的某些运行时行为。 |
'1.0' |
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。 |
输入[] |
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。 |
转换 |
名字 |
描述 |
价值 |
数据源 |
描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
StreamInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Stream”(必需) |
快速入门示例
以下快速入门示例部署此资源类型。
Bicep 文件 |
描述 |
创建标准流分析作业 |
此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)中提取的信息中识别模式和关系。 这些模式可用于触发操作并启动工作流,例如创建警报、将信息馈送给报告工具,或存储转换后的数据供以后使用。 此外,流分析在 Azure IoT Edge 运行时上可用,并支持与云相同的确切语言或语法。 |
ARM 模板资源定义
可以使用目标操作部署流式处理作业资源类型:
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 JSON 添加到模板。
{
"type": "Microsoft.StreamAnalytics/streamingjobs",
"apiVersion": "2016-03-01",
"name": "string",
"location": "string",
"properties": {
"compatibilityLevel": "string",
"dataLocale": "string",
"eventsLateArrivalMaxDelayInSeconds": "int",
"eventsOutOfOrderMaxDelayInSeconds": "int",
"eventsOutOfOrderPolicy": "string",
"functions": [
{
"name": "string",
"properties": {
"type": "string"
// For remaining properties, see FunctionProperties objects
}
}
],
"inputs": [
{
"name": "string",
"properties": {
"serialization": {
"type": "string"
// For remaining properties, see Serialization objects
},
"type": "string"
// For remaining properties, see InputProperties objects
}
}
],
"outputErrorPolicy": "string",
"outputs": [
{
"name": "string",
"properties": {
"datasource": {
"type": "string"
// For remaining properties, see OutputDataSource objects
},
"serialization": {
"type": "string"
// For remaining properties, see Serialization objects
}
}
}
],
"outputStartMode": "string",
"outputStartTime": "string",
"sku": {
"name": "string"
},
"transformation": {
"name": "string",
"properties": {
"query": "string",
"streamingUnits": "int"
}
}
},
"tags": {
"{customized property}": "string"
}
}
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"
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Devices/IotHubs,请使用:
{
"properties": {
"consumerGroupName": "string",
"endpoint": "string",
"iotHubNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.Devices/IotHubs"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
"properties": {
"consumerGroupName": "string",
"eventHubName": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"container": "string",
"dateFormat": "string",
"pathPattern": "string",
"sourcePartitionCount": "int",
"storageAccounts": [
{
"accountKey": "string",
"accountName": "string"
}
],
"timeFormat": "string"
},
"type": "Microsoft.Storage/Blob"
}
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
"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"
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 标量,请使用:
{
"properties": {
"binding": {
"type": "string"
// For remaining properties, see FunctionBinding objects
},
"inputs": [
{
"dataType": "string",
"isConfigurationParameter": "bool"
}
],
"output": {
"dataType": "string"
}
},
"type": "Scalar"
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 Microsoft.DataLake/Accounts,请使用:
{
"properties": {
"accountName": "string",
"dateFormat": "string",
"filePathPrefix": "string",
"refreshToken": "string",
"tenantId": "string",
"timeFormat": "string",
"tokenUserDisplayName": "string",
"tokenUserPrincipalName": "string"
},
"type": "Microsoft.DataLake/Accounts"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
"properties": {
"eventHubName": "string",
"partitionKey": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
"properties": {
"propertyColumns": [ "string" ],
"queueName": "string",
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string"
},
"type": "Microsoft.ServiceBus/Queue"
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
"properties": {
"propertyColumns": [ "string" ],
"serviceBusNamespace": "string",
"sharedAccessPolicyKey": "string",
"sharedAccessPolicyName": "string",
"topicName": "string"
},
"type": "Microsoft.ServiceBus/Topic"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
"properties": {
"database": "string",
"password": "string",
"server": "string",
"table": "string",
"user": "string"
},
"type": "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"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": {
"dataset": "string",
"groupId": "string",
"groupName": "string",
"refreshToken": "string",
"table": "string",
"tokenUserDisplayName": "string",
"tokenUserPrincipalName": "string"
},
"type": "PowerBI"
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Storage/Blob,请使用:
{
"properties": {
"container": "string",
"dateFormat": "string",
"pathPattern": "string",
"storageAccounts": [
{
"accountKey": "string",
"accountName": "string"
}
],
"timeFormat": "string"
},
"type": "Microsoft.Storage/Blob"
}
属性值
AvroSerialization
名字 |
描述 |
价值 |
性能 |
与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
任何 |
类型 |
指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Avro”(必需) |
AzureDataLakeStoreOutputDataSource
AzureDataLakeStoreOutputDataSourceProperties
名字 |
描述 |
价值 |
accountName |
Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
dateFormat |
日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 |
字符串 |
filePathPrefix |
输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
refreshToken |
一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
tenantId |
用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
timeFormat |
时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 |
字符串 |
tokenUserDisplayName |
用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
tokenUserPrincipalName |
用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
AzureMachineLearningWebServiceFunctionBinding
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[] |
AzureMachineLearningWebServiceOutputColumn
AzureSqlDatabaseOutputDataSource
AzureSqlDatabaseOutputDataSourceProperties
名字 |
描述 |
价值 |
数据库 |
Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
密码 |
将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
服务器 |
包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
桌子 |
Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
用户 |
将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
AzureTableOutputDataSource
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
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
BlobStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Storage/Blob”(必需) |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
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
名字 |
描述 |
价值 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
partitionKey |
用于确定要发送事件数据的分区的键/列。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
名字 |
描述 |
价值 |
consumerGroupName |
事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 |
字符串 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
功能
FunctionBinding
FunctionOutput
FunctionProperties
名字 |
描述 |
价值 |
名字 |
资源名称 |
字符串 |
性能 |
与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
InputProperties |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
IoTHubStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Devices/IotHubs”(必需) |
名字 |
描述 |
价值 |
consumerGroupName |
应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 |
字符串 |
端点 |
要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 |
字符串 |
iotHubNamespace |
IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
JavaScriptFunctionBinding
JavaScriptFunctionBindingProperties
名字 |
描述 |
价值 |
脚本 |
包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' |
字符串 |
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 版本 |
'2016-03-01' |
位置 |
资源所在的地理位置 |
字符串 |
名字 |
资源名称 |
string (必需) |
性能 |
与流式处理作业关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
StreamingJobProperties |
标签 |
资源标记 |
标记名称和值的字典。 请参阅模板 中的 标记 |
类型 |
资源类型 |
“Microsoft.StreamAnalytics/streamingjobs” |
输出
名字 |
描述 |
价值 |
名字 |
资源名称 |
字符串 |
性能 |
与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
OutputProperties |
OutputDataSource
OutputProperties
名字 |
描述 |
价值 |
数据源 |
描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
OutputDataSource |
序列化 |
描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 |
序列化 |
PowerBIOutputDataSource
PowerBIOutputDataSourceProperties
名字 |
描述 |
价值 |
数据 |
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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
名字 |
描述 |
价值 |
数据源 |
描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
ReferenceInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Reference”(必需) |
ScalarFunctionConfiguration
ScalarFunctionProperties
序列化
ServiceBusQueueOutputDataSource
ServiceBusQueueOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
queueName |
服务总线队列的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
ServiceBusTopicOutputDataSource
ServiceBusTopicOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
topicName |
服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
Sku
名字 |
描述 |
价值 |
名字 |
SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
“Standard” |
StorageAccount
名字 |
描述 |
价值 |
accountKey |
Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
accountName |
Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
StreamingJobProperties
名字 |
描述 |
价值 |
compatibilityLevel |
控制流式处理作业的某些运行时行为。 |
'1.0' |
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。 |
输入[] |
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。 |
转换 |
名字 |
描述 |
价值 |
数据源 |
描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
StreamInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Stream”(必需) |
快速入门模板
以下快速入门模板部署此资源类型。
模板 |
描述 |
创建标准流分析作业
|
此模板创建标准流分析作业。 有关详细信息,Azure 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)中提取的信息中识别模式和关系。 这些模式可用于触发操作并启动工作流,例如创建警报、将信息馈送给报告工具,或存储转换后的数据供以后使用。 此外,流分析在 Azure IoT Edge 运行时上可用,并支持与云相同的确切语言或语法。 |
可以使用目标操作部署流式处理作业资源类型:
有关每个 API 版本中已更改属性的列表,请参阅 更改日志。
若要创建 Microsoft.StreamAnalytics/streamingjobs 资源,请将以下 Terraform 添加到模板。
resource "azapi_resource" "symbolicname" {
type = "Microsoft.StreamAnalytics/streamingjobs@2016-03-01"
name = "string"
location = "string"
tags = {
{customized property} = "string"
}
body = jsonencode({
properties = {
compatibilityLevel = "string"
dataLocale = "string"
eventsLateArrivalMaxDelayInSeconds = int
eventsOutOfOrderMaxDelayInSeconds = int
eventsOutOfOrderPolicy = "string"
functions = [
{
name = "string"
properties = {
type = "string"
// For remaining properties, see FunctionProperties objects
}
}
]
inputs = [
{
name = "string"
properties = {
serialization = {
type = "string"
// For remaining properties, see Serialization objects
}
type = "string"
// For remaining properties, see InputProperties objects
}
}
]
outputErrorPolicy = "string"
outputs = [
{
name = "string"
properties = {
datasource = {
type = "string"
// For remaining properties, see OutputDataSource objects
}
serialization = {
type = "string"
// For remaining properties, see Serialization objects
}
}
}
]
outputStartMode = "string"
outputStartTime = "string"
sku = {
name = "string"
}
transformation = {
name = "string"
properties = {
query = "string"
streamingUnits = int
}
}
}
})
}
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"
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Devices/IotHubs,请使用:
{
properties = {
consumerGroupName = "string"
endpoint = "string"
iotHubNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.Devices/IotHubs"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties = {
consumerGroupName = "string"
eventHubName = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
container = "string"
dateFormat = "string"
pathPattern = "string"
sourcePartitionCount = int
storageAccounts = [
{
accountKey = "string"
accountName = "string"
}
]
timeFormat = "string"
}
type = "Microsoft.Storage/Blob"
}
设置 类型 属性以指定对象的类型。
对于 参考,请使用:
{
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"
}
FunctionProperties 对象
设置 类型 属性以指定对象的类型。
对于 标量,请使用:
{
properties = {
binding = {
type = "string"
// For remaining properties, see FunctionBinding objects
}
inputs = [
{
dataType = "string"
isConfigurationParameter = bool
}
]
output = {
dataType = "string"
}
}
type = "Scalar"
}
OutputDataSource 对象
设置 类型 属性以指定对象的类型。
对于 Microsoft.DataLake/Accounts,请使用:
{
properties = {
accountName = "string"
dateFormat = "string"
filePathPrefix = "string"
refreshToken = "string"
tenantId = "string"
timeFormat = "string"
tokenUserDisplayName = "string"
tokenUserPrincipalName = "string"
}
type = "Microsoft.DataLake/Accounts"
}
对于 Microsoft.ServiceBus/EventHub,请使用:
{
properties = {
eventHubName = "string"
partitionKey = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.ServiceBus/EventHub"
}
对于 Microsoft.ServiceBus/Queue,请使用:
{
properties = {
propertyColumns = [
"string"
]
queueName = "string"
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
}
type = "Microsoft.ServiceBus/Queue"
}
对于 Microsoft.ServiceBus/Topic,请使用:
{
properties = {
propertyColumns = [
"string"
]
serviceBusNamespace = "string"
sharedAccessPolicyKey = "string"
sharedAccessPolicyName = "string"
topicName = "string"
}
type = "Microsoft.ServiceBus/Topic"
}
对于 Microsoft.Sql/Server/Database,请使用:
{
properties = {
database = "string"
password = "string"
server = "string"
table = "string"
user = "string"
}
type = "Microsoft.Sql/Server/Database"
}
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
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 = {
dataset = "string"
groupId = "string"
groupName = "string"
refreshToken = "string"
table = "string"
tokenUserDisplayName = "string"
tokenUserPrincipalName = "string"
}
type = "PowerBI"
}
设置 类型 属性以指定对象的类型。
对于 Microsoft.Storage/Blob,请使用:
{
properties = {
container = "string"
dateFormat = "string"
pathPattern = "string"
storageAccounts = [
{
accountKey = "string"
accountName = "string"
}
]
timeFormat = "string"
}
type = "Microsoft.Storage/Blob"
}
属性值
AvroSerialization
名字 |
描述 |
价值 |
性能 |
与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
任何 |
类型 |
指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Avro”(必需) |
AzureDataLakeStoreOutputDataSource
AzureDataLakeStoreOutputDataSourceProperties
名字 |
描述 |
价值 |
accountName |
Azure Data Lake Store 帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
dateFormat |
日期格式。 无论 {date} 出现在 filePathPrefix 中,此属性的值将改为用作日期格式。 |
字符串 |
filePathPrefix |
输出应写入到的文件的位置。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
refreshToken |
一个刷新令牌,可用于获取有效的访问令牌,然后可用于向数据源进行身份验证。 当前只能通过 Azure 门户获取有效的刷新令牌。 建议在创建数据源时在此处放置虚拟字符串值,然后转到 Azure 门户对数据源进行身份验证,该数据源将使用有效的刷新令牌更新此属性。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
tenantId |
用于获取刷新令牌的用户的租户 ID。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
timeFormat |
时间格式。 无论 {time} 出现在 filePathPrefix 中,此属性的值将改为用作时间格式。 |
字符串 |
tokenUserDisplayName |
用于获取刷新令牌的用户的用户显示名称。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
tokenUserPrincipalName |
用于获取刷新令牌的用户的用户主体名称(UPN)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
AzureMachineLearningWebServiceFunctionBinding
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[] |
AzureMachineLearningWebServiceOutputColumn
AzureSqlDatabaseOutputDataSource
AzureSqlDatabaseOutputDataSourceProperties
名字 |
描述 |
价值 |
数据库 |
Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
密码 |
将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
服务器 |
包含 Azure SQL 数据库的 SQL Server 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
桌子 |
Azure SQL 数据库中表的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
用户 |
将用于连接到 Azure SQL 数据库的用户名。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
AzureTableOutputDataSource
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
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 Blob 输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
BlobStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Storage/Blob”(必需) |
名字 |
描述 |
价值 |
容器 |
关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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 中,此属性的值将改为用作时间格式。 |
字符串 |
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
名字 |
描述 |
价值 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
partitionKey |
用于确定要发送事件数据的分区的键/列。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
名字 |
描述 |
价值 |
consumerGroupName |
事件中心使用者组的名称,该组应用于从事件中心读取事件。 为多个输入指定不同的使用者组名称允许每个输入从事件中心接收相同的事件。 如果未指定,则输入使用事件中心的默认使用者组。 |
字符串 |
eventHubName |
事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
功能
FunctionBinding
FunctionOutput
FunctionProperties
名字 |
描述 |
价值 |
名字 |
资源名称 |
字符串 |
性能 |
与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
InputProperties |
名字 |
描述 |
价值 |
性能 |
与包含流数据的 IoT 中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
IoTHubStreamInputDataSourceProperties |
类型 |
指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 |
“Microsoft.Devices/IotHubs”(必需) |
名字 |
描述 |
价值 |
consumerGroupName |
应用于从 IoT 中心读取事件的 IoT 中心使用者组的名称。 如果未指定,则输入使用 Iot 中心的默认使用者组。 |
字符串 |
端点 |
要连接到的 IoT 中心终结点(例如消息/事件、消息/operationsMonitoringEvents 等)。 |
字符串 |
iotHubNamespace |
IoT 中心的名称或 URI。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
IoT 中心的共享访问策略名称。 此策略必须至少包含服务连接权限。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
JavaScriptFunctionBinding
JavaScriptFunctionBindingProperties
名字 |
描述 |
价值 |
脚本 |
包含单个函数定义的 JavaScript 代码。 例如:“function (x, y) { return x + y; }' |
字符串 |
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@2016-03-01” |
输出
名字 |
描述 |
价值 |
名字 |
资源名称 |
字符串 |
性能 |
与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 |
OutputProperties |
OutputDataSource
OutputProperties
名字 |
描述 |
价值 |
数据源 |
描述输出将写入到的数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
OutputDataSource |
序列化 |
描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 |
序列化 |
PowerBIOutputDataSource
PowerBIOutputDataSourceProperties
名字 |
描述 |
价值 |
数据 |
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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 |
字符串 |
名字 |
描述 |
价值 |
数据源 |
描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
ReferenceInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Reference”(必需) |
ScalarFunctionConfiguration
ScalarFunctionProperties
序列化
ServiceBusQueueOutputDataSource
ServiceBusQueueOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
queueName |
服务总线队列的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
ServiceBusTopicOutputDataSource
ServiceBusTopicOutputDataSourceProperties
名字 |
描述 |
价值 |
propertyColumns |
要作为自定义属性附加到服务总线消息的输出列名称的字符串数组。 |
string[] |
serviceBusNamespace |
与所需事件中心、服务总线队列、服务总线主题等关联的命名空间。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyKey |
指定共享访问策略的共享访问策略密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
sharedAccessPolicyName |
事件中心、服务总线队列、服务总线主题等的共享访问策略名称。PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
topicName |
服务总线主题的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
Sku
名字 |
描述 |
价值 |
名字 |
SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
“Standard” |
StorageAccount
名字 |
描述 |
价值 |
accountKey |
Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
accountName |
Azure 存储帐户的名称。 PUT (CreateOrReplace) 请求时是必需的。 |
字符串 |
StreamingJobProperties
名字 |
描述 |
价值 |
compatibilityLevel |
控制流式处理作业的某些运行时行为。 |
'1.0' |
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。 |
输入[] |
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。 |
转换 |
名字 |
描述 |
价值 |
数据源 |
描述包含流数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
StreamInputDataSource |
类型 |
指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 |
“Stream”(必需) |