Skip to content

Commit 4b5b690

Browse files
roslynluRoslyn Lu
roslynlu
and
Roslyn Lu
authored
[Azure Stream Analytics] New 2021 preview version (#16573)
* copy 2017 folder * add userAssignedIdenties * update readme * copy GA version to new preview folder * update Identity * update readme2 * some fixes * missed one * one more * change 2020 to 2021 * hopefully no breaking changes * address comments * add functions * add customClr Co-authored-by: Roslyn Lu <roslu@microsoft.com>
1 parent 4abc028 commit 4b5b690

File tree

93 files changed

+11241
-1
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

93 files changed

+11241
-1
lines changed

‎specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Function_Create_AzureML.json‎

Lines changed: 142 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,142 @@
1+
{
2+
"parameters": {
3+
"api-version": "2020-03-01",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg7",
6+
"jobName": "sj9093",
7+
"functionName": "function588",
8+
"function": {
9+
"properties": {
10+
"type": "Scalar",
11+
"properties": {
12+
"inputs": [
13+
{
14+
"dataType": "nvarchar(max)"
15+
}
16+
],
17+
"output": {
18+
"dataType": "nvarchar(max)"
19+
},
20+
"binding": {
21+
"type": "Microsoft.MachineLearning/WebService",
22+
"properties": {
23+
"endpoint": "someAzureMLEndpointURL",
24+
"apiKey": "someApiKey==",
25+
"inputs": {
26+
"name": "input1",
27+
"columnNames": [
28+
{
29+
"name": "tweet",
30+
"dataType": "string",
31+
"mapTo": 0
32+
}
33+
]
34+
},
35+
"outputs": [
36+
{
37+
"name": "Sentiment",
38+
"dataType": "string"
39+
}
40+
],
41+
"batchSize": 1000
42+
}
43+
}
44+
}
45+
}
46+
}
47+
},
48+
"responses": {
49+
"201": {
50+
"headers": {
51+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
52+
},
53+
"body": {
54+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7/providers/Microsoft.StreamAnalytics/streamingjobs/sj9093/functions/function588",
55+
"name": "function588",
56+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
57+
"properties": {
58+
"type": "Scalar",
59+
"properties": {
60+
"inputs": [
61+
{
62+
"dataType": "nvarchar(max)"
63+
}
64+
],
65+
"output": {
66+
"dataType": "nvarchar(max)"
67+
},
68+
"binding": {
69+
"type": "Microsoft.MachineLearning/WebService",
70+
"properties": {
71+
"endpoint": "someAzureMLEndpointURL",
72+
"inputs": {
73+
"name": "input1",
74+
"columnNames": [
75+
{
76+
"name": "tweet",
77+
"dataType": "string",
78+
"mapTo": 0
79+
}
80+
]
81+
},
82+
"outputs": [
83+
{
84+
"name": "Sentiment",
85+
"dataType": "string"
86+
}
87+
],
88+
"batchSize": 1000
89+
}
90+
}
91+
}
92+
}
93+
}
94+
},
95+
"200": {
96+
"headers": {
97+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
98+
},
99+
"body": {
100+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7/providers/Microsoft.StreamAnalytics/streamingjobs/sj9093/functions/function588",
101+
"name": "function588",
102+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
103+
"properties": {
104+
"type": "Scalar",
105+
"properties": {
106+
"inputs": [
107+
{
108+
"dataType": "nvarchar(max)"
109+
}
110+
],
111+
"output": {
112+
"dataType": "nvarchar(max)"
113+
},
114+
"binding": {
115+
"type": "Microsoft.MachineLearning/WebService",
116+
"properties": {
117+
"endpoint": "someAzureMLEndpointURL",
118+
"inputs": {
119+
"name": "input1",
120+
"columnNames": [
121+
{
122+
"name": "tweet",
123+
"dataType": "string",
124+
"mapTo": 0
125+
}
126+
]
127+
},
128+
"outputs": [
129+
{
130+
"name": "Sentiment",
131+
"dataType": "string"
132+
}
133+
],
134+
"batchSize": 1000
135+
}
136+
}
137+
}
138+
}
139+
}
140+
}
141+
}
142+
}

‎specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Function_Create_AzureMLService.json‎

Lines changed: 138 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,138 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"functionName": "function588",
8+
"function": {
9+
"properties": {
10+
"type": "Scalar",
11+
"properties": {
12+
"inputs": [
13+
{
14+
"dataType": "nvarchar(max)"
15+
}
16+
],
17+
"output": {
18+
"dataType": "nvarchar(max)"
19+
},
20+
"binding": {
21+
"type": "Microsoft.MachineLearningServices",
22+
"properties": {
23+
"endpoint": "someAzureMLEndpointURL",
24+
"apiKey": "someApiKey==",
25+
"inputs": [
26+
{
27+
"name": "data",
28+
"dataType": "array",
29+
"mapTo": 0
30+
}
31+
],
32+
"outputs": [
33+
{
34+
"name": "Sentiment",
35+
"dataType": "string"
36+
}
37+
],
38+
"batchSize": 1000,
39+
"numberOfParallelRequests": 1
40+
}
41+
}
42+
}
43+
}
44+
}
45+
},
46+
"responses": {
47+
"201": {
48+
"headers": {
49+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
50+
},
51+
"body": {
52+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/functions/function588",
53+
"name": "function588",
54+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
55+
"properties": {
56+
"type": "Scalar",
57+
"properties": {
58+
"inputs": [
59+
{
60+
"dataType": "nvarchar(max)"
61+
}
62+
],
63+
"output": {
64+
"dataType": "nvarchar(max)"
65+
},
66+
"binding": {
67+
"type": "Microsoft.MachineLearningServices",
68+
"properties": {
69+
"endpoint": "someAzureMLEndpointURL",
70+
"inputs": [
71+
{
72+
"name": "data",
73+
"dataType": "array",
74+
"mapTo": 0
75+
}
76+
],
77+
"outputs": [
78+
{
79+
"name": "Sentiment",
80+
"dataType": "string"
81+
}
82+
],
83+
"batchSize": 1000,
84+
"numberOfParallelRequests": 1
85+
}
86+
}
87+
}
88+
}
89+
}
90+
},
91+
"200": {
92+
"headers": {
93+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
94+
},
95+
"body": {
96+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/functions/function588",
97+
"name": "function588",
98+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
99+
"properties": {
100+
"type": "Scalar",
101+
"properties": {
102+
"inputs": [
103+
{
104+
"dataType": "nvarchar(max)"
105+
}
106+
],
107+
"output": {
108+
"dataType": "nvarchar(max)"
109+
},
110+
"binding": {
111+
"type": "Microsoft.MachineLearning/WebService",
112+
"properties": {
113+
"endpoint": "someAzureMLEndpointURL",
114+
"inputs": {
115+
"name": "input1",
116+
"columnNames": [
117+
{
118+
"name": "tweet",
119+
"dataType": "string",
120+
"mapTo": 0
121+
}
122+
]
123+
},
124+
"outputs": [
125+
{
126+
"name": "Sentiment",
127+
"dataType": "string"
128+
}
129+
],
130+
"batchSize": 1000
131+
}
132+
}
133+
}
134+
}
135+
}
136+
}
137+
}
138+
}

