Microsoft.StreamAnalytics streamingjobs

• Latest
• 2021-10-01-preview
• 2020-03-01
• 2017-04-01-preview
• 2016-03-01

Bicep resource definition

The streamingjobs resource type can be deployed with operations that target:

• Resource groups - See resource group deployment commands

For a list of changed properties in each API version, see change log.

Resource format

To create a Microsoft.StreamAnalytics/streamingjobs resource, add the following Bicep to your template.

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'
  }
}

StreamInputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.Devices/IotHubs, use:

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

For Microsoft.EventGrid/EventSubscriptions, use:

{
  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'
}

For Microsoft.EventHub/EventHub, use:

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

For Microsoft.ServiceBus/EventHub, use:

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

For Microsoft.Storage/Blob, use:

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

For Raw, use:

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

InputProperties objects

Set the type property to specify the type of object.

For Reference, use:

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

For Stream, use:

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

FunctionProperties objects

Set the type property to specify the type of object.

For Aggregate, use:

{
  type: 'Aggregate'
}

For Scalar, use:

{
  type: 'Scalar'
}

Serialization objects

Set the type property to specify the type of object.

For Avro, use:

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

For Csv, use:

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

For CustomClr, use:

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

For Delta, use:

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

For Json, use:

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

For Parquet, use:

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

ReferenceInputDataSource objects

Set the type property to specify the type of object.

For File, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  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'
}

For Raw, use:

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

FunctionBinding objects

Set the type property to specify the type of object.

For Microsoft.MachineLearning/WebService, use:

{
  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'
}

For Microsoft.MachineLearningServices, use:

{
  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'
}

For Microsoft.StreamAnalytics/CLRUdf, use:

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

For Microsoft.StreamAnalytics/JavascriptUdf, use:

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

OutputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.AzureFunction, use:

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

For Microsoft.DBForPostgreSQL/servers/databases, use:

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

For Microsoft.DataLake/Accounts, use:

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

For Microsoft.EventHub/EventHub, use:

{
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.EventHub/EventHub'
}

For Microsoft.Kusto/clusters/databases, use:

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

For Microsoft.ServiceBus/EventHub, use:

{
  properties: {
    authenticationMode: 'string'
    eventHubName: 'string'
    partitionCount: int
    partitionKey: 'string'
    propertyColumns: [
      'string'
    ]
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
  }
  type: 'Microsoft.ServiceBus/EventHub'
}

For Microsoft.ServiceBus/Queue, use:

{
  properties: {
    authenticationMode: 'string'
    propertyColumns: [
      'string'
    ]
    queueName: 'string'
    serviceBusNamespace: 'string'
    sharedAccessPolicyKey: 'string'
    sharedAccessPolicyName: 'string'
    systemPropertyColumns: any(Azure.Bicep.Types.Concrete.AnyType)
  }
  type: 'Microsoft.ServiceBus/Queue'
}

For Microsoft.ServiceBus/Topic, use:

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

For Microsoft.Sql/Server/DataWarehouse, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  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'
}

For Microsoft.Storage/DocumentDB, use:

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

For Microsoft.Storage/Table, use:

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

For PowerBI, use:

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

For Raw, use:

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

Property values

AggregateFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Aggregate' (required)

AvroSerialization

Name	Description	Value
properties	The properties that are associated with the Avro serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Avro' (required)

AzureDataExplorerOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Explorer output. Required on PUT (CreateOrReplace) requests.	AzureDataExplorerOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Kusto/clusters/databases' (required)

AzureDataExplorerOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
cluster	The name of the Azure Data Explorer cluster. Required on PUT (CreateOrReplace) requests.	string
database	The name of the Azure Data Explorer database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

AzureDataLakeStoreOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Lake Store output. Required on PUT (CreateOrReplace) requests.	AzureDataLakeStoreOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DataLake/Accounts' (required)

AzureDataLakeStoreOutputDataSourceProperties

Name	Description	Value
accountName	The name of the Azure Data Lake Store account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dateFormat	The date format. Wherever {date} appears in filePathPrefix, the value of this property is used as the date format instead.	string
filePathPrefix	The location of the file to which the output should be written to. Required on PUT (CreateOrReplace) requests.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
tenantId	The tenant id of the user used to obtain the refresh token. Required on PUT (CreateOrReplace) requests.	string
timeFormat	The time format. Wherever {time} appears in filePathPrefix, the value of this property is used as the time format instead.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

AzureFunctionOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Azure Function output. Required on PUT (CreateOrReplace) requests.	AzureFunctionOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.AzureFunction' (required)

AzureFunctionOutputDataSourceProperties

Name	Description	Value
apiKey	If you want to use an Azure Function from another subscription, you can do so by providing the key to access your function.	string
functionAppName	The name of your Azure Functions app.	string
functionName	The name of the function in your Azure Functions app.	string
maxBatchCount	A property that lets you specify the maximum number of events in each batch that's sent to Azure Functions. The default value is 100.	int
maxBatchSize	A property that lets you set the maximum size for each output batch that's sent to your Azure function. The input unit is in bytes. By default, this value is 262,144 bytes (256 KB).	int

AzureMachineLearningServiceFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning web service.	AzureMachineLearningServiceFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearningServices' (required)

AzureMachineLearningServiceFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning web service.	string
inputRequestName	Label for the input request object.	string
inputs	The inputs for the Azure Machine Learning web service endpoint.	AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests	The number of parallel requests that will be sent per partition of your job to the machine learning service. Default is 1.	int
outputResponseName	Label for the output request object.	string
outputs	A list of outputs from the Azure Machine Learning web service endpoint execution.	AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningServiceOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the output column.	string

AzureMachineLearningStudioFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning Studio.	AzureMachineLearningStudioFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearning/WebService' (required)

AzureMachineLearningStudioFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning Studio. Find out more here: /azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs	string
inputs	The inputs for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputs
outputs	A list of outputs from the Azure Machine Learning Studio endpoint execution.	AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningStudioInputs

Name	Description	Value
columnNames	A list of input columns for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputColumn[]
name	The name of the input. This is the name provided while authoring the endpoint.	string

AzureMachineLearningStudioOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
name	The name of the output column.	string

AzureSqlDatabaseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure SQL database output. Required on PUT (CreateOrReplace) requests.	AzureSqlDatabaseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlDatabaseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxBatchCount	Max Batch count for write to Sql database, the default value is 10,000. Optional on PUT requests.	int
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureSqlReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with SQL DB input containing reference data. Required on PUT (CreateOrReplace) requests.	AzureSqlReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	This element is associated with the datasource element. This is the name of the database that output will be written to.	string
deltaSnapshotQuery	This element is associated with the datasource element. This query is used to fetch incremental changes from the SQL database. To use this option, we recommend using temporal tables in Azure SQL Database.	string
fullSnapshotQuery	This element is associated with the datasource element. This query is used to fetch data from the sql database.	string
password	This element is associated with the datasource element. This is the password that will be used to connect to the SQL Database instance.	string Constraints: Sensitive value. Pass in as a secure parameter.
refreshRate	This element is associated with the datasource element. This indicates how frequently the data will be fetched from the database. It is of DateTime format.	string
refreshType	Indicates the type of data refresh option.	'RefreshPeriodicallyWithDelta' 'RefreshPeriodicallyWithFull' 'Static'
server	This element is associated with the datasource element. This is the name of the server that contains the database that will be written to.	string
user	This element is associated with the datasource element. This is the user name that will be used to connect to the SQL Database instance.	string

AzureSynapseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Synapse output. Required on PUT (CreateOrReplace) requests.	AzureSynapseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/DataWarehouse' (required)

AzureSynapseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureTableOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Table output. Required on PUT (CreateOrReplace) requests.	AzureTableOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Table' (required)

AzureTableOutputDataSourceProperties

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
batchSize	The number of rows to write to the Azure Table at a time.	int
columnsToRemove	If specified, each item in the array is the name of a column to remove (if present) from output event entities.	string[]
partitionKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the partition key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
rowKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the row key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

BlobOutputDataSource

Name	Description	Value
properties	The properties that are associated with a blob output. Required on PUT (CreateOrReplace) requests.	BlobOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobPathPrefix	Blob path prefix.	string
blobWriteMode	Blob write mode.	'Append' 'Once'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing reference data. Required on PUT (CreateOrReplace) requests.	BlobReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobName	The name of the blob input.	string
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
deltaPathPattern	The path pattern of the delta snapshot.	string
deltaSnapshotRefreshRate	The interval that the user generates a delta snapshot of this reference blob input data source.	string
fullSnapshotRefreshRate	The refresh interval of the blob input data source.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 256.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing stream data. Required on PUT (CreateOrReplace) requests.	BlobStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 1024.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ClusterInfo

Name	Description	Value
id	The resource id of cluster.	string

Compression

Name	Description	Value
type	Indicates the type of compression that the input uses. Required on PUT (CreateOrReplace) requests.	'Deflate' 'GZip' 'None' (required)

CSharpFunctionBinding

Name	Description	Value
properties	The binding properties associated with a CSharp function.	CSharpFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/CLRUdf' (required)

CSharpFunctionBindingProperties

Name	Description	Value
class	The Csharp code containing a single function definition.	string
dllPath	The Csharp code containing a single function definition.	string
method	The Csharp code containing a single function definition.	string
updateMode	Refresh modes for Stream Analytics functions.	'Refreshable' 'Static'

CsvSerialization

Name	Description	Value
properties	The properties that are associated with the CSV serialization type. Required on PUT (CreateOrReplace) requests.	CsvSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Csv' (required)

CsvSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
fieldDelimiter	Specifies the delimiter that will be used to separate comma-separated value (CSV) records. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a list of supported values. Required on PUT (CreateOrReplace) requests.	string

CustomClrSerialization

Name	Description	Value
properties	The properties that are associated with the CustomClr serialization type. Required on PUT (CreateOrReplace) requests.	CustomClrSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'CustomClr' (required)

CustomClrSerializationProperties

Name	Description	Value
serializationClassName	The serialization class name.	string
serializationDllPath	The serialization library path.	string

DeltaSerialization

