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

Microsoft.StreamAnalytics streamingjobs 2021-10-01-preview

Bicep 资源定义

可以使用目标操作部署流式处理作业资源类型:

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

资源格式

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

resource symbolicname 'Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview' = {
  identity: {
    type: 'string'
    userAssignedIdentities: {
      {customized property}: any(Azure.Bicep.Types.Concrete.AnyType)
    }
  }
  location: 'string'
  name: 'string'
  properties: {
    cluster: {
      id: 'string'
    }
    compatibilityLevel: 'string'
    contentStoragePolicy: 'string'
    dataLocale: 'string'
    eventsLateArrivalMaxDelayInSeconds: int
    eventsOutOfOrderMaxDelayInSeconds: int
    eventsOutOfOrderPolicy: 'string'
    externals: {
      container: 'string'
      path: 'string'
      refreshConfiguration: {
        dateFormat: 'string'
        pathPattern: 'string'
        refreshInterval: 'string'
        refreshType: 'string'
        timeFormat: 'string'
      }
      storageAccount: {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    }
    functions: [
      {
        name: 'string'
        properties: {
          properties: {
            binding: {
              type: 'string'
              // For remaining properties, see FunctionBinding objects
            }
            inputs: [
              {
                dataType: 'string'
                isConfigurationParameter: bool
              }
            ]
            output: {
              dataType: 'string'
            }
          }
          type: 'string'
          // For remaining properties, see FunctionProperties objects
        }
      }
    ]
    inputs: [
      {
        name: 'string'
        properties: {
          compression: {
            type: 'string'
          }
          partitionKey: 'string'
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          watermarkSettings: {
            watermarkMode: 'string'
          }
          type: 'string'
          // For remaining properties, see InputProperties objects
        }
      }
    ]
    jobStorageAccount: {
      accountKey: 'string'
      accountName: 'string'
      authenticationMode: 'string'
    }
    jobType: 'string'
    outputErrorPolicy: 'string'
    outputs: [
      {
        name: 'string'
        properties: {
          datasource: {
            type: 'string'
            // For remaining properties, see OutputDataSource objects
          }
          serialization: {
            type: 'string'
            // For remaining properties, see Serialization objects
          }
          sizeWindow: int
          timeWindow: 'string'
          watermarkSettings: {
            maxWatermarkDifferenceAcrossPartitions: 'string'
            watermarkMode: 'string'
          }
        }
      }
    ]
    outputStartMode: 'string'
    outputStartTime: 'string'
    sku: {
      capacity: int
      name: 'string'
    }
    transformation: {
      name: 'string'
      properties: {
        query: 'string'
        streamingUnits: int
        validStreamingUnits: [
          int
        ]
      }
    }
  }
  sku: {
    capacity: int
    name: 'string'
  }
  tags: {
    {customized property}: 'string'
  }
}

InputProperties 对象

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

对于 参考,请使用:

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

对于 Stream,请使用:

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

FunctionProperties 对象

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

对于 聚合,请使用:

{
  type: 'Aggregate'
}

对于 标量,请使用:

{
  type: 'Scalar'
}

OutputDataSource 对象

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

对于 GatewayMessageBus,请使用:

{
  properties: {
    topic: 'string'
  }
  type: 'GatewayMessageBus'
}

对于 Microsoft.AzureFunction,请使用:

{
  properties: {
    apiKey: 'string'
    functionAppName: 'string'
    functionName: 'string'
    maxBatchCount: int
    maxBatchSize: int
  }
  type: 'Microsoft.AzureFunction'
}

对于 Microsoft.DBForPostgreSQL/servers/databases,请使用:

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    maxWriterCount: int
    password: 'string'
    server: 'string'
    table: 'string'
    user: 'string'
  }
  type: 'Microsoft.DBForPostgreSQL/servers/databases'
}

对于 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'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.EventHub/EventHub'
}

对于 Microsoft.Kusto/clusters/databases,请使用:

{
  properties: {
    authenticationMode: 'string'
    cluster: 'string'
    database: 'string'
    table: 'string'
  }
  type: 'Microsoft.Kusto/clusters/databases'
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    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: {
    authenticationMode: 'string'
    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'
    blobWriteMode: 'string'
    container: 'string'
    dateFormat: 'string'
    pathPattern: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    timeFormat: 'string'
  }
  type: 'Microsoft.Storage/Blob'
}

对于 Microsoft.Storage/DocumentDB,请使用:

{
  properties: {
    accountId: 'string'
    accountKey: 'string'
    authenticationMode: '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'
}

对于 原始,请使用:

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

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.MachineLearningServices,请使用:

{
  properties: {
    apiKey: 'string'
    batchSize: int
    endpoint: 'string'
    inputRequestName: 'string'
    inputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
    numberOfParallelRequests: int
    outputResponseName: 'string'
    outputs: [
      {
        dataType: 'string'
        mapTo: int
        name: 'string'
      }
    ]
  }
  type: 'Microsoft.MachineLearningServices'
}

对于 Microsoft.StreamAnalytics/CLRUdf,请使用:

{
  properties: {
    class: 'string'
    dllPath: 'string'
    method: 'string'
    updateMode: 'string'
  }
  type: 'Microsoft.StreamAnalytics/CLRUdf'
}

对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:

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

ReferenceInputDataSource 对象

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

对于 文件,请使用:

{
  properties: {
    path: 'string'
  }
  type: 'File'
}

对于 Microsoft.Sql/Server/Database,请使用:

{
  properties: {
    authenticationMode: 'string'
    database: 'string'
    deltaSnapshotQuery: 'string'
    fullSnapshotQuery: 'string'
    password: 'string'
    refreshRate: 'string'
    refreshType: 'string'
    server: 'string'
    user: 'string'
  }
  type: 'Microsoft.Sql/Server/Database'
}

对于 Microsoft.Storage/Blob,请使用:

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

对于 原始,请使用:

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

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.EventGrid/EventSubscriptions,请使用:

{
  properties: {
    eventTypes: [
      'string'
    ]
    schema: 'string'
    storageAccounts: [
      {
        accountKey: 'string'
        accountName: 'string'
        authenticationMode: 'string'
      }
    ]
    subscriber: {
      properties: {
        authenticationMode: 'string'
        consumerGroupName: 'string'
        eventHubName: 'string'
        partitionCount: int
        prefetchCount: int
        serviceBusNamespace: 'string'
        sharedAccessPolicyKey: 'string'
        sharedAccessPolicyName: 'string'
      }
      type: 'string'
    }
  }
  type: 'Microsoft.EventGrid/EventSubscriptions'
}

对于 Microsoft.EventHub/EventHub,请使用:

{
  properties: {
    authenticationMode: 'string'
    consumerGroupName: 'string'
    eventHubName: 'string'
    partitionCount: int
    prefetchCount: int
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.EventHub/EventHub'
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  properties: {
    authenticationMode: 'string'
    consumerGroupName: 'string'
    eventHubName: 'string'
    partitionCount: int
    prefetchCount: int
    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'
        authenticationMode: 'string'
      }
    ]
    timeFormat: 'string'
  }
  type: 'Microsoft.Storage/Blob'
}

