Skip to content

Commit 62a23dc

Browse files
roslynlumarkcowlRoslyn Lu
authored andcommitted
[Stream Analytics] Fix s360 for 2021 preview version (#18305)
* Add blockchain to latest profile * Add additional types * add azure function * add authenticationMode to blob input, AzFunction and DW ex files * update api version in 2021 preview ex files * fix api version * fix password * try to run model validation again * update pe to readonly * 2021 preview features * fix validation errors * more fixes * add aggregate func, which should be GA * rename new refreshType object Co-authored-by: Mark Cowlishaw <markcowl@microsoft.com> Co-authored-by: Roslyn Lu <roslu@microsoft.com>
1 parent f3102d4 commit 62a23dc

20 files changed

+812
-49
lines changed

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2020-03-01-preview/privateEndpoints.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -298,7 +298,8 @@
298298
},
299299
"requestMessage": {
300300
"description": "A message passed to the owner of the remote resource with this connection request. Restricted to 140 chars.",
301-
"type": "string"
301+
"type": "string",
302+
"readOnly": true
302303
},
303304
"privateLinkServiceConnectionState": {
304305
"description": "A collection of read-only information about the state of the connection to the private remote resource.",

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,9 @@
3636
}
3737
],
3838
"batchSize": 1000,
39-
"numberOfParallelRequests": 1
39+
"numberOfParallelRequests": 1,
40+
"inputRequestName": "Inputs",
41+
"outputResponseName": "Results"
4042
}
4143
}
4244
}

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,8 @@
2222
"properties": {
2323
"dllPath": "ASAEdgeApplication2_CodeBehind",
2424
"class": "ASAEdgeUDFDemo.Class1",
25-
"method": "SquareFunction"
25+
"method": "SquareFunction",
26+
"updateMode": "Static"
2627
}
2728
}
2829
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,122 @@
1+
{
2+
"parameters": {
3+
"api-version": "2021-10-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg3467",
6+
"jobName": "sj9742",
7+
"inputName": "input7970",
8+
"input": {
9+
"properties": {
10+
"type": "Stream",
11+
"datasource": {
12+
"type": "Microsoft.EventGrid/EventSubscriptions",
13+
"properties": {
14+
"subscriber": {
15+
"type": "Microsoft.EventHub/EventHub",
16+
"properties": {
17+
"serviceBusNamespace": "sdktest",
18+
"sharedAccessPolicyName": "RootManageSharedAccessKey",
19+
"sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
20+
"consumerGroupName": "sdkconsumergroup",
21+
"eventHubName": "sdkeventhub",
22+
"partitionCount": 16,
23+
"authenticationMode": "Msi"
24+
}
25+
},
26+
"schema": "CloudEventSchema",
27+
"storageAccounts": [
28+
{
29+
"authenticationMode": "Msi",
30+
"accountName": "myaccount",
31+
"accountKey": "myaccountkey"
32+
}
33+
],
34+
"eventTypes": [
35+
"Microsoft.Storage.BlobCreated"
36+
]
37+
}
38+
}
39+
}
40+
}
41+
},
42+
"responses": {
43+
"201": {
44+
"headers": {
45+
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
46+
},
47+
"body": {
48+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
49+
"name": "input7970",
50+
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
51+
"properties": {
52+
"type": "Stream",
53+
"datasource": {
54+
"type": "Microsoft.EventGrid/EventSubscriptions",
55+
"properties": {
56+
"subscriber": {
57+
"type": "Microsoft.EventHub/EventHub",
58+
"properties": {
59+
"serviceBusNamespace": "sdktest",
60+
"sharedAccessPolicyName": "RootManageSharedAccessKey",
61+
"consumerGroupName": "sdkconsumergroup",
62+
"eventHubName": "sdkeventhub",
63+
"partitionCount": 16,
64+
"authenticationMode": "Msi"
65+
}
66+
},
67+
"schema": "CloudEventSchema",
68+
"storageAccounts": [
69+
{
70+
"authenticationMode": "Msi",
71+
"accountName": "myaccount"
72+
}
73+
],
74+
"eventTypes": [
75+
"Microsoft.Storage.BlobCreated"
76+
]
77+
}
78+
}
79+
}
80+
}
81+
},
82+
"200": {
83+
"headers": {
84+
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
85+
},
86+
"body": {
87+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
88+
"name": "input7970",
89+
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
90+
"properties": {
91+
"type": "Stream",
92+
"datasource": {
93+
"type": "Microsoft.EventGrid/EventSubscriptions",
94+
"properties": {
95+
"subscriber": {
96+
"type": "Microsoft.EventHub/EventHub",
97+
"properties": {
98+
"serviceBusNamespace": "sdktest",
99+
"sharedAccessPolicyName": "RootManageSharedAccessKey",
100+
"consumerGroupName": "sdkconsumergroup",
101+
"eventHubName": "sdkeventhub",
102+
"partitionCount": 16,
103+
"authenticationMode": "Msi"
104+
}
105+
},
106+
"schema": "CloudEventSchema",
107+
"storageAccounts": [
108+
{
109+
"authenticationMode": "Msi",
110+
"accountName": "myaccount"
111+
}
112+
],
113+
"eventTypes": [
114+
"Microsoft.Storage.BlobCreated"
115+
]
116+
}
117+
}
118+
}
119+
}
120+
}
121+
}
122+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
{
2+
"parameters": {
3+
"api-version": "2021-10-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg3467",
6+
"jobName": "sj9742",
7+
"inputName": "input7970",
8+
"input": {
9+
"properties": {
10+
"type": "Stream",
11+
"datasource": {
12+
"type": "GatewayMessageBus",
13+
"properties": {
14+
"topic": "EdgeTopic1"
15+
}
16+
}
17+
}
18+
}
19+
},
20+
"responses": {
21+
"201": {
22+
"headers": {
23+
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
24+
},
25+
"body": {
26+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
27+
"name": "input7970",
28+
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
29+
"properties": {
30+
"type": "Stream",
31+
"datasource": {
32+
"type": "GatewayMessageBus",
33+
"properties": {
34+
"topic": "EdgeTopic1"
35+
}
36+
}
37+
}
38+
}
39+
},
40+
"200": {
41+
"headers": {
42+
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
43+
},
44+
"body": {
45+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
46+
"name": "input7970",
47+
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
48+
"properties": {
49+
"type": "Stream",
50+
"datasource": {
51+
"type": "GatewayMessageBus",
52+
"properties": {
53+
"topic": "EdgeTopic1"
54+
}
55+
}
56+
}
57+
}
58+
}
59+
}
60+
}

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,12 @@
2020
"container": "state",
2121
"pathPattern": "{date}/{time}",
2222
"dateFormat": "yyyy/MM/dd",
23-
"timeFormat": "HH"
23+
"timeFormat": "HH",
24+
"blobName": "myblobinput",
25+
"deltaPathPattern": "/testBlob/{date}/delta/{time}/",
26+
"sourcePartitionCount": 16,
27+
"fullSnapshotRefreshRate": "16:14:30",
28+
"deltaSnapshotRefreshRate": "16:14:30"
2429
}
2530
},
2631
"serialization": {

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,9 @@
2323
"properties": {
2424
"encoding": "UTF8"
2525
}
26+
},
27+
"watermarkSettings": {
28+
"watermarkMode": "ReadWatermark"
2629
}
2730
}
2831
}

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,9 @@
1919
"container": "state",
2020
"pathPattern": "{date}/{time}",
2121
"dateFormat": "yyyy/MM/dd",
22-
"timeFormat": "HH"
22+
"timeFormat": "HH",
23+
"blobPathPrefix": "my/path",
24+
"blobWriteMode": "Once"
2325
}
2426
},
2527
"serialization": {

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,8 @@
1414
"server": "asatestserver",
1515
"database": "zhayaSQLpool",
1616
"user": "tolladmin",
17-
"password": "password123"
17+
"password": "password123",
18+
"authenticationMode": "Msi"
1819
}
1920
}
2021
}

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@
1515
"database": "db01",
1616
"collectionNamePattern": "collection",
1717
"partitionKey": "key",
18-
"documentId": "documentId"
18+
"documentId": "documentId",
19+
"authenticationMode": "Msi"
1920
}
2021
}
2122
}

0 commit comments

Comments
 (0)