Name	Description	Value
properties	The properties that are associated with the Delta Lake serialization type. Required on PUT (CreateOrReplace) requests.	DeltaSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Delta' (required)

DeltaSerializationProperties

Name	Description	Value
deltaTablePath	Specifies the path of the Delta Lake table that the output will be written to.	string (required)
partitionColumns	Specifies the names of the columns for which the Delta Lake table will be partitioned. We are only supporting 1 partition column, but keeping it as an array for extensibility.	string[]

DocumentDbOutputDataSource

Name	Description	Value
properties	The properties that are associated with a DocumentDB output. Required on PUT (CreateOrReplace) requests.	DocumentDbOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/DocumentDB' (required)

DocumentDbOutputDataSourceProperties

Name	Description	Value
accountId	The DocumentDB account name or ID. Required on PUT (CreateOrReplace) requests.	string
accountKey	The account key for the DocumentDB account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
collectionNamePattern	The collection name pattern for the collections to be used. The collection name format can be constructed using the optional {partition} token, where partitions start from 0. See the DocumentDB section of /rest/api/streamanalytics/stream-analytics-output for more information. Required on PUT (CreateOrReplace) requests.	string
database	The name of the DocumentDB database. Required on PUT (CreateOrReplace) requests.	string
documentId	The name of the field in output events used to specify the primary key which insert or update operations are based on.	string
partitionKey	The name of the field in output events used to specify the key for partitioning output across collections. If 'collectionNamePattern' contains the {partition} token, this property is required to be specified.	string

EventGridStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an event grid input containing stream data.	EventGridStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventGrid/EventSubscriptions' (required)

EventGridStreamInputDataSourceProperties

Name	Description	Value
eventTypes	List of Event Types that are supported by the Event Grid adapter.	string[]
schema	Indicates the Event Grid schema type.	'CloudEventSchema' 'EventGridEventSchema'
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
subscriber	Subscribers for the Event Grid. Currently only EventHub Subscriber is supported.	EventHubV2StreamInputDataSource

EventHubOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
partitionKey	The key/column that is used to determine to which partition to send event data.	string
propertyColumns	The properties associated with this Event Hub output.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
consumerGroupName	The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.	string
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
prefetchCount	The number of messages that the message receiver can simultaneously request.	int
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubV2OutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	string (required)

External

Name	Description	Value
container	The UserCustomCode container.	string
path	The UserCustomCode path.	string
refreshConfiguration	The refresh parameters for any/all updatable user defined functions present in the job config.	RefreshConfiguration
storageAccount	The properties that are associated with an Azure Storage account	StorageAccount

FileReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a file input containing reference data. Required on PUT (CreateOrReplace) requests.	FileReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'File' (required)

FileReferenceInputDataSourceProperties

Name	Description	Value
path	The path of the file.	string

Function

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a function.	FunctionProperties

FunctionBinding

Name	Description	Value
type	Set to 'Microsoft.MachineLearning/WebService' for type AzureMachineLearningStudioFunctionBinding. Set to 'Microsoft.MachineLearningServices' for type AzureMachineLearningServiceFunctionBinding. Set to 'Microsoft.StreamAnalytics/CLRUdf' for type CSharpFunctionBinding. Set to 'Microsoft.StreamAnalytics/JavascriptUdf' for type JavaScriptFunctionBinding.	'Microsoft.MachineLearning/WebService' 'Microsoft.MachineLearningServices' 'Microsoft.StreamAnalytics/CLRUdf' 'Microsoft.StreamAnalytics/JavascriptUdf' (required)

FunctionConfiguration

Name	Description	Value
binding	The physical binding of the function. For example, in the Azure Machine Learning web service’s case, this describes the endpoint.	FunctionBinding
inputs		FunctionInput[]
output	Describes the output of a function.	FunctionOutput

FunctionInput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function input parameter. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string
isConfigurationParameter	A flag indicating if the parameter is a configuration parameter. True if this input parameter is expected to be a constant. Default is false.	bool

FunctionOutput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function output. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string

FunctionProperties

Name	Description	Value
properties		FunctionConfiguration
type	Set to 'Aggregate' for type AggregateFunctionProperties. Set to 'Scalar' for type ScalarFunctionProperties.	'Aggregate' 'Scalar' (required)

GatewayMessageBusOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Gateway Message Bus output. Required on PUT (CreateOrReplace) requests.	GatewayMessageBusOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusOutputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

GatewayMessageBusStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a gateway message bus input containing stream data.	GatewayMessageBusStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusStreamInputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

Identity

Name	Description	Value
type	The type of identity, can be SystemAssigned or UserAssigned.	string
userAssignedIdentities	The user assigned identities associated with the streaming job resource.	IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

Name	Description	Value

Input

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an input. Required on PUT (CreateOrReplace) requests.	InputProperties

InputProperties

Name	Description	Value
compression	Describes how input data is compressed	Compression
partitionKey	partitionKey Describes a key in the input data which is used for partitioning the input data	string
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
type	Set to 'Reference' for type ReferenceInputProperties. Set to 'Stream' for type StreamInputProperties.	'Reference' 'Stream' (required)
watermarkSettings	Settings which determine whether to read watermark events.	InputWatermarkProperties

InputWatermarkProperties

Name	Description	Value
watermarkMode	The input watermark mode.	'None' 'ReadWatermark'

IoTHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an IoT Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	IoTHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Devices/IotHubs' (required)

IoTHubStreamInputDataSourceProperties

Name	Description	Value
consumerGroupName	The name of an IoT Hub Consumer Group that should be used to read events from the IoT Hub. If not specified, the input uses the Iot Hub’s default consumer group.	string
endpoint	The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).	string
iotHubNamespace	The name or the URI of the IoT Hub. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the IoT Hub. This policy must contain at least the Service connect permission. Required on PUT (CreateOrReplace) requests.	string

JavaScriptFunctionBinding

Name	Description	Value
properties	The binding properties associated with a JavaScript function.	JavaScriptFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/JavascriptUdf' (required)

JavaScriptFunctionBindingProperties

Name	Description	Value
script	The JavaScript code containing a single function definition. For example: 'function (x, y) { return x + y; }'	string

JobStorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

JsonSerialization

Name	Description	Value
properties	The properties that are associated with the JSON serialization type. Required on PUT (CreateOrReplace) requests.	JsonSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Json' (required)

JsonSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
format	This property only applies to JSON serialization of outputs only. It is not applicable to inputs. This property specifies the format of the JSON the output will be written in. The currently supported values are 'lineSeparated' indicating the output will be formatted by having each JSON object separated by a new line and 'array' indicating the output will be formatted as an array of JSON objects. Default value is 'lineSeparated' if left null.	'Array' 'LineSeparated'

Microsoft.StreamAnalytics/streamingjobs

Name	Description	Value
identity	Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs.	Identity
location	The geo-location where the resource lives	string
name	The resource name	string (required)
properties	The properties that are associated with a streaming job. Required on PUT (CreateOrReplace) requests.	StreamingJobProperties
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
tags	Resource tags	Dictionary of tag names and values. See Tags in templates

Output

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an output. Required on PUT (CreateOrReplace) requests.	OutputProperties

OutputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusOutputDataSource. Set to 'Microsoft.AzureFunction' for type AzureFunctionOutputDataSource. Set to 'Microsoft.DBForPostgreSQL/servers/databases' for type PostgreSQLOutputDataSource. Set to 'Microsoft.DataLake/Accounts' for type AzureDataLakeStoreOutputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2OutputDataSource. Set to 'Microsoft.Kusto/clusters/databases' for type AzureDataExplorerOutputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubOutputDataSource. Set to 'Microsoft.ServiceBus/Queue' for type ServiceBusQueueOutputDataSource. Set to 'Microsoft.ServiceBus/Topic' for type ServiceBusTopicOutputDataSource. Set to 'Microsoft.Sql/Server/DataWarehouse' for type AzureSynapseOutputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlDatabaseOutputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobOutputDataSource. Set to 'Microsoft.Storage/DocumentDB' for type DocumentDbOutputDataSource. Set to 'Microsoft.Storage/Table' for type AzureTableOutputDataSource. Set to 'PowerBI' for type PowerBIOutputDataSource. Set to 'Raw' for type RawOutputDatasource.	'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' (required)

OutputProperties

Name	Description	Value
datasource	Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.	OutputDataSource
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
sizeWindow	The size window to constrain a Stream Analytics output to.	int
timeWindow	The time frame for filtering Stream Analytics job outputs.	string
watermarkSettings	Settings which determine whether to send watermarks to downstream.	OutputWatermarkProperties

OutputWatermarkProperties

Name	Description	Value
maxWatermarkDifferenceAcrossPartitions	Describes the maximal delta between the fastest and slowest partitions, so the out of order window that catches all necessary events in downstream jobs is well defined.	string
watermarkMode	The output watermark mode.	'None' 'SendCurrentPartitionWatermark' 'SendLowestWatermarkAcrossPartitions'

ParquetSerialization

Name	Description	Value
properties	The properties that are associated with the Parquet serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Parquet' (required)

PostgreSQLOutputDataSource

Name	Description	Value
properties	The properties that are associated with a PostgreSQL output data source. Required on PUT (CreateOrReplace) requests.	PostgreSQLOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DBForPostgreSQL/servers/databases' (required)

PostgreSQLOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

PowerBIOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Power BI output. Required on PUT (CreateOrReplace) requests.	PowerBIOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'PowerBI' (required)

PowerBIOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dataset	The name of the Power BI dataset. Required on PUT (CreateOrReplace) requests.	string
groupId	The ID of the Power BI group.	string
groupName	The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Power BI table under the specified dataset. Required on PUT (CreateOrReplace) requests.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

RawInputDatasourceProperties

Name	Description	Value
payload	The JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string
payloadUri	The SAS URL to a blob containing the JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string

RawOutputDatasource

Name	Description	Value
properties	The properties that are associated with a raw output. Required on PUT (CreateOrReplace) requests.	RawOutputDatasourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawOutputDatasourceProperties

Name	Description	Value
payloadUri	The SAS URL to a blob where the output should be written. If this property is not set, output data will be written into a temporary storage, and a SAS URL to that temporary storage will be included in the result.	string

RawReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input containing reference data. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

ReferenceInputDataSource

Name	Description	Value
type	Set to 'File' for type FileReferenceInputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlReferenceInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobReferenceInputDataSource. Set to 'Raw' for type RawReferenceInputDataSource.	'File' 'Microsoft.Sql/Server/Database' 'Microsoft.Storage/Blob' 'Raw' (required)

ReferenceInputProperties

Name	Description	Value
datasource	Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests.	ReferenceInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Reference' (required)

RefreshConfiguration

Name	Description	Value
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
refreshInterval	The refresh interval.	string
refreshType	This property indicates which data refresh option to use, Blocking or Nonblocking.	'Blocking' 'Nonblocking'
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ScalarFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Scalar' (required)

Serialization

Name	Description	Value
type	Set to 'Avro' for type AvroSerialization. Set to 'Csv' for type CsvSerialization. Set to 'CustomClr' for type CustomClrSerialization. Set to 'Delta' for type DeltaSerialization. Set to 'Json' for type JsonSerialization. Set to 'Parquet' for type ParquetSerialization.	'Avro' 'Csv' 'CustomClr' 'Delta' 'Json' 'Parquet' (required)

ServiceBusQueueOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Queue output. Required on PUT (CreateOrReplace) requests.	ServiceBusQueueOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Queue' (required)

ServiceBusQueueOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
queueName	The name of the Service Bus Queue. Required on PUT (CreateOrReplace) requests.	string
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Queue. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	any

ServiceBusTopicOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Topic output. Required on PUT (CreateOrReplace) requests.	ServiceBusTopicOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Topic' (required)

ServiceBusTopicOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Topic Output. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
topicName	The name of the Service Bus Topic. Required on PUT (CreateOrReplace) requests.	string

ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns

Name	Description	Value

Sku

Name	Description	Value
capacity	The capacity of the SKU.	int
name	The name of the SKU. Required on PUT (CreateOrReplace) requests.	'Standard'

StorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

StreamingJobProperties

Name	Description	Value
cluster	The cluster which streaming jobs will run on.	ClusterInfo
compatibilityLevel	Controls certain runtime behaviors of the streaming job.	'1.0' '1.2'
contentStoragePolicy	Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. .	'JobStorageAccount' 'SystemAccount'
dataLocale	The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to 'en-US' if none specified.	string
eventsLateArrivalMaxDelayInSeconds	The maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.	int
eventsOutOfOrderMaxDelayInSeconds	The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.	int
eventsOutOfOrderPolicy	Indicates the policy to apply to events that arrive out of order in the input event stream.	'Adjust' 'Drop'
externals	The storage account where the custom code artifacts are located.	External
functions	A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Function[]
inputs	A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.	Input[]
jobStorageAccount	The properties that are associated with an Azure Storage account with MSI	JobStorageAccount
jobType	Describes the type of the job. Valid modes are Cloud and 'Edge'.	'Cloud' 'Edge'
outputErrorPolicy	Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).	'Drop' 'Stop'
outputs	A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.	Output[]
outputStartMode	This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time.	'CustomTime' 'JobStartTime' 'LastOutputEventTime'
outputStartTime	Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.	string
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
transformation	Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Transformation

StreamInputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusStreamInputDataSource. Set to 'Microsoft.Devices/IotHubs' for type IoTHubStreamInputDataSource. Set to 'Microsoft.EventGrid/EventSubscriptions' for type EventGridStreamInputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2StreamInputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubStreamInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobStreamInputDataSource. Set to 'Raw' for type RawStreamInputDataSource.	'GatewayMessageBus' 'Microsoft.Devices/IotHubs' 'Microsoft.EventGrid/EventSubscriptions' 'Microsoft.EventHub/EventHub' 'Microsoft.ServiceBus/EventHub' 'Microsoft.Storage/Blob' 'Raw' (required)

StreamInputProperties

Name	Description	Value
datasource	Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests.	StreamInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Stream' (required)

TrackedResourceTags

Name	Description	Value

Transformation

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a transformation. Required on PUT (CreateOrReplace) requests.	TransformationProperties

TransformationProperties

Name	Description	Value
query	Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests.	string
streamingUnits	Specifies the number of streaming units that the streaming job uses.	int
validStreamingUnits	Specifies the valid streaming units a streaming job can scale to.	int[]

Quickstart samples

The following quickstart samples deploy this resource type.

Bicep File

Description

Create a Standard Stream Analytics Job

This template creates a Standard Stream Analytics Job. For more information, Azure Stream Analytics is a real-time analytics and complex event-processing engine that is designed to analyze and process high volumes of fast streaming data from multiple sources simultaneously. Patterns and relationships can be identified in information extracted from a number of input sources including devices, sensors, clickstreams, social media feeds, and applications. These patterns can be used to trigger actions and initiate workflows such creating alerts, feeding information to a reporting tool, or storing transformed data for later use. Also, Stream Analytics is available on Azure IoT Edge runtime, and supports the same exact language or syntax as cloud.

ARM template resource definition

The streamingjobs resource type can be deployed with operations that target:

• Resource groups - See resource group deployment commands

For a list of changed properties in each API version, see change log.

Resource format

To create a Microsoft.StreamAnalytics/streamingjobs resource, add the following JSON to your template.

{
  "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"
  }
}

StreamInputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.Devices/IotHubs, use:

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

For Microsoft.EventGrid/EventSubscriptions, use:

{
  "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"
}

For Microsoft.EventHub/EventHub, use:

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

For Microsoft.ServiceBus/EventHub, use:

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

For Microsoft.Storage/Blob, use:

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

For Raw, use:

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

InputProperties objects

Set the type property to specify the type of object.

For Reference, use:

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

For Stream, use:

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

FunctionProperties objects

Set the type property to specify the type of object.

For Aggregate, use:

{
  "type": "Aggregate"
}

For Scalar, use:

{
  "type": "Scalar"
}

Serialization objects

Set the type property to specify the type of object.

For Avro, use:

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

For Csv, use:

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

For CustomClr, use:

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

For Delta, use:

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

For Json, use:

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

For Parquet, use:

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

ReferenceInputDataSource objects

Set the type property to specify the type of object.

For File, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  "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"
}

For Raw, use:

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

FunctionBinding objects

Set the type property to specify the type of object.

For Microsoft.MachineLearning/WebService, use:

{
  "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"
}

For Microsoft.MachineLearningServices, use:

{
  "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"
}

For Microsoft.StreamAnalytics/CLRUdf, use:

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

For Microsoft.StreamAnalytics/JavascriptUdf, use:

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

OutputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.AzureFunction, use:

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

For Microsoft.DBForPostgreSQL/servers/databases, use:

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

For Microsoft.DataLake/Accounts, use:

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

For Microsoft.EventHub/EventHub, use:

{
  "properties": {
    "authenticationMode": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "partitionKey": "string",
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  },
  "type": "Microsoft.EventHub/EventHub"
}

For Microsoft.Kusto/clusters/databases, use:

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

For Microsoft.ServiceBus/EventHub, use:

{
  "properties": {
    "authenticationMode": "string",
    "eventHubName": "string",
    "partitionCount": "int",
    "partitionKey": "string",
    "propertyColumns": [ "string" ],
    "serviceBusNamespace": "string",
    "sharedAccessPolicyKey": "string",
    "sharedAccessPolicyName": "string"
  },
  "type": "Microsoft.ServiceBus/EventHub"
}

For Microsoft.ServiceBus/Queue, use:

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

For Microsoft.ServiceBus/Topic, use:

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

For Microsoft.Sql/Server/DataWarehouse, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  "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"
}

For Microsoft.Storage/DocumentDB, use:

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

For Microsoft.Storage/Table, use:

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

For PowerBI, use:

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

For Raw, use:

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

Property values

AggregateFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Aggregate' (required)

AvroSerialization

Name	Description	Value
properties	The properties that are associated with the Avro serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Avro' (required)

AzureDataExplorerOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Explorer output. Required on PUT (CreateOrReplace) requests.	AzureDataExplorerOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Kusto/clusters/databases' (required)

AzureDataExplorerOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
cluster	The name of the Azure Data Explorer cluster. Required on PUT (CreateOrReplace) requests.	string
database	The name of the Azure Data Explorer database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

AzureDataLakeStoreOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Lake Store output. Required on PUT (CreateOrReplace) requests.	AzureDataLakeStoreOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DataLake/Accounts' (required)

AzureDataLakeStoreOutputDataSourceProperties

Name	Description	Value
accountName	The name of the Azure Data Lake Store account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dateFormat	The date format. Wherever {date} appears in filePathPrefix, the value of this property is used as the date format instead.	string
filePathPrefix	The location of the file to which the output should be written to. Required on PUT (CreateOrReplace) requests.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
tenantId	The tenant id of the user used to obtain the refresh token. Required on PUT (CreateOrReplace) requests.	string
timeFormat	The time format. Wherever {time} appears in filePathPrefix, the value of this property is used as the time format instead.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

AzureFunctionOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Azure Function output. Required on PUT (CreateOrReplace) requests.	AzureFunctionOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.AzureFunction' (required)

AzureFunctionOutputDataSourceProperties

Name	Description	Value
apiKey	If you want to use an Azure Function from another subscription, you can do so by providing the key to access your function.	string
functionAppName	The name of your Azure Functions app.	string
functionName	The name of the function in your Azure Functions app.	string
maxBatchCount	A property that lets you specify the maximum number of events in each batch that's sent to Azure Functions. The default value is 100.	int
maxBatchSize	A property that lets you set the maximum size for each output batch that's sent to your Azure function. The input unit is in bytes. By default, this value is 262,144 bytes (256 KB).	int

AzureMachineLearningServiceFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning web service.	AzureMachineLearningServiceFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearningServices' (required)

AzureMachineLearningServiceFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning web service.	string
inputRequestName	Label for the input request object.	string
inputs	The inputs for the Azure Machine Learning web service endpoint.	AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests	The number of parallel requests that will be sent per partition of your job to the machine learning service. Default is 1.	int
outputResponseName	Label for the output request object.	string
outputs	A list of outputs from the Azure Machine Learning web service endpoint execution.	AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningServiceOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the output column.	string

AzureMachineLearningStudioFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning Studio.	AzureMachineLearningStudioFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearning/WebService' (required)

AzureMachineLearningStudioFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning Studio. Find out more here: /azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs	string
inputs	The inputs for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputs
outputs	A list of outputs from the Azure Machine Learning Studio endpoint execution.	AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningStudioInputs

Name	Description	Value
columnNames	A list of input columns for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputColumn[]
name	The name of the input. This is the name provided while authoring the endpoint.	string

AzureMachineLearningStudioOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
name	The name of the output column.	string

AzureSqlDatabaseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure SQL database output. Required on PUT (CreateOrReplace) requests.	AzureSqlDatabaseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlDatabaseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxBatchCount	Max Batch count for write to Sql database, the default value is 10,000. Optional on PUT requests.	int
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureSqlReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with SQL DB input containing reference data. Required on PUT (CreateOrReplace) requests.	AzureSqlReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	This element is associated with the datasource element. This is the name of the database that output will be written to.	string
deltaSnapshotQuery	This element is associated with the datasource element. This query is used to fetch incremental changes from the SQL database. To use this option, we recommend using temporal tables in Azure SQL Database.	string
fullSnapshotQuery	This element is associated with the datasource element. This query is used to fetch data from the sql database.	string
password	This element is associated with the datasource element. This is the password that will be used to connect to the SQL Database instance.	string Constraints: Sensitive value. Pass in as a secure parameter.
refreshRate	This element is associated with the datasource element. This indicates how frequently the data will be fetched from the database. It is of DateTime format.	string
refreshType	Indicates the type of data refresh option.	'RefreshPeriodicallyWithDelta' 'RefreshPeriodicallyWithFull' 'Static'
server	This element is associated with the datasource element. This is the name of the server that contains the database that will be written to.	string
user	This element is associated with the datasource element. This is the user name that will be used to connect to the SQL Database instance.	string

AzureSynapseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Synapse output. Required on PUT (CreateOrReplace) requests.	AzureSynapseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/DataWarehouse' (required)

AzureSynapseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureTableOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Table output. Required on PUT (CreateOrReplace) requests.	AzureTableOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Table' (required)

AzureTableOutputDataSourceProperties

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
batchSize	The number of rows to write to the Azure Table at a time.	int
columnsToRemove	If specified, each item in the array is the name of a column to remove (if present) from output event entities.	string[]
partitionKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the partition key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
rowKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the row key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

BlobOutputDataSource

Name	Description	Value
properties	The properties that are associated with a blob output. Required on PUT (CreateOrReplace) requests.	BlobOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobPathPrefix	Blob path prefix.	string
blobWriteMode	Blob write mode.	'Append' 'Once'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing reference data. Required on PUT (CreateOrReplace) requests.	BlobReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobName	The name of the blob input.	string
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
deltaPathPattern	The path pattern of the delta snapshot.	string
deltaSnapshotRefreshRate	The interval that the user generates a delta snapshot of this reference blob input data source.	string
fullSnapshotRefreshRate	The refresh interval of the blob input data source.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 256.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing stream data. Required on PUT (CreateOrReplace) requests.	BlobStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 1024.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ClusterInfo

Name	Description	Value
id	The resource id of cluster.	string

Compression

Name	Description	Value
type	Indicates the type of compression that the input uses. Required on PUT (CreateOrReplace) requests.	'Deflate' 'GZip' 'None' (required)

CSharpFunctionBinding

Name	Description	Value
properties	The binding properties associated with a CSharp function.	CSharpFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/CLRUdf' (required)

CSharpFunctionBindingProperties

Name	Description	Value
class	The Csharp code containing a single function definition.	string
dllPath	The Csharp code containing a single function definition.	string
method	The Csharp code containing a single function definition.	string
updateMode	Refresh modes for Stream Analytics functions.	'Refreshable' 'Static'

CsvSerialization

Name	Description	Value
properties	The properties that are associated with the CSV serialization type. Required on PUT (CreateOrReplace) requests.	CsvSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Csv' (required)

CsvSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
fieldDelimiter	Specifies the delimiter that will be used to separate comma-separated value (CSV) records. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a list of supported values. Required on PUT (CreateOrReplace) requests.	string

CustomClrSerialization

Name	Description	Value
properties	The properties that are associated with the CustomClr serialization type. Required on PUT (CreateOrReplace) requests.	CustomClrSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'CustomClr' (required)

CustomClrSerializationProperties

Name	Description	Value
serializationClassName	The serialization class name.	string
serializationDllPath	The serialization library path.	string

DeltaSerialization

Name	Description	Value
properties	The properties that are associated with the Delta Lake serialization type. Required on PUT (CreateOrReplace) requests.	DeltaSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Delta' (required)

DeltaSerializationProperties

Name	Description	Value
deltaTablePath	Specifies the path of the Delta Lake table that the output will be written to.	string (required)
partitionColumns	Specifies the names of the columns for which the Delta Lake table will be partitioned. We are only supporting 1 partition column, but keeping it as an array for extensibility.	string[]

DocumentDbOutputDataSource

Name	Description	Value
properties	The properties that are associated with a DocumentDB output. Required on PUT (CreateOrReplace) requests.	DocumentDbOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/DocumentDB' (required)

DocumentDbOutputDataSourceProperties

Name	Description	Value
accountId	The DocumentDB account name or ID. Required on PUT (CreateOrReplace) requests.	string
accountKey	The account key for the DocumentDB account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
collectionNamePattern	The collection name pattern for the collections to be used. The collection name format can be constructed using the optional {partition} token, where partitions start from 0. See the DocumentDB section of /rest/api/streamanalytics/stream-analytics-output for more information. Required on PUT (CreateOrReplace) requests.	string
database	The name of the DocumentDB database. Required on PUT (CreateOrReplace) requests.	string
documentId	The name of the field in output events used to specify the primary key which insert or update operations are based on.	string
partitionKey	The name of the field in output events used to specify the key for partitioning output across collections. If 'collectionNamePattern' contains the {partition} token, this property is required to be specified.	string

EventGridStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an event grid input containing stream data.	EventGridStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventGrid/EventSubscriptions' (required)

EventGridStreamInputDataSourceProperties

Name	Description	Value
eventTypes	List of Event Types that are supported by the Event Grid adapter.	string[]
schema	Indicates the Event Grid schema type.	'CloudEventSchema' 'EventGridEventSchema'
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
subscriber	Subscribers for the Event Grid. Currently only EventHub Subscriber is supported.	EventHubV2StreamInputDataSource

EventHubOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
partitionKey	The key/column that is used to determine to which partition to send event data.	string
propertyColumns	The properties associated with this Event Hub output.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
consumerGroupName	The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.	string
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
prefetchCount	The number of messages that the message receiver can simultaneously request.	int
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubV2OutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	string (required)

External

Name	Description	Value
container	The UserCustomCode container.	string
path	The UserCustomCode path.	string
refreshConfiguration	The refresh parameters for any/all updatable user defined functions present in the job config.	RefreshConfiguration
storageAccount	The properties that are associated with an Azure Storage account	StorageAccount

FileReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a file input containing reference data. Required on PUT (CreateOrReplace) requests.	FileReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'File' (required)

FileReferenceInputDataSourceProperties

Name	Description	Value
path	The path of the file.	string

Function

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a function.	FunctionProperties

FunctionBinding

Name	Description	Value
type	Set to 'Microsoft.MachineLearning/WebService' for type AzureMachineLearningStudioFunctionBinding. Set to 'Microsoft.MachineLearningServices' for type AzureMachineLearningServiceFunctionBinding. Set to 'Microsoft.StreamAnalytics/CLRUdf' for type CSharpFunctionBinding. Set to 'Microsoft.StreamAnalytics/JavascriptUdf' for type JavaScriptFunctionBinding.	'Microsoft.MachineLearning/WebService' 'Microsoft.MachineLearningServices' 'Microsoft.StreamAnalytics/CLRUdf' 'Microsoft.StreamAnalytics/JavascriptUdf' (required)

FunctionConfiguration

Name	Description	Value
binding	The physical binding of the function. For example, in the Azure Machine Learning web service’s case, this describes the endpoint.	FunctionBinding
inputs		FunctionInput[]
output	Describes the output of a function.	FunctionOutput

FunctionInput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function input parameter. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string
isConfigurationParameter	A flag indicating if the parameter is a configuration parameter. True if this input parameter is expected to be a constant. Default is false.	bool

FunctionOutput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function output. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string

FunctionProperties

Name	Description	Value
properties		FunctionConfiguration
type	Set to 'Aggregate' for type AggregateFunctionProperties. Set to 'Scalar' for type ScalarFunctionProperties.	'Aggregate' 'Scalar' (required)

GatewayMessageBusOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Gateway Message Bus output. Required on PUT (CreateOrReplace) requests.	GatewayMessageBusOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusOutputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

GatewayMessageBusStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a gateway message bus input containing stream data.	GatewayMessageBusStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusStreamInputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

Identity

Name	Description	Value
type	The type of identity, can be SystemAssigned or UserAssigned.	string
userAssignedIdentities	The user assigned identities associated with the streaming job resource.	IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

Name	Description	Value

Input

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an input. Required on PUT (CreateOrReplace) requests.	InputProperties

InputProperties

Name	Description	Value
compression	Describes how input data is compressed	Compression
partitionKey	partitionKey Describes a key in the input data which is used for partitioning the input data	string
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
type	Set to 'Reference' for type ReferenceInputProperties. Set to 'Stream' for type StreamInputProperties.	'Reference' 'Stream' (required)
watermarkSettings	Settings which determine whether to read watermark events.	InputWatermarkProperties

InputWatermarkProperties

Name	Description	Value
watermarkMode	The input watermark mode.	'None' 'ReadWatermark'

IoTHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an IoT Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	IoTHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Devices/IotHubs' (required)

IoTHubStreamInputDataSourceProperties