对于 原始,请使用:

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

序列化对象

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

对于 Avro,请使用:

{
  properties: any(Azure.Bicep.Types.Concrete.AnyType)
  type: 'Avro'
}

对于 Csv,请使用:

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

对于 customClr ,请使用:

{
  properties: {
    serializationClassName: 'string'
    serializationDllPath: 'string'
  }
  type: 'CustomClr'
}

对于 Delta,请使用:

{
  properties: {
    deltaTablePath: 'string'
    partitionColumns: [
      'string'
    ]
  }
  type: 'Delta'
}

对于 Json,请使用:

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

对于 Parquet,请使用:

{
  properties: any(Azure.Bicep.Types.Concrete.AnyType)
  type: 'Parquet'
}

属性值

AggregateFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “Aggregate”(必需)

AvroSerialization

名字 描述 价值
性能 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Avro”(必需)

AzureDataExplorerOutputDataSource

名字 描述 价值
性能 与 Azure 数据资源管理器输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureDataExplorerOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Kusto/clusters/databases”(必需)

AzureDataExplorerOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
Azure 数据资源管理器群集的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
数据库 Azure 数据资源管理器数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
桌子 Azure 表的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

AzureMachineLearningServiceFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearningServices”(必需)

AzureMachineLearningServiceFunctionBindingProperties

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

AzureMachineLearningServiceInputColumn

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

AzureMachineLearningServiceOutputColumn

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

AzureMachineLearningStudioFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearning/WebService”(必需)

AzureMachineLearningStudioFunctionBindingProperties

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

AzureMachineLearningStudioInputColumn

名字 描述 价值
dataType 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
名字 输入列的名称。 字符串

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioOutputColumn

名字 描述 价值
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

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

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

AzureSynapseOutputDataSource

名字 描述 价值
性能 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Sql/Server/DataWarehouse”(必需)

AzureSynapseOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 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 路径前缀。 字符串
blobWriteMode Blob 写入模式。 “Append”
“Once”
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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”
blobName Blob 输入的名称。 字符串
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 Blob 输入数据源的增量快照的间隔。 字符串
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
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”
“无”(必需)

CSharpFunctionBinding

名字 描述 价值
性能 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.StreamAnalytics/CLRUdf”(必需)

CSharpFunctionBindingProperties

名字 描述 价值
包含单个函数定义的 Csharp 代码。 字符串
dllPath 包含单个函数定义的 Csharp 代码。 字符串
方法 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 “Refreshable”
“Static”

CsvSerialization

名字 描述 价值
性能 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CsvSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Csv”(必需)

CsvSerializationProperties

名字 描述 价值
编码 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 “UTF8”
fieldDelimiter 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 字符串

CustomClrSerialization

名字 描述 价值
性能 与 CustomClr 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CustomClrSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “CustomClr”(必需)

CustomClrSerializationProperties

名字 描述 价值
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名字 描述 价值
性能 与 Delta Lake 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DeltaSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Delta”(必需)

DeltaSerializationProperties

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

DocumentDbOutputDataSource

名字 描述 价值
性能 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DocumentDbOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/DocumentDB”(必需)

DocumentDbOutputDataSourceProperties

名字 描述 价值
accountId DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 字符串
accountKey DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

EventGridStreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.EventGrid/EventSubscriptions”(必需)

EventGridStreamInputDataSourceProperties

名字 描述 价值
eventTypes 事件网格适配器支持的事件类型列表。 string[]
图式 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
订户 事件网格的订阅服务器。 目前仅支持 EventHub 订阅服务器。 EventHubV2StreamInputDataSource

EventHubOutputDataSource

名字 描述 价值
性能 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub”(必需)

EventHubOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
eventHubName 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
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) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
prefetchCount 消息接收方可以同时请求的消息数。 int
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”(必需)

EventHubV2StreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 string (必需)

外部

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

FileReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 FileReferenceInputDataSourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “File”(必需)

FileReferenceInputDataSourceProperties

名字 描述 价值
路径 文件的路径。 字符串

功能

名字 描述 价值
名字 资源名称 字符串
性能 与函数关联的属性。 FunctionProperties

FunctionBinding

名字 描述 价值
类型 对于 AzureMachineLearningStudioFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 AzureMachineLearningServiceFunctionBinding,请设置为“Microsoft.MachineLearningServices”。 对于 CSharpFunctionBinding,请设置为“Microsoft.StreamAnalytics/CLRUdf”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 “Microsoft.MachineLearning/WebService”
“Microsoft.MachineLearningServices”
“Microsoft.StreamAnalytics/CLRUdf”
“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

名字 描述 价值
主题 服务总线主题的名称。 字符串

身份

名字 描述 价值
类型 标识的类型可以是 SystemAssigned 或 UserAssigned。 字符串
userAssignedIdentities 用户分配的标识与流式处理作业资源相关联。 IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

名字 描述 价值

输入

名字 描述 价值
名字 资源名称 字符串
性能 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 InputProperties

InputProperties

名字 描述 价值
压缩 描述如何压缩输入数据 压缩
partitionKey partitionKey 描述用于对输入数据进行分区的输入数据中的键 字符串
序列化 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 序列化
类型 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 “Reference”
“Stream”(必需)
watermarkSettings 用于确定是否读取水印事件的设置。 InputWatermarkProperties

InputWatermarkProperties

名字 描述 价值
watermarkMode 输入水印模式。 “None”
“ReadWatermark”

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
sku 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 Sku
标签 资源标记 标记名称和值的字典。 请参阅模板 中的 标记

输出

名字 描述 价值
名字 资源名称 字符串
性能 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 OutputProperties

OutputDataSource

名字 描述 价值
类型 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 PostgreSQLOutputDataSource,请设置为“Microsoft.DBForPostgreSQL/servers/databases”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 AzureDataExplorerOutputDataSource,请设置为“Microsoft.Kusto/clusters/databases”。 对于 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”。 对于 RawOutputDatasource,请设置为“Raw”。 “GatewayMessageBus”
“Microsoft.AzureFunction”
“Microsoft.DataLake/Accounts”
“Microsoft.DBForPostgreSQL/servers/databases”
“Microsoft.EventHub/EventHub”
“Microsoft.Kusto/clusters/databases”
“Microsoft.ServiceBus/EventHub”
“Microsoft.ServiceBus/Queue”
“Microsoft.ServiceBus/Topic”
“Microsoft.Sql/Server/Database”
“Microsoft.Sql/Server/DataWarehouse”
“Microsoft.Storage/Blob”
“Microsoft.Storage/DocumentDB”
“Microsoft.Storage/Table”
“PowerBI”
“Raw”(必需)

OutputProperties

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

OutputWatermarkProperties

