New-AzStreamAnalyticsFunction
Creates a function or replaces an already existing function under an existing streaming job.
Syntax
Default (Default)
New-AzStreamAnalyticsFunction
-JobName <String>
-Name <String>
-ResourceGroupName <String>
-File <String>
[-SubscriptionId <String>]
[-IfMatch <String>]
[-IfNoneMatch <String>]
[-DefaultProfile <PSObject>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
Description
Creates a function or replaces an already existing function under an existing streaming job.
Examples
Example 1: Create a Stream Analytics function
New-AzStreamAnalyticsFunction -ResourceGroupName azure-rg-test -JobName sajob-02-pwsh -Name function-01 -File .\test\template-json\Function_JavascriptUdf.json
Name Type ETag
---- ---- ----
function-01 Microsoft.StreamAnalytics/streamingjobs/functions 7bbd6ccd-c7a4-4910-b2ae-a3eae19d9b18
This command creates a function from the file Function_JavascriptUdf.json.
(below is an example for "Function_JavascriptUdf.json")
{
"properties": {
"type": "Scalar",
"properties": {
"inputs": [
{
"dataType": "any"
},
{
"dataType": "any"
}
],
"output": {
"dataType": "any"
},
"binding": {
"type": "Microsoft.StreamAnalytics/JavascriptUdf",
"properties": {
"script": "// Sample UDF which returns sum of two values.\nfunction main(arg3, arg4) {\n return arg1 + arg2;\n}"
}
}
}
}
}
Example 2: Create a Stream Analytics function
New-AzStreamAnalyticsFunction -ResourceGroupName azure-rg-test -JobName sajob-02-pwsh -Name function-01 -File .\test\template-json\MachineLearningServices.json
Name Type ETag
---- ---- ----
function-01 Microsoft.StreamAnalytics/streamingjobs/functions 7bbd6ccd-c7a4-4910-b2ae-a3eae19d9b18
This command creates a function from the file MachineLearningServices.json.
(below is an example for "MachineLearningServices.json")
{
"properties": {
"type": "Scalar",
"properties": {
"inputs": [
{
"dataType": "record"
}
],
"output": {
"dataType": "bigint"
},
"binding": {
"type": "Microsoft.MachineLearningServices",
"properties": {
"endpoint": "http://xxxxxxxxxxxxxxxxxxx.eastus.azurecontainer.io/score",
"inputs": [
{
"name": "data",
"dataType": "object",
"mapTo": 0
}
],
"outputs": [
{
"name": "output",
"dataType": "int64",
"mapTo": 0
}
],
"batchSize": 10000,
"numberOfParallelRequests": 1
}
}
}
}
}
Parameters
-Confirm
Prompts you for confirmation before running the cmdlet.
Parameter properties
Type: SwitchParameter
Default value: None Supports wildcards: False DontShow: False Aliases: cf
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-DefaultProfile
The credentials, account, tenant, and subscription used for communication with Azure.
Parameter properties
Type: PSObject
Default value: None Supports wildcards: False DontShow: False Aliases: AzureRMContext, AzureCredential
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-File
The name of the resource group.
The name is case insensitive.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: True Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-IfMatch
The ETag of the function.
Omit this value to always overwrite the current function.
Specify the last-seen ETag value to prevent accidentally overwriting concurrent changes.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-IfNoneMatch
Set to '*' to allow a new function to be created, but to prevent updating an existing function.
Other values will result in a 412 Pre-condition Failed response.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-JobName
The name of the streaming job.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: True Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-Name
The name of the function.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False Aliases: FunctionName
Parameter sets
(All)
Position: Named Mandatory: True Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-ResourceGroupName
The name of the resource group.
The name is case insensitive.
Parameter properties
Type: String
Default value: None Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: True Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-SubscriptionId
The ID of the target subscription.
Parameter properties
Type: String
Default value: (Get-AzContext).Subscription.Id Supports wildcards: False DontShow: False
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
-WhatIf
Shows what would happen if the cmdlet runs.
The cmdlet is not run.
Parameter properties
Type: SwitchParameter
Default value: None Supports wildcards: False DontShow: False Aliases: wi
Parameter sets
(All)
Position: Named Mandatory: False Value from pipeline: False Value from pipeline by property name: False Value from remaining arguments: False
CommonParameters
This cmdlet supports the common parameters: -Debug, -ErrorAction, -ErrorVariable,
-InformationAction, -InformationVariable, -OutBuffer, -OutVariable, -PipelineVariable,
-ProgressAction, -Verbose, -WarningAction, and -WarningVariable. For more information, see
about_CommonParameters .
Outputs