Name	Description	Value
consumerGroupName	The name of an IoT Hub Consumer Group that should be used to read events from the IoT Hub. If not specified, the input uses the Iot Hub’s default consumer group.	string
endpoint	The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).	string
iotHubNamespace	The name or the URI of the IoT Hub. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the IoT Hub. This policy must contain at least the Service connect permission. Required on PUT (CreateOrReplace) requests.	string

JavaScriptFunctionBinding

Name	Description	Value
properties	The binding properties associated with a JavaScript function.	JavaScriptFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/JavascriptUdf' (required)

JavaScriptFunctionBindingProperties

Name	Description	Value
script	The JavaScript code containing a single function definition. For example: 'function (x, y) { return x + y; }'	string

JobStorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

JsonSerialization

Name	Description	Value
properties	The properties that are associated with the JSON serialization type. Required on PUT (CreateOrReplace) requests.	JsonSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Json' (required)

JsonSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
format	This property only applies to JSON serialization of outputs only. It is not applicable to inputs. This property specifies the format of the JSON the output will be written in. The currently supported values are 'lineSeparated' indicating the output will be formatted by having each JSON object separated by a new line and 'array' indicating the output will be formatted as an array of JSON objects. Default value is 'lineSeparated' if left null.	'Array' 'LineSeparated'

Microsoft.StreamAnalytics/streamingjobs

Name	Description	Value
apiVersion	The api version	'2021-10-01-preview'
identity	Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs.	Identity
location	The geo-location where the resource lives	string
name	The resource name	string (required)
properties	The properties that are associated with a streaming job. Required on PUT (CreateOrReplace) requests.	StreamingJobProperties
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
tags	Resource tags	Dictionary of tag names and values. See Tags in templates
type	The resource type	'Microsoft.StreamAnalytics/streamingjobs'

Output

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an output. Required on PUT (CreateOrReplace) requests.	OutputProperties

OutputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusOutputDataSource. Set to 'Microsoft.AzureFunction' for type AzureFunctionOutputDataSource. Set to 'Microsoft.DBForPostgreSQL/servers/databases' for type PostgreSQLOutputDataSource. Set to 'Microsoft.DataLake/Accounts' for type AzureDataLakeStoreOutputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2OutputDataSource. Set to 'Microsoft.Kusto/clusters/databases' for type AzureDataExplorerOutputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubOutputDataSource. Set to 'Microsoft.ServiceBus/Queue' for type ServiceBusQueueOutputDataSource. Set to 'Microsoft.ServiceBus/Topic' for type ServiceBusTopicOutputDataSource. Set to 'Microsoft.Sql/Server/DataWarehouse' for type AzureSynapseOutputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlDatabaseOutputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobOutputDataSource. Set to 'Microsoft.Storage/DocumentDB' for type DocumentDbOutputDataSource. Set to 'Microsoft.Storage/Table' for type AzureTableOutputDataSource. Set to 'PowerBI' for type PowerBIOutputDataSource. Set to 'Raw' for type RawOutputDatasource.	'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' (required)

OutputProperties

Name	Description	Value
datasource	Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.	OutputDataSource
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
sizeWindow	The size window to constrain a Stream Analytics output to.	int
timeWindow	The time frame for filtering Stream Analytics job outputs.	string
watermarkSettings	Settings which determine whether to send watermarks to downstream.	OutputWatermarkProperties

OutputWatermarkProperties

Name	Description	Value
maxWatermarkDifferenceAcrossPartitions	Describes the maximal delta between the fastest and slowest partitions, so the out of order window that catches all necessary events in downstream jobs is well defined.	string
watermarkMode	The output watermark mode.	'None' 'SendCurrentPartitionWatermark' 'SendLowestWatermarkAcrossPartitions'

ParquetSerialization

Name	Description	Value
properties	The properties that are associated with the Parquet serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Parquet' (required)

PostgreSQLOutputDataSource

Name	Description	Value
properties	The properties that are associated with a PostgreSQL output data source. Required on PUT (CreateOrReplace) requests.	PostgreSQLOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DBForPostgreSQL/servers/databases' (required)

PostgreSQLOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

PowerBIOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Power BI output. Required on PUT (CreateOrReplace) requests.	PowerBIOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'PowerBI' (required)

PowerBIOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dataset	The name of the Power BI dataset. Required on PUT (CreateOrReplace) requests.	string
groupId	The ID of the Power BI group.	string
groupName	The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Power BI table under the specified dataset. Required on PUT (CreateOrReplace) requests.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

RawInputDatasourceProperties

Name	Description	Value
payload	The JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string
payloadUri	The SAS URL to a blob containing the JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string

RawOutputDatasource

Name	Description	Value
properties	The properties that are associated with a raw output. Required on PUT (CreateOrReplace) requests.	RawOutputDatasourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawOutputDatasourceProperties

Name	Description	Value
payloadUri	The SAS URL to a blob where the output should be written. If this property is not set, output data will be written into a temporary storage, and a SAS URL to that temporary storage will be included in the result.	string

RawReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input containing reference data. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

ReferenceInputDataSource

Name	Description	Value
type	Set to 'File' for type FileReferenceInputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlReferenceInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobReferenceInputDataSource. Set to 'Raw' for type RawReferenceInputDataSource.	'File' 'Microsoft.Sql/Server/Database' 'Microsoft.Storage/Blob' 'Raw' (required)

ReferenceInputProperties

Name	Description	Value
datasource	Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests.	ReferenceInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Reference' (required)

RefreshConfiguration

Name	Description	Value
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
refreshInterval	The refresh interval.	string
refreshType	This property indicates which data refresh option to use, Blocking or Nonblocking.	'Blocking' 'Nonblocking'
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ScalarFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Scalar' (required)

Serialization

Name	Description	Value
type	Set to 'Avro' for type AvroSerialization. Set to 'Csv' for type CsvSerialization. Set to 'CustomClr' for type CustomClrSerialization. Set to 'Delta' for type DeltaSerialization. Set to 'Json' for type JsonSerialization. Set to 'Parquet' for type ParquetSerialization.	'Avro' 'Csv' 'CustomClr' 'Delta' 'Json' 'Parquet' (required)

ServiceBusQueueOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Queue output. Required on PUT (CreateOrReplace) requests.	ServiceBusQueueOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Queue' (required)

ServiceBusQueueOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
queueName	The name of the Service Bus Queue. Required on PUT (CreateOrReplace) requests.	string
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Queue. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	any

ServiceBusTopicOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Topic output. Required on PUT (CreateOrReplace) requests.	ServiceBusTopicOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Topic' (required)

ServiceBusTopicOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Topic Output. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
topicName	The name of the Service Bus Topic. Required on PUT (CreateOrReplace) requests.	string

ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns

Name	Description	Value

Sku

Name	Description	Value
capacity	The capacity of the SKU.	int
name	The name of the SKU. Required on PUT (CreateOrReplace) requests.	'Standard'

StorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

StreamingJobProperties

Name	Description	Value
cluster	The cluster which streaming jobs will run on.	ClusterInfo
compatibilityLevel	Controls certain runtime behaviors of the streaming job.	'1.0' '1.2'
contentStoragePolicy	Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. .	'JobStorageAccount' 'SystemAccount'
dataLocale	The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to 'en-US' if none specified.	string
eventsLateArrivalMaxDelayInSeconds	The maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.	int
eventsOutOfOrderMaxDelayInSeconds	The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.	int
eventsOutOfOrderPolicy	Indicates the policy to apply to events that arrive out of order in the input event stream.	'Adjust' 'Drop'
externals	The storage account where the custom code artifacts are located.	External
functions	A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Function[]
inputs	A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.	Input[]
jobStorageAccount	The properties that are associated with an Azure Storage account with MSI	JobStorageAccount
jobType	Describes the type of the job. Valid modes are Cloud and 'Edge'.	'Cloud' 'Edge'
outputErrorPolicy	Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).	'Drop' 'Stop'
outputs	A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.	Output[]
outputStartMode	This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time.	'CustomTime' 'JobStartTime' 'LastOutputEventTime'
outputStartTime	Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.	string
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
transformation	Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Transformation

StreamInputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusStreamInputDataSource. Set to 'Microsoft.Devices/IotHubs' for type IoTHubStreamInputDataSource. Set to 'Microsoft.EventGrid/EventSubscriptions' for type EventGridStreamInputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2StreamInputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubStreamInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobStreamInputDataSource. Set to 'Raw' for type RawStreamInputDataSource.	'GatewayMessageBus' 'Microsoft.Devices/IotHubs' 'Microsoft.EventGrid/EventSubscriptions' 'Microsoft.EventHub/EventHub' 'Microsoft.ServiceBus/EventHub' 'Microsoft.Storage/Blob' 'Raw' (required)

StreamInputProperties

Name	Description	Value
datasource	Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests.	StreamInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Stream' (required)

TrackedResourceTags

Name	Description	Value

Transformation

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a transformation. Required on PUT (CreateOrReplace) requests.	TransformationProperties

TransformationProperties

Name	Description	Value
query	Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests.	string
streamingUnits	Specifies the number of streaming units that the streaming job uses.	int
validStreamingUnits	Specifies the valid streaming units a streaming job can scale to.	int[]

Quickstart templates

The following quickstart templates deploy this resource type.

Template

Description

Create a Standard Stream Analytics Job

This template creates a Standard Stream Analytics Job. For more information, Azure Stream Analytics is a real-time analytics and complex event-processing engine that is designed to analyze and process high volumes of fast streaming data from multiple sources simultaneously. Patterns and relationships can be identified in information extracted from a number of input sources including devices, sensors, clickstreams, social media feeds, and applications. These patterns can be used to trigger actions and initiate workflows such creating alerts, feeding information to a reporting tool, or storing transformed data for later use. Also, Stream Analytics is available on Azure IoT Edge runtime, and supports the same exact language or syntax as cloud.

Terraform (AzAPI provider) resource definition

The streamingjobs resource type can be deployed with operations that target:

• Resource groups

For a list of changed properties in each API version, see change log.

Resource format

To create a Microsoft.StreamAnalytics/streamingjobs resource, add the following Terraform to your template.

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
          ]
        }
      }
    }
  })
}

StreamInputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.Devices/IotHubs, use:

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

For Microsoft.EventGrid/EventSubscriptions, use:

{
  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"
}

For Microsoft.EventHub/EventHub, use:

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