名字 描述 价值
maxWatermarkDifferenceAcrossPartitions 描述最快分区和最慢分区之间的最大增量,因此定义捕获下游作业中所有必要事件的无序窗口。 字符串
watermarkMode 输出水印模式。 “None”
“SendCurrentPartitionWatermark”
“SendLowestWatermarkAcrossPartitions”

ParquetSerialization

名字 描述 价值
性能 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Parquet”(必需)

PostgreSQLOutputDataSource

名字 描述 价值
性能 与 PostgreSQL 输出数据源关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 PostgreSQLOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DBForPostgreSQL/servers/databases”(必需)

PostgreSQLOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxWriterCount 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 int
密码 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 字符串

RawInputDatasourceProperties

名字 描述 价值
有效载荷 输入数据的 JSON 序列化内容。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串

RawOutputDatasource

名字 描述 价值
性能 与原始输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawOutputDatasourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawOutputDatasourceProperties

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

RawReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawStreamInputDataSource

名字 描述 价值
性能 与原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

ReferenceInputDataSource

名字 描述 价值
类型 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 对于 RawReferenceInputDataSource,请设置为“Raw”。 “File”
“Microsoft.Sql/Server/Database”
“Microsoft.Storage/Blob”
“Raw”(必需)

ReferenceInputProperties

名字 描述 价值
数据源 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 ReferenceInputDataSource
类型 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 “Reference”(必需)

RefreshConfiguration

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

ScalarFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “标量”(必需)

序列化

名字 描述 价值
类型 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 customClrSerialization 类型,设置为“CustomClr”。 对于 DeltaSerialization类型,设置为“Delta”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 “Avro”
“Csv”
“CustomClr”
“Delta”
“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 的容量。 int
名字 SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 “Standard”

StorageAccount

名字 描述 价值
accountKey Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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 EventGridStreamInputDataSource,设置为“Microsoft.EventGrid/EventSubscriptions”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 rawStreamInputDataSource,请设置为 “RawStreamInputDataSource”。 “GatewayMessageBus”
“Microsoft.Devices/IotHubs”
“Microsoft.EventGrid/EventSubscriptions”
“Microsoft.EventHub/EventHub”
“Microsoft.ServiceBus/EventHub”
“Microsoft.Storage/Blob”
“Raw”(必需)

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": "2021-10-01-preview",
  "name": "string",
  "identity": {
    "type": "string",
    "userAssignedIdentities": {
      "{customized property}": {}
    }
  },
  "location": "string",
  "properties": {
    "cluster": {
      "id": "string"
    },
    "compatibilityLevel": "string",
    "contentStoragePolicy": "string",
    "dataLocale": "string",
    "eventsLateArrivalMaxDelayInSeconds": "int",
    "eventsOutOfOrderMaxDelayInSeconds": "int",
    "eventsOutOfOrderPolicy": "string",
    "externals": {
      "container": "string",
      "path": "string",
      "refreshConfiguration": {
        "dateFormat": "string",
        "pathPattern": "string",
        "refreshInterval": "string",
        "refreshType": "string",
        "timeFormat": "string"
      },
      "storageAccount": {
        "accountKey": "string",
        "accountName": "string",
        "authenticationMode": "string"
      }
    },
    "functions": [
      {
        "name": "string",
        "properties": {
          "properties": {
            "binding": {
              "type": "string"
              // For remaining properties, see FunctionBinding objects
            },
            "inputs": [
              {
                "dataType": "string",
                "isConfigurationParameter": "bool"
              }
            ],
            "output": {
              "dataType": "string"
            }
          },
          "type": "string"
          // For remaining properties, see FunctionProperties objects
        }
      }
    ],
    "inputs": [
      {
        "name": "string",
        "properties": {
          "compression": {
            "type": "string"
          },
          "partitionKey": "string",
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          },
          "watermarkSettings": {
            "watermarkMode": "string"
          },
          "type": "string"
          // For remaining properties, see InputProperties objects
        }
      }
    ],
    "jobStorageAccount": {
      "accountKey": "string",
      "accountName": "string",
      "authenticationMode": "string"
    },
    "jobType": "string",
    "outputErrorPolicy": "string",
    "outputs": [
      {
        "name": "string",
        "properties": {
          "datasource": {
            "type": "string"
            // For remaining properties, see OutputDataSource objects
          },
          "serialization": {
            "type": "string"
            // For remaining properties, see Serialization objects
          },
          "sizeWindow": "int",
          "timeWindow": "string",
          "watermarkSettings": {
            "maxWatermarkDifferenceAcrossPartitions": "string",
            "watermarkMode": "string"
          }
        }
      }
    ],
    "outputStartMode": "string",
    "outputStartTime": "string",
    "sku": {
      "capacity": "int",
      "name": "string"
    },
    "transformation": {
      "name": "string",
      "properties": {
        "query": "string",
        "streamingUnits": "int",
        "validStreamingUnits": [ "int" ]
      }
    }
  },
  "sku": {
    "capacity": "int",
    "name": "string"
  },
  "tags": {
    "{customized property}": "string"
  }
}

InputProperties 对象

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

对于 参考,请使用:

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

对于 Stream,请使用:

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

FunctionProperties 对象

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

对于 聚合,请使用:

{
  "type": "Aggregate"
}

对于 标量,请使用:

{
  "type": "Scalar"
}

OutputDataSource 对象

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

对于 GatewayMessageBus,请使用:

{
  "properties": {
    "topic": "string"
  },
  "type": "GatewayMessageBus"
}

对于 Microsoft.AzureFunction,请使用:

{
  "properties": {
    "apiKey": "string",
    "functionAppName": "string",
    "functionName": "string",
    "maxBatchCount": "int",
    "maxBatchSize": "int"
  },
  "type": "Microsoft.AzureFunction"
}

对于 Microsoft.DBForPostgreSQL/servers/databases,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "database": "string",
    "maxWriterCount": "int",
    "password": "string",
    "server": "string",
    "table": "string",
    "user": "string"
  },
  "type": "Microsoft.DBForPostgreSQL/servers/databases"
}

对于 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",
    "partitionCount": "int",
    "partitionKey": "string",
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  },
  "type": "Microsoft.EventHub/EventHub"
}

对于 Microsoft.Kusto/clusters/databases,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "cluster": "string",
    "database": "string",
    "table": "string"
  },
  "type": "Microsoft.Kusto/clusters/databases"
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "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": {
    "authenticationMode": "string",
    "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",
    "blobWriteMode": "string",
    "container": "string",
    "dateFormat": "string",
    "pathPattern": "string",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string",
        "authenticationMode": "string"
      }
    ],
    "timeFormat": "string"
  },
  "type": "Microsoft.Storage/Blob"
}

对于 Microsoft.Storage/DocumentDB,请使用:

{
  "properties": {
    "accountId": "string",
    "accountKey": "string",
    "authenticationMode": "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"
}

对于 原始,请使用:

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

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.MachineLearningServices,请使用:

{
  "properties": {
    "apiKey": "string",
    "batchSize": "int",
    "endpoint": "string",
    "inputRequestName": "string",
    "inputs": [
      {
        "dataType": "string",
        "mapTo": "int",
        "name": "string"
      }
    ],
    "numberOfParallelRequests": "int",
    "outputResponseName": "string",
    "outputs": [
      {
        "dataType": "string",
        "mapTo": "int",
        "name": "string"
      }
    ]
  },
  "type": "Microsoft.MachineLearningServices"
}

对于 Microsoft.StreamAnalytics/CLRUdf,请使用:

{
  "properties": {
    "class": "string",
    "dllPath": "string",
    "method": "string",
    "updateMode": "string"
  },
  "type": "Microsoft.StreamAnalytics/CLRUdf"
}

对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:

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

ReferenceInputDataSource 对象

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

对于 文件,请使用:

{
  "properties": {
    "path": "string"
  },
  "type": "File"
}

对于 Microsoft.Sql/Server/Database,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "database": "string",
    "deltaSnapshotQuery": "string",
    "fullSnapshotQuery": "string",
    "password": "string",
    "refreshRate": "string",
    "refreshType": "string",
    "server": "string",
    "user": "string"
  },
  "type": "Microsoft.Sql/Server/Database"
}

对于 Microsoft.Storage/Blob,请使用:

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

对于 原始,请使用:

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

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.EventGrid/EventSubscriptions,请使用:

{
  "properties": {
    "eventTypes": [ "string" ],
    "schema": "string",
    "storageAccounts": [
      {
        "accountKey": "string",
        "accountName": "string",
        "authenticationMode": "string"
      }
    ],
    "subscriber": {
      "properties": {
        "authenticationMode": "string",
        "consumerGroupName": "string",
        "eventHubName": "string",
        "partitionCount": "int",
        "prefetchCount": "int",
        "serviceBusNamespace": "string",
        "sharedAccessPolicyKey": "string",
        "sharedAccessPolicyName": "string"
      },
      "type": "string"
    }
  },
  "type": "Microsoft.EventGrid/EventSubscriptions"
}

对于 Microsoft.EventHub/EventHub,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "consumerGroupName": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "prefetchCount": "int",
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  },
  "type": "Microsoft.EventHub/EventHub"
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  "properties": {
    "authenticationMode": "string",
    "consumerGroupName": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "prefetchCount": "int",
    "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",
        "authenticationMode": "string"
      }
    ],
    "timeFormat": "string"
  },
  "type": "Microsoft.Storage/Blob"
}

对于 原始,请使用:

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

序列化对象

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

对于 Avro,请使用:

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

对于 Csv,请使用:

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

对于 customClr ,请使用:

{
  "properties": {
    "serializationClassName": "string",
    "serializationDllPath": "string"
  },
  "type": "CustomClr"
}

对于 Delta,请使用:

{
  "properties": {
    "deltaTablePath": "string",
    "partitionColumns": [ "string" ]
  },
  "type": "Delta"
}

对于 Json,请使用:

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

对于 Parquet,请使用:

{
  "properties": {},
  "type": "Parquet"
}

属性值

AggregateFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “Aggregate”(必需)

AvroSerialization

名字 描述 价值
性能 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Avro”(必需)

AzureDataExplorerOutputDataSource

名字 描述 价值
性能 与 Azure 数据资源管理器输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureDataExplorerOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Kusto/clusters/databases”(必需)

AzureDataExplorerOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
Azure 数据资源管理器群集的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
数据库 Azure 数据资源管理器数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
桌子 Azure 表的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

AzureMachineLearningServiceFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearningServices”(必需)

AzureMachineLearningServiceFunctionBindingProperties

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

AzureMachineLearningServiceInputColumn

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

AzureMachineLearningServiceOutputColumn

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

AzureMachineLearningStudioFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearning/WebService”(必需)

AzureMachineLearningStudioFunctionBindingProperties

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

AzureMachineLearningStudioInputColumn

名字 描述 价值
dataType 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
名字 输入列的名称。 字符串

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioOutputColumn

名字 描述 价值
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

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

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

AzureSynapseOutputDataSource

名字 描述 价值
性能 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Sql/Server/DataWarehouse”(必需)

AzureSynapseOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 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 路径前缀。 字符串
blobWriteMode Blob 写入模式。 “Append”
“Once”
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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”
blobName Blob 输入的名称。 字符串
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 Blob 输入数据源的增量快照的间隔。 字符串
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
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”
“无”(必需)

CSharpFunctionBinding

名字 描述 价值
性能 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.StreamAnalytics/CLRUdf”(必需)

CSharpFunctionBindingProperties

名字 描述 价值
包含单个函数定义的 Csharp 代码。 字符串
dllPath 包含单个函数定义的 Csharp 代码。 字符串
方法 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 “Refreshable”
“Static”

CsvSerialization

名字 描述 价值
性能 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CsvSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Csv”(必需)

CsvSerializationProperties

名字 描述 价值
编码 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 “UTF8”
fieldDelimiter 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 字符串

CustomClrSerialization

名字 描述 价值
性能 与 CustomClr 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CustomClrSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “CustomClr”(必需)

CustomClrSerializationProperties

名字 描述 价值
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名字 描述 价值
性能 与 Delta Lake 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DeltaSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Delta”(必需)

DeltaSerializationProperties

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

DocumentDbOutputDataSource

名字 描述 价值
性能 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DocumentDbOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/DocumentDB”(必需)

DocumentDbOutputDataSourceProperties

名字 描述 价值
accountId DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 字符串
accountKey DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

EventGridStreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.EventGrid/EventSubscriptions”(必需)

EventGridStreamInputDataSourceProperties

名字 描述 价值
eventTypes 事件网格适配器支持的事件类型列表。 string[]
图式 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
订户 事件网格的订阅服务器。 目前仅支持 EventHub 订阅服务器。 EventHubV2StreamInputDataSource

EventHubOutputDataSource

名字 描述 价值
性能 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub”(必需)

EventHubOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
eventHubName 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
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) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
prefetchCount 消息接收方可以同时请求的消息数。 int
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”(必需)

EventHubV2StreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 string (必需)

外部

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

FileReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 FileReferenceInputDataSourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “File”(必需)

FileReferenceInputDataSourceProperties

名字 描述 价值
路径 文件的路径。 字符串

功能

名字 描述 价值
名字 资源名称 字符串
性能 与函数关联的属性。 FunctionProperties

FunctionBinding

名字 描述 价值
类型 对于 AzureMachineLearningStudioFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 AzureMachineLearningServiceFunctionBinding,请设置为“Microsoft.MachineLearningServices”。 对于 CSharpFunctionBinding,请设置为“Microsoft.StreamAnalytics/CLRUdf”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 “Microsoft.MachineLearning/WebService”
“Microsoft.MachineLearningServices”
“Microsoft.StreamAnalytics/CLRUdf”
“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