‎specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Function_Create_CSharp.json‎

Lines changed: 96 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,96 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"functionName": "function588",
8+
"function": {
9+
"properties": {
10+
"type": "Scalar",
11+
"properties": {
12+
"inputs": [
13+
{
14+
"dataType": "nvarchar(max)"
15+
}
16+
],
17+
"output": {
18+
"dataType": "nvarchar(max)"
19+
},
20+
"binding": {
21+
"type": "Microsoft.StreamAnalytics/CLRUdf",
22+
"properties": {
23+
"dllPath": "ASAEdgeApplication2_CodeBehind",
24+
"class": "ASAEdgeUDFDemo.Class1",
25+
"method": "SquareFunction"
26+
}
27+
}
28+
}
29+
}
30+
}
31+
},
32+
"responses": {
33+
"201": {
34+
"headers": {
35+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
36+
},
37+
"body": {
38+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/functions/function588",
39+
"name": "function588",
40+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
41+
"properties": {
42+
"type": "Scalar",
43+
"properties": {
44+
"inputs": [
45+
{
46+
"dataType": "nvarchar(max)"
47+
}
48+
],
49+
"output": {
50+
"dataType": "nvarchar(max)"
51+
},
52+
"binding": {
53+
"type": "Microsoft.StreamAnalytics/CLRUdf",
54+
"properties": {
55+
"dllPath": "ASAEdgeApplication2_CodeBehind",
56+
"class": "ASAEdgeUDFDemo.Class1",
57+
"method": "SquareFunction"
58+
}
59+
}
60+
}
61+
}
62+
}
63+
},
64+
"200": {
65+
"headers": {
66+
"ETag": "dac52a15-66be-4aa7-8a18-20c5409983df"
67+
},
68+
"body": {
69+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/functions/function588",
70+
"name": "function588",
71+
"type": "Microsoft.StreamAnalytics/streamingjobs/functions",
72+
"properties": {
73+
"type": "Scalar",
74+
"properties": {
75+
"inputs": [
76+
{
77+
"dataType": "nvarchar(max)"
78+
}
79+
],
80+
"output": {
81+
"dataType": "nvarchar(max)"
82+
},
83+
"binding": {
84+
"type": "Microsoft.StreamAnalytics/CLRUdf",
85+
"properties": {
86+
"dllPath": "ASAEdgeApplication2_CodeBehind",
87+
"class": "ASAEdgeUDFDemo.Class1",
88+
"method": "SquareFunction"
89+
}
90+
}
91+
}
92+
}
93+
}
94+
}
95+
}
96+
}

0 commit comments

Comments
 (0)