For Microsoft.ServiceBus/EventHub, use:

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

For Microsoft.Storage/Blob, use:

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

For Raw, use:

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

InputProperties objects

Set the type property to specify the type of object.

For Reference, use:

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

For Stream, use:

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

FunctionProperties objects

Set the type property to specify the type of object.

For Aggregate, use:

{
  type = "Aggregate"
}

For Scalar, use:

{
  type = "Scalar"
}

Serialization objects

Set the type property to specify the type of object.

For Avro, use:

{
  properties = ?
  type = "Avro"
}

For Csv, use:

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

For CustomClr, use:

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

For Delta, use:

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

For Json, use:

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

For Parquet, use:

{
  properties = ?
  type = "Parquet"
}

ReferenceInputDataSource objects

Set the type property to specify the type of object.

For File, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  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"
}

For Raw, use:

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

FunctionBinding objects

Set the type property to specify the type of object.

For Microsoft.MachineLearning/WebService, use:

{
  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"
}

For Microsoft.MachineLearningServices, use:

{
  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"
}

For Microsoft.StreamAnalytics/CLRUdf, use:

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

For Microsoft.StreamAnalytics/JavascriptUdf, use:

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

OutputDataSource objects

Set the type property to specify the type of object.

For GatewayMessageBus, use:

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

For Microsoft.AzureFunction, use:

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

For Microsoft.DBForPostgreSQL/servers/databases, use:

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

For Microsoft.DataLake/Accounts, use:

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

For Microsoft.EventHub/EventHub, use:

{
  properties = {
    authenticationMode = "string"
    eventHubName = "string"
    partitionCount = int
    partitionKey = "string"
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }
  type = "Microsoft.EventHub/EventHub"
}

For Microsoft.Kusto/clusters/databases, use:

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

For Microsoft.ServiceBus/EventHub, use:

{
  properties = {
    authenticationMode = "string"
    eventHubName = "string"
    partitionCount = int
    partitionKey = "string"
    propertyColumns = [
      "string"
    ]
    serviceBusNamespace = "string"
    sharedAccessPolicyKey = "string"
    sharedAccessPolicyName = "string"
  }
  type = "Microsoft.ServiceBus/EventHub"
}

For Microsoft.ServiceBus/Queue, use:

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

For Microsoft.ServiceBus/Topic, use:

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

For Microsoft.Sql/Server/DataWarehouse, use:

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

For Microsoft.Sql/Server/Database, use:

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

For Microsoft.Storage/Blob, use:

{
  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"
}

For Microsoft.Storage/DocumentDB, use:

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

For Microsoft.Storage/Table, use:

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

For PowerBI, use:

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

For Raw, use:

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

Property values

AggregateFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Aggregate' (required)

AvroSerialization

Name	Description	Value
properties	The properties that are associated with the Avro serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Avro' (required)

AzureDataExplorerOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Explorer output. Required on PUT (CreateOrReplace) requests.	AzureDataExplorerOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Kusto/clusters/databases' (required)

AzureDataExplorerOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
cluster	The name of the Azure Data Explorer cluster. Required on PUT (CreateOrReplace) requests.	string
database	The name of the Azure Data Explorer database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

AzureDataLakeStoreOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Data Lake Store output. Required on PUT (CreateOrReplace) requests.	AzureDataLakeStoreOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DataLake/Accounts' (required)

AzureDataLakeStoreOutputDataSourceProperties

Name	Description	Value
accountName	The name of the Azure Data Lake Store account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dateFormat	The date format. Wherever {date} appears in filePathPrefix, the value of this property is used as the date format instead.	string
filePathPrefix	The location of the file to which the output should be written to. Required on PUT (CreateOrReplace) requests.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
tenantId	The tenant id of the user used to obtain the refresh token. Required on PUT (CreateOrReplace) requests.	string
timeFormat	The time format. Wherever {time} appears in filePathPrefix, the value of this property is used as the time format instead.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

AzureFunctionOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Azure Function output. Required on PUT (CreateOrReplace) requests.	AzureFunctionOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.AzureFunction' (required)

AzureFunctionOutputDataSourceProperties

Name	Description	Value
apiKey	If you want to use an Azure Function from another subscription, you can do so by providing the key to access your function.	string
functionAppName	The name of your Azure Functions app.	string
functionName	The name of the function in your Azure Functions app.	string
maxBatchCount	A property that lets you specify the maximum number of events in each batch that's sent to Azure Functions. The default value is 100.	int
maxBatchSize	A property that lets you set the maximum size for each output batch that's sent to your Azure function. The input unit is in bytes. By default, this value is 262,144 bytes (256 KB).	int

AzureMachineLearningServiceFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning web service.	AzureMachineLearningServiceFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearningServices' (required)

AzureMachineLearningServiceFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning web service.	string
inputRequestName	Label for the input request object.	string
inputs	The inputs for the Azure Machine Learning web service endpoint.	AzureMachineLearningServiceInputColumn[]
numberOfParallelRequests	The number of parallel requests that will be sent per partition of your job to the machine learning service. Default is 1.	int
outputResponseName	Label for the output request object.	string
outputs	A list of outputs from the Azure Machine Learning web service endpoint execution.	AzureMachineLearningServiceOutputColumn[]

AzureMachineLearningServiceInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningServiceOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column.	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the output column.	string

AzureMachineLearningStudioFunctionBinding

Name	Description	Value
properties	The binding properties associated with an Azure Machine learning Studio.	AzureMachineLearningStudioFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.MachineLearning/WebService' (required)

AzureMachineLearningStudioFunctionBindingProperties

Name	Description	Value
apiKey	The API key used to authenticate with Request-Response endpoint.	string
batchSize	Number between 1 and 10000 describing maximum number of rows for every Azure ML RRS execute request. Default is 1000.	int
endpoint	The Request-Response execute endpoint of the Azure Machine Learning Studio. Find out more here: /azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs	string
inputs	The inputs for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputs
outputs	A list of outputs from the Azure Machine Learning Studio endpoint execution.	AzureMachineLearningStudioOutputColumn[]

AzureMachineLearningStudioInputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the input column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
mapTo	The zero based index of the function parameter this input maps to.	int
name	The name of the input column.	string

AzureMachineLearningStudioInputs

Name	Description	Value
columnNames	A list of input columns for the Azure Machine Learning Studio endpoint.	AzureMachineLearningStudioInputColumn[]
name	The name of the input. This is the name provided while authoring the endpoint.	string

AzureMachineLearningStudioOutputColumn

Name	Description	Value
dataType	The (Azure Machine Learning supported) data type of the output column. A list of valid Azure Machine Learning data types are described at https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .	string
name	The name of the output column.	string

AzureSqlDatabaseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure SQL database output. Required on PUT (CreateOrReplace) requests.	AzureSqlDatabaseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlDatabaseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxBatchCount	Max Batch count for write to Sql database, the default value is 10,000. Optional on PUT requests.	int
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureSqlReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with SQL DB input containing reference data. Required on PUT (CreateOrReplace) requests.	AzureSqlReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/Database' (required)

AzureSqlReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	This element is associated with the datasource element. This is the name of the database that output will be written to.	string
deltaSnapshotQuery	This element is associated with the datasource element. This query is used to fetch incremental changes from the SQL database. To use this option, we recommend using temporal tables in Azure SQL Database.	string
fullSnapshotQuery	This element is associated with the datasource element. This query is used to fetch data from the sql database.	string
password	This element is associated with the datasource element. This is the password that will be used to connect to the SQL Database instance.	string Constraints: Sensitive value. Pass in as a secure parameter.
refreshRate	This element is associated with the datasource element. This indicates how frequently the data will be fetched from the database. It is of DateTime format.	string
refreshType	Indicates the type of data refresh option.	'RefreshPeriodicallyWithDelta' 'RefreshPeriodicallyWithFull' 'Static'
server	This element is associated with the datasource element. This is the name of the server that contains the database that will be written to.	string
user	This element is associated with the datasource element. This is the user name that will be used to connect to the SQL Database instance.	string

AzureSynapseOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Synapse output. Required on PUT (CreateOrReplace) requests.	AzureSynapseOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Sql/Server/DataWarehouse' (required)

AzureSynapseOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

AzureTableOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Azure Table output. Required on PUT (CreateOrReplace) requests.	AzureTableOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Table' (required)

AzureTableOutputDataSourceProperties

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
batchSize	The number of rows to write to the Azure Table at a time.	int
columnsToRemove	If specified, each item in the array is the name of a column to remove (if present) from output event entities.	string[]
partitionKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the partition key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
rowKey	This element indicates the name of a column from the SELECT statement in the query that will be used as the row key for the Azure Table. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Azure Table. Required on PUT (CreateOrReplace) requests.	string

BlobOutputDataSource

Name	Description	Value
properties	The properties that are associated with a blob output. Required on PUT (CreateOrReplace) requests.	BlobOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobPathPrefix	Blob path prefix.	string
blobWriteMode	Blob write mode.	'Append' 'Once'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing reference data. Required on PUT (CreateOrReplace) requests.	BlobReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobReferenceInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
blobName	The name of the blob input.	string
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
deltaPathPattern	The path pattern of the delta snapshot.	string
deltaSnapshotRefreshRate	The interval that the user generates a delta snapshot of this reference blob input data source.	string
fullSnapshotRefreshRate	The refresh interval of the blob input data source.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 256.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

BlobStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a blob input containing stream data. Required on PUT (CreateOrReplace) requests.	BlobStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/Blob' (required)

BlobStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
container	The name of a container within the associated Storage account. This container contains either the blob(s) to be read from or written to. Required on PUT (CreateOrReplace) requests.	string
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
sourcePartitionCount	The partition count of the blob input data source. Range 1 - 1024.	int
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ClusterInfo

Name	Description	Value
id	The resource id of cluster.	string

Compression

Name	Description	Value
type	Indicates the type of compression that the input uses. Required on PUT (CreateOrReplace) requests.	'Deflate' 'GZip' 'None' (required)

CSharpFunctionBinding

Name	Description	Value
properties	The binding properties associated with a CSharp function.	CSharpFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/CLRUdf' (required)