名字 描述 价值
主题 服务总线主题的名称。 字符串

身份

名字 描述 价值
类型 标识的类型可以是 SystemAssigned 或 UserAssigned。 字符串
userAssignedIdentities 用户分配的标识与流式处理作业资源相关联。 IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

名字 描述 价值

输入

名字 描述 价值
名字 资源名称 字符串
性能 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 InputProperties

InputProperties

名字 描述 价值
压缩 描述如何压缩输入数据 压缩
partitionKey partitionKey 描述用于对输入数据进行分区的输入数据中的键 字符串
序列化 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 序列化
类型 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 “Reference”
“Stream”(必需)
watermarkSettings 用于确定是否读取水印事件的设置。 InputWatermarkProperties

InputWatermarkProperties

名字 描述 价值
watermarkMode 输入水印模式。 “None”
“ReadWatermark”

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 版本 '2021-10-01-preview'
身份 描述分配给此作业的托管标识,该标识可用于通过输入和输出进行身份验证。 标识
位置 资源所在的地理位置 字符串
名字 资源名称 string (必需)
性能 与流式处理作业关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 StreamingJobProperties
sku 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 Sku
标签 资源标记 标记名称和值的字典。 请参阅模板 中的 标记
类型 资源类型 “Microsoft.StreamAnalytics/streamingjobs”

输出

名字 描述 价值
名字 资源名称 字符串
性能 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 OutputProperties

OutputDataSource

名字 描述 价值
类型 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 PostgreSQLOutputDataSource,请设置为“Microsoft.DBForPostgreSQL/servers/databases”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 AzureDataExplorerOutputDataSource,请设置为“Microsoft.Kusto/clusters/databases”。 对于 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”。 对于 RawOutputDatasource,请设置为“Raw”。 “GatewayMessageBus”
“Microsoft.AzureFunction”
“Microsoft.DataLake/Accounts”
“Microsoft.DBForPostgreSQL/servers/databases”
“Microsoft.EventHub/EventHub”
“Microsoft.Kusto/clusters/databases”
“Microsoft.ServiceBus/EventHub”
“Microsoft.ServiceBus/Queue”
“Microsoft.ServiceBus/Topic”
“Microsoft.Sql/Server/Database”
“Microsoft.Sql/Server/DataWarehouse”
“Microsoft.Storage/Blob”
“Microsoft.Storage/DocumentDB”
“Microsoft.Storage/Table”
“PowerBI”
“Raw”(必需)

OutputProperties

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

OutputWatermarkProperties

名字 描述 价值
maxWatermarkDifferenceAcrossPartitions 描述最快分区和最慢分区之间的最大增量,因此定义捕获下游作业中所有必要事件的无序窗口。 字符串
watermarkMode 输出水印模式。 “None”
“SendCurrentPartitionWatermark”
“SendLowestWatermarkAcrossPartitions”

ParquetSerialization

名字 描述 价值
性能 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Parquet”(必需)

PostgreSQLOutputDataSource

名字 描述 价值
性能 与 PostgreSQL 输出数据源关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 PostgreSQLOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DBForPostgreSQL/servers/databases”(必需)

PostgreSQLOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxWriterCount 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 int
密码 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 字符串

RawInputDatasourceProperties

名字 描述 价值
有效载荷 输入数据的 JSON 序列化内容。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串

RawOutputDatasource

名字 描述 价值
性能 与原始输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawOutputDatasourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawOutputDatasourceProperties

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

RawReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawStreamInputDataSource

名字 描述 价值
性能 与原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

ReferenceInputDataSource

名字 描述 价值
类型 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 对于 RawReferenceInputDataSource,请设置为“Raw”。 “File”
“Microsoft.Sql/Server/Database”
“Microsoft.Storage/Blob”
“Raw”(必需)

ReferenceInputProperties

名字 描述 价值
数据源 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 ReferenceInputDataSource
类型 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 “Reference”(必需)

RefreshConfiguration

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

ScalarFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “标量”(必需)

序列化

名字 描述 价值
类型 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 customClrSerialization 类型,设置为“CustomClr”。 对于 DeltaSerialization类型,设置为“Delta”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 “Avro”
“Csv”
“CustomClr”
“Delta”
“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 的容量。 int
名字 SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 “Standard”

StorageAccount

名字 描述 价值
accountKey Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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 EventGridStreamInputDataSource,设置为“Microsoft.EventGrid/EventSubscriptions”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 rawStreamInputDataSource,请设置为 “RawStreamInputDataSource”。 “GatewayMessageBus”
“Microsoft.Devices/IotHubs”
“Microsoft.EventGrid/EventSubscriptions”
“Microsoft.EventHub/EventHub”
“Microsoft.ServiceBus/EventHub”
“Microsoft.Storage/Blob”
“Raw”(必需)

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 流分析是一个实时分析和复杂的事件处理引擎,旨在同时分析和处理来自多个源的大量快速流数据。 可以在从许多输入源(包括设备、传感器、点击流、社交媒体源和应用程序)中提取的信息中识别模式和关系。 这些模式可用于触发操作并启动工作流,例如创建警报、将信息馈送给报告工具,或存储转换后的数据供以后使用。 此外,流分析在 Azure IoT Edge 运行时上可用,并支持与云相同的确切语言或语法。

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

可以使用目标操作部署流式处理作业资源类型:

  • 资源组

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

资源格式

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

resource "azapi_resource" "symbolicname" {
  type = "Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview"
  name = "string"
  identity = {
    type = "string"
    userAssignedIdentities = {
      {customized property} = ?
    }
  }
  location = "string"
  sku = {
    capacity = int
    name = "string"
  }
  tags = {
    {customized property} = "string"
  }
  body = jsonencode({
    properties = {
      cluster = {
        id = "string"
      }
      compatibilityLevel = "string"
      contentStoragePolicy = "string"
      dataLocale = "string"
      eventsLateArrivalMaxDelayInSeconds = int
      eventsOutOfOrderMaxDelayInSeconds = int
      eventsOutOfOrderPolicy = "string"
      externals = {
        container = "string"
        path = "string"
        refreshConfiguration = {
          dateFormat = "string"
          pathPattern = "string"
          refreshInterval = "string"
          refreshType = "string"
          timeFormat = "string"
        }
        storageAccount = {
          accountKey = "string"
          accountName = "string"
          authenticationMode = "string"
        }
      }
      functions = [
        {
          name = "string"
          properties = {
            properties = {
              binding = {
                type = "string"
                // For remaining properties, see FunctionBinding objects
              }
              inputs = [
                {
                  dataType = "string"
                  isConfigurationParameter = bool
                }
              ]
              output = {
                dataType = "string"
              }
            }
            type = "string"
            // For remaining properties, see FunctionProperties objects
          }
        }
      ]
      inputs = [
        {
          name = "string"
          properties = {
            compression = {
              type = "string"
            }
            partitionKey = "string"
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
            watermarkSettings = {
              watermarkMode = "string"
            }
            type = "string"
            // For remaining properties, see InputProperties objects
          }
        }
      ]
      jobStorageAccount = {
        accountKey = "string"
        accountName = "string"
        authenticationMode = "string"
      }
      jobType = "string"
      outputErrorPolicy = "string"
      outputs = [
        {
          name = "string"
          properties = {
            datasource = {
              type = "string"
              // For remaining properties, see OutputDataSource objects
            }
            serialization = {
              type = "string"
              // For remaining properties, see Serialization objects
            }
            sizeWindow = int
            timeWindow = "string"
            watermarkSettings = {
              maxWatermarkDifferenceAcrossPartitions = "string"
              watermarkMode = "string"
            }
          }
        }
      ]
      outputStartMode = "string"
      outputStartTime = "string"
      sku = {
        capacity = int
        name = "string"
      }
      transformation = {
        name = "string"
        properties = {
          query = "string"
          streamingUnits = int
          validStreamingUnits = [
            int
          ]
        }
      }
    }
  })
}