CSharpFunctionBindingProperties

Name	Description	Value
class	The Csharp code containing a single function definition.	string
dllPath	The Csharp code containing a single function definition.	string
method	The Csharp code containing a single function definition.	string
updateMode	Refresh modes for Stream Analytics functions.	'Refreshable' 'Static'

CsvSerialization

Name	Description	Value
properties	The properties that are associated with the CSV serialization type. Required on PUT (CreateOrReplace) requests.	CsvSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Csv' (required)

CsvSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
fieldDelimiter	Specifies the delimiter that will be used to separate comma-separated value (CSV) records. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a list of supported values. Required on PUT (CreateOrReplace) requests.	string

CustomClrSerialization

Name	Description	Value
properties	The properties that are associated with the CustomClr serialization type. Required on PUT (CreateOrReplace) requests.	CustomClrSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'CustomClr' (required)

CustomClrSerializationProperties

Name	Description	Value
serializationClassName	The serialization class name.	string
serializationDllPath	The serialization library path.	string

DeltaSerialization

Name	Description	Value
properties	The properties that are associated with the Delta Lake serialization type. Required on PUT (CreateOrReplace) requests.	DeltaSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Delta' (required)

DeltaSerializationProperties

Name	Description	Value
deltaTablePath	Specifies the path of the Delta Lake table that the output will be written to.	string (required)
partitionColumns	Specifies the names of the columns for which the Delta Lake table will be partitioned. We are only supporting 1 partition column, but keeping it as an array for extensibility.	string[]

DocumentDbOutputDataSource

Name	Description	Value
properties	The properties that are associated with a DocumentDB output. Required on PUT (CreateOrReplace) requests.	DocumentDbOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.Storage/DocumentDB' (required)

DocumentDbOutputDataSourceProperties

Name	Description	Value
accountId	The DocumentDB account name or ID. Required on PUT (CreateOrReplace) requests.	string
accountKey	The account key for the DocumentDB account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
collectionNamePattern	The collection name pattern for the collections to be used. The collection name format can be constructed using the optional {partition} token, where partitions start from 0. See the DocumentDB section of /rest/api/streamanalytics/stream-analytics-output for more information. Required on PUT (CreateOrReplace) requests.	string
database	The name of the DocumentDB database. Required on PUT (CreateOrReplace) requests.	string
documentId	The name of the field in output events used to specify the primary key which insert or update operations are based on.	string
partitionKey	The name of the field in output events used to specify the key for partitioning output across collections. If 'collectionNamePattern' contains the {partition} token, this property is required to be specified.	string

EventGridStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an event grid input containing stream data.	EventGridStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventGrid/EventSubscriptions' (required)

EventGridStreamInputDataSourceProperties

Name	Description	Value
eventTypes	List of Event Types that are supported by the Event Grid adapter.	string[]
schema	Indicates the Event Grid schema type.	'CloudEventSchema' 'EventGridEventSchema'
storageAccounts	A list of one or more Azure Storage accounts. Required on PUT (CreateOrReplace) requests.	StorageAccount[]
subscriber	Subscribers for the Event Grid. Currently only EventHub Subscriber is supported.	EventHubV2StreamInputDataSource

EventHubOutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
partitionKey	The key/column that is used to determine to which partition to send event data.	string
propertyColumns	The properties associated with this Event Hub output.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/EventHub' (required)

EventHubStreamInputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
consumerGroupName	The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.	string
eventHubName	The name of the Event Hub. Required on PUT (CreateOrReplace) requests.	string
partitionCount	The partition count of the event hub data source. Range 1 - 256.	int
prefetchCount	The number of messages that the message receiver can simultaneously request.	int
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string

EventHubV2OutputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub output. Required on PUT (CreateOrReplace) requests.	EventHubOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.EventHub/EventHub' (required)

EventHubV2StreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an Event Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	EventHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	string (required)

External

Name	Description	Value
container	The UserCustomCode container.	string
path	The UserCustomCode path.	string
refreshConfiguration	The refresh parameters for any/all updatable user defined functions present in the job config.	RefreshConfiguration
storageAccount	The properties that are associated with an Azure Storage account	StorageAccount

FileReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a file input containing reference data. Required on PUT (CreateOrReplace) requests.	FileReferenceInputDataSourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'File' (required)

FileReferenceInputDataSourceProperties

Name	Description	Value
path	The path of the file.	string

Function

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a function.	FunctionProperties

FunctionBinding

Name	Description	Value
type	Set to 'Microsoft.MachineLearning/WebService' for type AzureMachineLearningStudioFunctionBinding. Set to 'Microsoft.MachineLearningServices' for type AzureMachineLearningServiceFunctionBinding. Set to 'Microsoft.StreamAnalytics/CLRUdf' for type CSharpFunctionBinding. Set to 'Microsoft.StreamAnalytics/JavascriptUdf' for type JavaScriptFunctionBinding.	'Microsoft.MachineLearning/WebService' 'Microsoft.MachineLearningServices' 'Microsoft.StreamAnalytics/CLRUdf' 'Microsoft.StreamAnalytics/JavascriptUdf' (required)

FunctionConfiguration

Name	Description	Value
binding	The physical binding of the function. For example, in the Azure Machine Learning web service’s case, this describes the endpoint.	FunctionBinding
inputs		FunctionInput[]
output	Describes the output of a function.	FunctionOutput

FunctionInput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function input parameter. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string
isConfigurationParameter	A flag indicating if the parameter is a configuration parameter. True if this input parameter is expected to be a constant. Default is false.	bool

FunctionOutput

Name	Description	Value
dataType	The (Azure Stream Analytics supported) data type of the function output. A list of valid Azure Stream Analytics data types are described at https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx	string

FunctionProperties

Name	Description	Value
properties		FunctionConfiguration
type	Set to 'Aggregate' for type AggregateFunctionProperties. Set to 'Scalar' for type ScalarFunctionProperties.	'Aggregate' 'Scalar' (required)

GatewayMessageBusOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Gateway Message Bus output. Required on PUT (CreateOrReplace) requests.	GatewayMessageBusOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusOutputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

GatewayMessageBusStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a gateway message bus input containing stream data.	GatewayMessageBusStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'GatewayMessageBus' (required)

GatewayMessageBusStreamInputDataSourceProperties

Name	Description	Value
topic	The name of the Service Bus topic.	string

Identity

Name	Description	Value
type	The type of identity, can be SystemAssigned or UserAssigned.	string
userAssignedIdentities	The user assigned identities associated with the streaming job resource.	IdentityUserAssignedIdentities

IdentityUserAssignedIdentities

Name	Description	Value

Input

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an input. Required on PUT (CreateOrReplace) requests.	InputProperties

InputProperties

Name	Description	Value
compression	Describes how input data is compressed	Compression
partitionKey	partitionKey Describes a key in the input data which is used for partitioning the input data	string
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
type	Set to 'Reference' for type ReferenceInputProperties. Set to 'Stream' for type StreamInputProperties.	'Reference' 'Stream' (required)
watermarkSettings	Settings which determine whether to read watermark events.	InputWatermarkProperties

InputWatermarkProperties

Name	Description	Value
watermarkMode	The input watermark mode.	'None' 'ReadWatermark'

IoTHubStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with an IoT Hub input containing stream data. Required on PUT (CreateOrReplace) requests.	IoTHubStreamInputDataSourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Microsoft.Devices/IotHubs' (required)

IoTHubStreamInputDataSourceProperties

Name	Description	Value
consumerGroupName	The name of an IoT Hub Consumer Group that should be used to read events from the IoT Hub. If not specified, the input uses the Iot Hub’s default consumer group.	string
endpoint	The IoT Hub endpoint to connect to (ie. messages/events, messages/operationsMonitoringEvents, etc.).	string
iotHubNamespace	The name or the URI of the IoT Hub. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the IoT Hub. This policy must contain at least the Service connect permission. Required on PUT (CreateOrReplace) requests.	string

JavaScriptFunctionBinding

Name	Description	Value
properties	The binding properties associated with a JavaScript function.	JavaScriptFunctionBindingProperties
type	Indicates the function binding type.	'Microsoft.StreamAnalytics/JavascriptUdf' (required)

JavaScriptFunctionBindingProperties

Name	Description	Value
script	The JavaScript code containing a single function definition. For example: 'function (x, y) { return x + y; }'	string

JobStorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

JsonSerialization

Name	Description	Value
properties	The properties that are associated with the JSON serialization type. Required on PUT (CreateOrReplace) requests.	JsonSerializationProperties
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Json' (required)

JsonSerializationProperties

Name	Description	Value
encoding	Specifies the encoding of the incoming data in the case of input and the encoding of outgoing data in the case of output. Required on PUT (CreateOrReplace) requests.	'UTF8'
format	This property only applies to JSON serialization of outputs only. It is not applicable to inputs. This property specifies the format of the JSON the output will be written in. The currently supported values are 'lineSeparated' indicating the output will be formatted by having each JSON object separated by a new line and 'array' indicating the output will be formatted as an array of JSON objects. Default value is 'lineSeparated' if left null.	'Array' 'LineSeparated'

Microsoft.StreamAnalytics/streamingjobs

Name	Description	Value
identity	Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs.	Identity
location	The geo-location where the resource lives	string
name	The resource name	string (required)
properties	The properties that are associated with a streaming job. Required on PUT (CreateOrReplace) requests.	StreamingJobProperties
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
tags	Resource tags	Dictionary of tag names and values.
type	The resource type	"Microsoft.StreamAnalytics/streamingjobs@2021-10-01-preview"

Output

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with an output. Required on PUT (CreateOrReplace) requests.	OutputProperties

OutputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusOutputDataSource. Set to 'Microsoft.AzureFunction' for type AzureFunctionOutputDataSource. Set to 'Microsoft.DBForPostgreSQL/servers/databases' for type PostgreSQLOutputDataSource. Set to 'Microsoft.DataLake/Accounts' for type AzureDataLakeStoreOutputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2OutputDataSource. Set to 'Microsoft.Kusto/clusters/databases' for type AzureDataExplorerOutputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubOutputDataSource. Set to 'Microsoft.ServiceBus/Queue' for type ServiceBusQueueOutputDataSource. Set to 'Microsoft.ServiceBus/Topic' for type ServiceBusTopicOutputDataSource. Set to 'Microsoft.Sql/Server/DataWarehouse' for type AzureSynapseOutputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlDatabaseOutputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobOutputDataSource. Set to 'Microsoft.Storage/DocumentDB' for type DocumentDbOutputDataSource. Set to 'Microsoft.Storage/Table' for type AzureTableOutputDataSource. Set to 'PowerBI' for type PowerBIOutputDataSource. Set to 'Raw' for type RawOutputDatasource.	'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' (required)

OutputProperties

Name	Description	Value
datasource	Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests.	OutputDataSource
serialization	Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests.	Serialization
sizeWindow	The size window to constrain a Stream Analytics output to.	int
timeWindow	The time frame for filtering Stream Analytics job outputs.	string
watermarkSettings	Settings which determine whether to send watermarks to downstream.	OutputWatermarkProperties

OutputWatermarkProperties

Name	Description	Value
maxWatermarkDifferenceAcrossPartitions	Describes the maximal delta between the fastest and slowest partitions, so the out of order window that catches all necessary events in downstream jobs is well defined.	string
watermarkMode	The output watermark mode.	'None' 'SendCurrentPartitionWatermark' 'SendLowestWatermarkAcrossPartitions'

ParquetSerialization

Name	Description	Value
properties	The properties that are associated with the Parquet serialization type. Required on PUT (CreateOrReplace) requests.	any
type	Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests.	'Parquet' (required)

PostgreSQLOutputDataSource

Name	Description	Value
properties	The properties that are associated with a PostgreSQL output data source. Required on PUT (CreateOrReplace) requests.	PostgreSQLOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.DBForPostgreSQL/servers/databases' (required)

PostgreSQLOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
database	The name of the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
maxWriterCount	Max Writer count, currently only 1(single writer) and 0(based on query partition) are available. Optional on PUT requests.	int
password	The password that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
server	The name of the SQL server containing the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
table	The name of the table in the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string
user	The user name that will be used to connect to the Azure SQL database. Required on PUT (CreateOrReplace) requests.	string

PowerBIOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Power BI output. Required on PUT (CreateOrReplace) requests.	PowerBIOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'PowerBI' (required)

PowerBIOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
dataset	The name of the Power BI dataset. Required on PUT (CreateOrReplace) requests.	string
groupId	The ID of the Power BI group.	string
groupName	The name of the Power BI group. Use this property to help remember which specific Power BI group id was used.	string
refreshToken	A refresh token that can be used to obtain a valid access token that can then be used to authenticate with the data source. A valid refresh token is currently only obtainable via the Azure Portal. It is recommended to put a dummy string value here when creating the data source and then going to the Azure Portal to authenticate the data source which will update this property with a valid refresh token. Required on PUT (CreateOrReplace) requests.	string
table	The name of the Power BI table under the specified dataset. Required on PUT (CreateOrReplace) requests.	string
tokenUserDisplayName	The user display name of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string
tokenUserPrincipalName	The user principal name (UPN) of the user that was used to obtain the refresh token. Use this property to help remember which user was used to obtain the refresh token.	string

RawInputDatasourceProperties

Name	Description	Value
payload	The JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string
payloadUri	The SAS URL to a blob containing the JSON serialized content of the input data. Either payload or payloadUri must be set, but not both.	string

RawOutputDatasource

Name	Description	Value
properties	The properties that are associated with a raw output. Required on PUT (CreateOrReplace) requests.	RawOutputDatasourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawOutputDatasourceProperties

Name	Description	Value
payloadUri	The SAS URL to a blob where the output should be written. If this property is not set, output data will be written into a temporary storage, and a SAS URL to that temporary storage will be included in the result.	string

RawReferenceInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input containing reference data. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

RawStreamInputDataSource

Name	Description	Value
properties	The properties that are associated with a raw input. Required on PUT (CreateOrReplace) requests.	RawInputDatasourceProperties
type	Indicates the type of input data source containing stream data. Required on PUT (CreateOrReplace) requests.	'Raw' (required)

ReferenceInputDataSource

Name	Description	Value
type	Set to 'File' for type FileReferenceInputDataSource. Set to 'Microsoft.Sql/Server/Database' for type AzureSqlReferenceInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobReferenceInputDataSource. Set to 'Raw' for type RawReferenceInputDataSource.	'File' 'Microsoft.Sql/Server/Database' 'Microsoft.Storage/Blob' 'Raw' (required)

ReferenceInputProperties

Name	Description	Value
datasource	Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests.	ReferenceInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Reference' (required)

RefreshConfiguration

Name	Description	Value
dateFormat	The date format. Wherever {date} appears in pathPattern, the value of this property is used as the date format instead.	string
pathPattern	The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job. See /rest/api/streamanalytics/stream-analytics-input or /rest/api/streamanalytics/stream-analytics-output for a more detailed explanation and example.	string
refreshInterval	The refresh interval.	string
refreshType	This property indicates which data refresh option to use, Blocking or Nonblocking.	'Blocking' 'Nonblocking'
timeFormat	The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead.	string

ScalarFunctionProperties

Name	Description	Value
type	Indicates the type of function.	'Scalar' (required)

Serialization

Name	Description	Value
type	Set to 'Avro' for type AvroSerialization. Set to 'Csv' for type CsvSerialization. Set to 'CustomClr' for type CustomClrSerialization. Set to 'Delta' for type DeltaSerialization. Set to 'Json' for type JsonSerialization. Set to 'Parquet' for type ParquetSerialization.	'Avro' 'Csv' 'CustomClr' 'Delta' 'Json' 'Parquet' (required)

ServiceBusQueueOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Queue output. Required on PUT (CreateOrReplace) requests.	ServiceBusQueueOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Queue' (required)

ServiceBusQueueOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
queueName	The name of the Service Bus Queue. Required on PUT (CreateOrReplace) requests.	string
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Queue. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	any

ServiceBusTopicOutputDataSource

Name	Description	Value
properties	The properties that are associated with a Service Bus Topic output. Required on PUT (CreateOrReplace) requests.	ServiceBusTopicOutputDataSourceProperties
type	Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests.	'Microsoft.ServiceBus/Topic' (required)

ServiceBusTopicOutputDataSourceProperties

Name	Description	Value
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'
propertyColumns	A string array of the names of output columns to be attached to Service Bus messages as custom properties.	string[]
serviceBusNamespace	The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
sharedAccessPolicyKey	The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
sharedAccessPolicyName	The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.	string
systemPropertyColumns	The system properties associated with the Service Bus Topic Output. The following system properties are supported: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.	ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns
topicName	The name of the Service Bus Topic. Required on PUT (CreateOrReplace) requests.	string

ServiceBusTopicOutputDataSourcePropertiesSystemPropertyColumns

Name	Description	Value

Sku

Name	Description	Value
capacity	The capacity of the SKU.	int
name	The name of the SKU. Required on PUT (CreateOrReplace) requests.	'Standard'

StorageAccount

Name	Description	Value
accountKey	The account key for the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string Constraints: Sensitive value. Pass in as a secure parameter.
accountName	The name of the Azure Storage account. Required on PUT (CreateOrReplace) requests.	string
authenticationMode	Authentication Mode.	'ConnectionString' 'Msi' 'UserToken'

StreamingJobProperties

Name	Description	Value
cluster	The cluster which streaming jobs will run on.	ClusterInfo
compatibilityLevel	Controls certain runtime behaviors of the streaming job.	'1.0' '1.2'
contentStoragePolicy	Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. .	'JobStorageAccount' 'SystemAccount'
dataLocale	The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to 'en-US' if none specified.	string
eventsLateArrivalMaxDelayInSeconds	The maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.	int
eventsOutOfOrderMaxDelayInSeconds	The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.	int
eventsOutOfOrderPolicy	Indicates the policy to apply to events that arrive out of order in the input event stream.	'Adjust' 'Drop'
externals	The storage account where the custom code artifacts are located.	External
functions	A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Function[]
inputs	A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.	Input[]
jobStorageAccount	The properties that are associated with an Azure Storage account with MSI	JobStorageAccount
jobType	Describes the type of the job. Valid modes are Cloud and 'Edge'.	'Cloud' 'Edge'
outputErrorPolicy	Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).	'Drop' 'Stop'
outputs	A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.	Output[]
outputStartMode	This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time.	'CustomTime' 'JobStartTime' 'LastOutputEventTime'
outputStartTime	Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.	string
sku	Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.	Sku
transformation	Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.	Transformation

StreamInputDataSource

Name	Description	Value
type	Set to 'GatewayMessageBus' for type GatewayMessageBusStreamInputDataSource. Set to 'Microsoft.Devices/IotHubs' for type IoTHubStreamInputDataSource. Set to 'Microsoft.EventGrid/EventSubscriptions' for type EventGridStreamInputDataSource. Set to 'Microsoft.EventHub/EventHub' for type EventHubV2StreamInputDataSource. Set to 'Microsoft.ServiceBus/EventHub' for type EventHubStreamInputDataSource. Set to 'Microsoft.Storage/Blob' for type BlobStreamInputDataSource. Set to 'Raw' for type RawStreamInputDataSource.	'GatewayMessageBus' 'Microsoft.Devices/IotHubs' 'Microsoft.EventGrid/EventSubscriptions' 'Microsoft.EventHub/EventHub' 'Microsoft.ServiceBus/EventHub' 'Microsoft.Storage/Blob' 'Raw' (required)

StreamInputProperties

Name	Description	Value
datasource	Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests.	StreamInputDataSource
type	Indicates whether the input is a source of reference data or stream data. Required on PUT (CreateOrReplace) requests.	'Stream' (required)

TrackedResourceTags

Name	Description	Value

Transformation

Name	Description	Value
name	Resource name	string
properties	The properties that are associated with a transformation. Required on PUT (CreateOrReplace) requests.	TransformationProperties

TransformationProperties

Name	Description	Value
query	Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests.	string
streamingUnits	Specifies the number of streaming units that the streaming job uses.	int
validStreamingUnits	Specifies the valid streaming units a streaming job can scale to.	int[]