InputProperties 对象

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

对于 参考,请使用:

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

对于 Stream,请使用:

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

FunctionProperties 对象

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

对于 聚合,请使用:

{
  type = "Aggregate"
}

对于 标量,请使用:

{
  type = "Scalar"
}

OutputDataSource 对象

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

对于 GatewayMessageBus,请使用:

{
  properties = {
    topic = "string"
  }
  type = "GatewayMessageBus"
}

对于 Microsoft.AzureFunction,请使用:

{
  properties = {
    apiKey = "string"
    functionAppName = "string"
    functionName = "string"
    maxBatchCount = int
    maxBatchSize = int
  }
  type = "Microsoft.AzureFunction"
}

对于 Microsoft.DBForPostgreSQL/servers/databases,请使用:

{
  properties = {
    authenticationMode = "string"
    database = "string"
    maxWriterCount = int
    password = "string"
    server = "string"
    table = "string"
    user = "string"
  }
  type = "Microsoft.DBForPostgreSQL/servers/databases"
}

对于 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"
    partitionCount = int
    partitionKey = "string"
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }
  type = "Microsoft.EventHub/EventHub"
}

对于 Microsoft.Kusto/clusters/databases,请使用:

{
  properties = {
    authenticationMode = "string"
    cluster = "string"
    database = "string"
    table = "string"
  }
  type = "Microsoft.Kusto/clusters/databases"
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  properties = {
    authenticationMode = "string"
    eventHubName = "string"
    partitionCount = int
    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 = {
    authenticationMode = "string"
    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"
    blobWriteMode = "string"
    container = "string"
    dateFormat = "string"
    pathPattern = "string"
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
        authenticationMode = "string"
      }
    ]
    timeFormat = "string"
  }
  type = "Microsoft.Storage/Blob"
}

对于 Microsoft.Storage/DocumentDB,请使用:

{
  properties = {
    accountId = "string"
    accountKey = "string"
    authenticationMode = "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"
}

对于 原始,请使用:

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

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.MachineLearningServices,请使用:

{
  properties = {
    apiKey = "string"
    batchSize = int
    endpoint = "string"
    inputRequestName = "string"
    inputs = [
      {
        dataType = "string"
        mapTo = int
        name = "string"
      }
    ]
    numberOfParallelRequests = int
    outputResponseName = "string"
    outputs = [
      {
        dataType = "string"
        mapTo = int
        name = "string"
      }
    ]
  }
  type = "Microsoft.MachineLearningServices"
}

对于 Microsoft.StreamAnalytics/CLRUdf,请使用:

{
  properties = {
    class = "string"
    dllPath = "string"
    method = "string"
    updateMode = "string"
  }
  type = "Microsoft.StreamAnalytics/CLRUdf"
}

对于 Microsoft.StreamAnalytics/JavascriptUdf,请使用:

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

ReferenceInputDataSource 对象

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

对于 文件,请使用:

{
  properties = {
    path = "string"
  }
  type = "File"
}

对于 Microsoft.Sql/Server/Database,请使用:

{
  properties = {
    authenticationMode = "string"
    database = "string"
    deltaSnapshotQuery = "string"
    fullSnapshotQuery = "string"
    password = "string"
    refreshRate = "string"
    refreshType = "string"
    server = "string"
    user = "string"
  }
  type = "Microsoft.Sql/Server/Database"
}

对于 Microsoft.Storage/Blob,请使用:

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

对于 原始,请使用:

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

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.EventGrid/EventSubscriptions,请使用:

{
  properties = {
    eventTypes = [
      "string"
    ]
    schema = "string"
    storageAccounts = [
      {
        accountKey = "string"
        accountName = "string"
        authenticationMode = "string"
      }
    ]
    subscriber = {
      properties = {
        authenticationMode = "string"
        consumerGroupName = "string"
        eventHubName = "string"
        partitionCount = int
        prefetchCount = int
        serviceBusNamespace = "string"
        sharedAccessPolicyKey = "string"
        sharedAccessPolicyName = "string"
      }
      type = "string"
    }
  }
  type = "Microsoft.EventGrid/EventSubscriptions"
}

对于 Microsoft.EventHub/EventHub,请使用:

{
  properties = {
    authenticationMode = "string"
    consumerGroupName = "string"
    eventHubName = "string"
    partitionCount = int
    prefetchCount = int
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }
  type = "Microsoft.EventHub/EventHub"
}

对于 Microsoft.ServiceBus/EventHub,请使用:

{
  properties = {
    authenticationMode = "string"
    consumerGroupName = "string"
    eventHubName = "string"
    partitionCount = int
    prefetchCount = int
    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"
        authenticationMode = "string"
      }
    ]
    timeFormat = "string"
  }
  type = "Microsoft.Storage/Blob"
}

对于 原始,请使用:

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

序列化对象

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

对于 Avro,请使用:

{
  properties = ?
  type = "Avro"
}

对于 Csv,请使用:

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

对于 customClr ,请使用:

{
  properties = {
    serializationClassName = "string"
    serializationDllPath = "string"
  }
  type = "CustomClr"
}

对于 Delta,请使用:

{
  properties = {
    deltaTablePath = "string"
    partitionColumns = [
      "string"
    ]
  }
  type = "Delta"
}

对于 Json,请使用:

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

对于 Parquet,请使用:

{
  properties = ?
  type = "Parquet"
}

属性值

AggregateFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “Aggregate”(必需)

AvroSerialization

名字 描述 价值
性能 与 Avro 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Avro”(必需)

AzureDataExplorerOutputDataSource

名字 描述 价值
性能 与 Azure 数据资源管理器输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureDataExplorerOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Kusto/clusters/databases”(必需)

AzureDataExplorerOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
Azure 数据资源管理器群集的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
数据库 Azure 数据资源管理器数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
桌子 Azure 表的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

AzureMachineLearningServiceFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习 Web 服务关联的绑定属性。 AzureMachineLearningServiceFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearningServices”(必需)

AzureMachineLearningServiceFunctionBindingProperties

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

AzureMachineLearningServiceInputColumn

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

AzureMachineLearningServiceOutputColumn

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

AzureMachineLearningStudioFunctionBinding

名字 描述 价值
性能 与 Azure 机器学习工作室关联的绑定属性。 AzureMachineLearningStudioFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.MachineLearning/WebService”(必需)

AzureMachineLearningStudioFunctionBindingProperties

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

AzureMachineLearningStudioInputColumn

名字 描述 价值
dataType 输入列的 (Azure 机器学习支持)数据类型。 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 介绍了有效的 Azure 机器学习数据类型的列表。 字符串
mapTo 此输入映射到的函数参数的从零开始的索引。 int
名字 输入列的名称。 字符串

AzureMachineLearningStudioInputs

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

AzureMachineLearningStudioOutputColumn

名字 描述 价值
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

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

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

AzureSynapseOutputDataSource

名字 描述 价值
性能 与 Azure Synapse 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 AzureSynapseOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Sql/Server/DataWarehouse”(必需)

AzureSynapseOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 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 路径前缀。 字符串
blobWriteMode Blob 写入模式。 “Append”
“Once”
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 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”
blobName Blob 输入的名称。 字符串
容器 关联的存储帐户中的容器的名称。 此容器包含要从中读取或写入到的 blob(s)。 PUT (CreateOrReplace) 请求时是必需的。 字符串
dateFormat 日期格式。 无论 {date} 出现在 pathPattern 中,此属性的值将改为用作日期格式。 字符串
deltaPathPattern 增量快照的路径模式。 字符串
deltaSnapshotRefreshRate 用户生成此引用 Blob 输入数据源的增量快照的间隔。 字符串
fullSnapshotRefreshRate Blob 输入数据源的刷新间隔。 字符串
pathPattern Blob 路径模式。 不是正则表达式。 它表示将匹配 Blob 名称的模式,以确定它们是否应作为作业的输入或输出包含在内。 有关更详细的说明和示例,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 字符串
sourcePartitionCount Blob 输入数据源的分区计数。 范围 1 - 256。 int
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”
“无”(必需)

CSharpFunctionBinding

名字 描述 价值
性能 与 CSharp 函数关联的绑定属性。 CSharpFunctionBindingProperties
类型 指示函数绑定类型。 “Microsoft.StreamAnalytics/CLRUdf”(必需)

CSharpFunctionBindingProperties

名字 描述 价值
包含单个函数定义的 Csharp 代码。 字符串
dllPath 包含单个函数定义的 Csharp 代码。 字符串
方法 包含单个函数定义的 Csharp 代码。 字符串
updateMode 流分析函数的刷新模式。 “Refreshable”
“Static”

CsvSerialization

名字 描述 价值
性能 与 CSV 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CsvSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Csv”(必需)

CsvSerializationProperties

名字 描述 价值
编码 指定传入数据的编码(在输入的情况下)和输出时传出数据的编码。 PUT (CreateOrReplace) 请求时是必需的。 “UTF8”
fieldDelimiter 指定将用于分隔逗号分隔值 (CSV) 记录的分隔符。 有关支持的值列表,请参阅 /rest/api/streamanalytics/streamanalytics/streamanalytics/stream-analytics-output。 PUT (CreateOrReplace) 请求时是必需的。 字符串

CustomClrSerialization

名字 描述 价值
性能 与 CustomClr 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 CustomClrSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “CustomClr”(必需)

CustomClrSerializationProperties

名字 描述 价值
serializationClassName 序列化类名称。 字符串
serializationDllPath 序列化库路径。 字符串

DeltaSerialization

名字 描述 价值
性能 与 Delta Lake 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DeltaSerializationProperties
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Delta”(必需)

DeltaSerializationProperties

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

DocumentDbOutputDataSource

名字 描述 价值
性能 与 DocumentDB 输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 DocumentDbOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.Storage/DocumentDB”(必需)

DocumentDbOutputDataSourceProperties

名字 描述 价值
accountId DocumentDB 帐户名称或 ID。 PUT (CreateOrReplace) 请求时是必需的。 字符串
accountKey DocumentDB 帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

EventGridStreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件网格输入关联的属性。 EventGridStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.EventGrid/EventSubscriptions”(必需)

EventGridStreamInputDataSourceProperties

名字 描述 价值
eventTypes 事件网格适配器支持的事件类型列表。 string[]
图式 指示事件网格架构类型。 “CloudEventSchema”
“EventGridEventSchema”
storageAccounts 一个或多个 Azure 存储帐户的列表。 PUT (CreateOrReplace) 请求时是必需的。 StorageAccount[]
订户 事件网格的订阅服务器。 目前仅支持 EventHub 订阅服务器。 EventHubV2StreamInputDataSource

EventHubOutputDataSource

名字 描述 价值
性能 与事件中心输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.ServiceBus/EventHub”(必需)

EventHubOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
eventHubName 事件中心的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
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) 请求时是必需的。 字符串
partitionCount 事件中心数据源的分区计数。 范围 1 - 256。 int
prefetchCount 消息接收方可以同时请求的消息数。 int
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”(必需)

EventHubV2StreamInputDataSource

名字 描述 价值
性能 与包含流数据的事件中心输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 EventHubStreamInputDataSourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 string (必需)

外部

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

FileReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的文件输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 FileReferenceInputDataSourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “File”(必需)

FileReferenceInputDataSourceProperties

名字 描述 价值
路径 文件的路径。 字符串

功能

名字 描述 价值
名字 资源名称 字符串
性能 与函数关联的属性。 FunctionProperties

FunctionBinding

名字 描述 价值
类型 对于 AzureMachineLearningStudioFunctionBinding,请设置为“Microsoft.MachineLearning/WebService”。 对于 AzureMachineLearningServiceFunctionBinding,请设置为“Microsoft.MachineLearningServices”。 对于 CSharpFunctionBinding,请设置为“Microsoft.StreamAnalytics/CLRUdf”。 对于 JavaScriptFunctionBinding,请设置为“Microsoft.StreamAnalytics/JavascriptUdf”。 “Microsoft.MachineLearning/WebService”
“Microsoft.MachineLearningServices”
“Microsoft.StreamAnalytics/CLRUdf”
“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

名字 描述 价值
主题 服务总线主题的名称。 字符串

身份

名字 描述 价值
类型 标识的类型可以是 SystemAssigned 或 UserAssigned。 字符串
userAssignedIdentities 用户分配的标识与流式处理作业资源相关联。 IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

名字 描述 价值

输入

名字 描述 价值
名字 资源名称 字符串
性能 与输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 InputProperties

InputProperties

名字 描述 价值
压缩 描述如何压缩输入数据 压缩
partitionKey partitionKey 描述用于对输入数据进行分区的输入数据中的键 字符串
序列化 描述如何序列化输入中的数据,或将数据写入输出时如何序列化数据。 PUT (CreateOrReplace) 请求时是必需的。 序列化
类型 设置为 type ReferenceInputProperties的“Reference”。 对于 StreamInputProperties类型,设置为“Stream”。 “Reference”
“Stream”(必需)
watermarkSettings 用于确定是否读取水印事件的设置。 InputWatermarkProperties

InputWatermarkProperties

名字 描述 价值
watermarkMode 输入水印模式。 “None”
“ReadWatermark”

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
sku 描述流式处理作业的 SKU。 PUT (CreateOrReplace) 请求时是必需的。 Sku
标签 资源标记 标记名称和值的字典。
类型 资源类型 “Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview”

输出

名字 描述 价值
名字 资源名称 字符串
性能 与输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 OutputProperties

OutputDataSource

名字 描述 价值
类型 对于 GatewayMessageBusOutputDataSource,请设置为“GatewayMessageBus”。 对于 AzureFunctionOutputDataSource,请设置为“Microsoft.AzureFunction”。 对于 PostgreSQLOutputDataSource,请设置为“Microsoft.DBForPostgreSQL/servers/databases”。 对于 azureDataLakeStoreOutputDataSource,请设置为“Microsoft.DataLake/Accounts”。 对于 type EventHubV2OutputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 AzureDataExplorerOutputDataSource,请设置为“Microsoft.Kusto/clusters/databases”。 对于 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”。 对于 RawOutputDatasource,请设置为“Raw”。 “GatewayMessageBus”
“Microsoft.AzureFunction”
“Microsoft.DataLake/Accounts”
“Microsoft.DBForPostgreSQL/servers/databases”
“Microsoft.EventHub/EventHub”
“Microsoft.Kusto/clusters/databases”
“Microsoft.ServiceBus/EventHub”
“Microsoft.ServiceBus/Queue”
“Microsoft.ServiceBus/Topic”
“Microsoft.Sql/Server/Database”
“Microsoft.Sql/Server/DataWarehouse”
“Microsoft.Storage/Blob”
“Microsoft.Storage/DocumentDB”
“Microsoft.Storage/Table”
“PowerBI”
“Raw”(必需)

OutputProperties

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

OutputWatermarkProperties

名字 描述 价值
maxWatermarkDifferenceAcrossPartitions 描述最快分区和最慢分区之间的最大增量,因此定义捕获下游作业中所有必要事件的无序窗口。 字符串
watermarkMode 输出水印模式。 “None”
“SendCurrentPartitionWatermark”
“SendLowestWatermarkAcrossPartitions”

ParquetSerialization

名字 描述 价值
性能 与 Parquet 序列化类型关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 任何
类型 指示输入或输出使用的序列化类型。 PUT (CreateOrReplace) 请求时是必需的。 “Parquet”(必需)

PostgreSQLOutputDataSource

名字 描述 价值
性能 与 PostgreSQL 输出数据源关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 PostgreSQLOutputDataSourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Microsoft.DBForPostgreSQL/servers/databases”(必需)

PostgreSQLOutputDataSourceProperties

名字 描述 价值
authenticationMode 身份验证模式。 “ConnectionString”
“Msi”
“UserToken”
数据库 Azure SQL 数据库的名称。 PUT (CreateOrReplace) 请求时是必需的。 字符串
maxWriterCount 最大编写器计数,目前仅提供 1(单个编写器)和 0(基于查询分区)。 PUT 请求可选。 int
密码 将用于连接到 Azure SQL 数据库的密码。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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)。 使用此属性有助于记住哪些用户用于获取刷新令牌。 字符串

RawInputDatasourceProperties

名字 描述 价值
有效载荷 输入数据的 JSON 序列化内容。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串
payloadUri 包含输入数据的 JSON 序列化内容的 Blob 的 SAS URL。 必须设置有效负载或 payloadUri,但不能同时设置两者。 字符串

RawOutputDatasource

名字 描述 价值
性能 与原始输出关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawOutputDatasourceProperties
类型 指示将写入数据源输出的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawOutputDatasourceProperties

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

RawReferenceInputDataSource

名字 描述 价值
性能 与包含引用数据的原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含引用数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

RawStreamInputDataSource

名字 描述 价值
性能 与原始输入关联的属性。 PUT (CreateOrReplace) 请求时是必需的。 RawInputDatasourceProperties
类型 指示包含流数据的输入数据源的类型。 PUT (CreateOrReplace) 请求时是必需的。 “Raw”(必需)

ReferenceInputDataSource

名字 描述 价值
类型 对于 fileReferenceInputDataSource类型,设置为“File”。 对于 azureSqlReferenceInputDataSource,请设置为“Microsoft.Sql/Server/Database”。 对于 BlobReferenceInputDataSource,请设置为“Microsoft.Storage/Blob”。 对于 RawReferenceInputDataSource,请设置为“Raw”。 “File”
“Microsoft.Sql/Server/Database”
“Microsoft.Storage/Blob”
“Raw”(必需)

ReferenceInputProperties

名字 描述 价值
数据源 描述包含引用数据的输入数据源。 PUT (CreateOrReplace) 请求时是必需的。 ReferenceInputDataSource
类型 指示输入是引用数据源还是流数据源。 PUT (CreateOrReplace) 请求时是必需的。 “Reference”(必需)

RefreshConfiguration

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

ScalarFunctionProperties

名字 描述 价值
类型 指示函数的类型。 “标量”(必需)

序列化

名字 描述 价值
类型 对于 AvroSerialization,请设置为“Avro”。 对于 CsvSerialization,请设置为“Csv”。 对于 customClrSerialization 类型,设置为“CustomClr”。 对于 DeltaSerialization类型,设置为“Delta”。 对于 JsonSerialization类型,设置为“Json”。 对于 ParquetSerialization类型,设置为“Parquet”。 “Avro”
“Csv”
“CustomClr”
“Delta”
“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 的容量。 int
名字 SKU 的名称。 PUT (CreateOrReplace) 请求时是必需的。 “Standard”

StorageAccount

名字 描述 价值
accountKey Azure 存储帐户的帐户密钥。 PUT (CreateOrReplace) 请求时是必需的。 字符串

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

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 EventGridStreamInputDataSource,设置为“Microsoft.EventGrid/EventSubscriptions”。 对于 type EventHubV2StreamInputDataSource,设置为“Microsoft.EventHub/EventHub”。 对于 EventHubStreamInputDataSource类型,设置为“Microsoft.ServiceBus/EventHub”。 对于 blobStreamInputDataSource类型,设置为“Microsoft.Storage/Blob”。 对于 rawStreamInputDataSource,请设置为 “RawStreamInputDataSource”。 “GatewayMessageBus”
“Microsoft.Devices/IotHubs”
“Microsoft.EventGrid/EventSubscriptions”
“Microsoft.EventHub/EventHub”
“Microsoft.ServiceBus/EventHub”
“Microsoft.Storage/Blob”
“Raw”(必需)

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[]