Skip to content

[Stream Analytics] Fix s360 for 2021 preview version #18305

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 17 commits into from
Mar 25, 2022
Merged

[Stream Analytics] Fix s360 for 2021 preview version #18305

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
1bcc20d
Add blockchain to latest profile
markcowl Aug 22, 2019
7b46097
Add additional types
markcowl Aug 22, 2019
962ac62
add azure function
Feb 3, 2022
6ce661c
add authenticationMode to blob input, AzFunction and DW ex files
Feb 8, 2022
419cd52
update api version in 2021 preview ex files
Feb 8, 2022
131c976
fix api version
Feb 8, 2022
abb2281
fix password
Feb 15, 2022
6a2d393
try to run model validation again
Feb 15, 2022
fe63aa2
update pe to readonly
Feb 17, 2022
4c86724
Merge branch 'Azure:main' into main
roslynlu Feb 17, 2022
e8568d6
Merge branch 'main' of https://github.com/roslynlu/azure-rest-api-spe…
Feb 17, 2022
80cca55
2021 preview features
Mar 17, 2022
1e917c0
Merge branch 'main' of https://github.com/Azure/azure-rest-api-specs …
Mar 17, 2022
aecb2a7
fix validation errors
Mar 21, 2022
ea3dafa
more fixes
Mar 21, 2022
d50b725
add aggregate func, which should be GA
Mar 25, 2022
61c8451
rename new refreshType object
Mar 25, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion ...source-manager/Microsoft.StreamAnalytics/preview/2020-03-01-preview/privateEndpoints.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -298,7 +298,8 @@
},
"requestMessage": {
"description": "A message passed to the owner of the remote resource with this connection request. Restricted to 140 chars.",
"type": "string"
"type": "string",
"readOnly": true
},
"privateLinkServiceConnectionState": {
"description": "A collection of read-only information about the state of the connection to the private remote resource.",
Expand Down
4 changes: 3 additions & 1 deletion ...t.StreamAnalytics/preview/2021-10-01-preview/examples/Function_Create_AzureMLService.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,9 @@
}
],
"batchSize": 1000,
"numberOfParallelRequests": 1
"numberOfParallelRequests": 1,
"inputRequestName": "Inputs",
"outputResponseName": "Results"
}
}
}
Expand Down
3 changes: 2 additions & 1 deletion ...Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Function_Create_CSharp.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,8 @@
"properties": {
"dllPath": "ASAEdgeApplication2_CodeBehind",
"class": "ASAEdgeUDFDemo.Class1",
"method": "SquareFunction"
"method": "SquareFunction",
"updateMode": "Static"
}
}
}
Expand Down
122 changes: 122 additions & 0 deletions ...Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Input_Create_EventGrid.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,122 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg3467",
"jobName": "sj9742",
"inputName": "input7970",
"input": {
"properties": {
"type": "Stream",
"datasource": {
"type": "Microsoft.EventGrid/EventSubscriptions",
"properties": {
"subscriber": {
"type": "Microsoft.EventHub/EventHub",
"properties": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
"consumerGroupName": "sdkconsumergroup",
"eventHubName": "sdkeventhub",
"partitionCount": 16,
"authenticationMode": "Msi"
}
},
"schema": "CloudEventSchema",
"storageAccounts": [
{
"authenticationMode": "Msi",
"accountName": "myaccount",
"accountKey": "myaccountkey"
}
],
"eventTypes": [
"Microsoft.Storage.BlobCreated"
]
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
"name": "input7970",
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
"properties": {
"type": "Stream",
"datasource": {
"type": "Microsoft.EventGrid/EventSubscriptions",
"properties": {
"subscriber": {
"type": "Microsoft.EventHub/EventHub",
"properties": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"consumerGroupName": "sdkconsumergroup",
"eventHubName": "sdkeventhub",
"partitionCount": 16,
"authenticationMode": "Msi"
}
},
"schema": "CloudEventSchema",
"storageAccounts": [
{
"authenticationMode": "Msi",
"accountName": "myaccount"
}
],
"eventTypes": [
"Microsoft.Storage.BlobCreated"
]
}
}
}
}
},
"200": {
"headers": {
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
"name": "input7970",
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
"properties": {
"type": "Stream",
"datasource": {
"type": "Microsoft.EventGrid/EventSubscriptions",
"properties": {
"subscriber": {
"type": "Microsoft.EventHub/EventHub",
"properties": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"consumerGroupName": "sdkconsumergroup",
"eventHubName": "sdkeventhub",
"partitionCount": 16,
"authenticationMode": "Msi"
}
},
"schema": "CloudEventSchema",
"storageAccounts": [
{
"authenticationMode": "Msi",
"accountName": "myaccount"
}
],
"eventTypes": [
"Microsoft.Storage.BlobCreated"
]
}
}
}
}
}
}
}
60 changes: 60 additions & 0 deletions ...t.StreamAnalytics/preview/2021-10-01-preview/examples/Input_Create_GatewayMessageBus.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,60 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg3467",
"jobName": "sj9742",
"inputName": "input7970",
"input": {
"properties": {
"type": "Stream",
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
"name": "input7970",
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
"properties": {
"type": "Stream",
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
},
"200": {
"headers": {
"ETag": "bd8009b3-8165-4bd3-aad2-29a2b378dd14"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
"name": "input7970",
"type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
"properties": {
"type": "Stream",
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
}
}
}
7 changes: 6 additions & 1 deletion ....StreamAnalytics/preview/2021-10-01-preview/examples/Input_Create_Reference_Blob_CSV.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,12 @@
"container": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
"timeFormat": "HH",
"blobName": "myblobinput",
"deltaPathPattern": "/testBlob/{date}/delta/{time}/",
"sourcePartitionCount": 16,
"fullSnapshotRefreshRate": "16:14:30",
"deltaSnapshotRefreshRate": "16:14:30"
}
},
"serialization": {
Expand Down
3 changes: 3 additions & 0 deletions ...treamAnalytics/preview/2021-10-01-preview/examples/Input_Create_Stream_EventHub_JSON.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@
"properties": {
"encoding": "UTF8"
}
},
"watermarkSettings": {
"watermarkMode": "ReadWatermark"
}
}
}
Expand Down
4 changes: 3 additions & 1 deletion ...Microsoft.StreamAnalytics/preview/2021-10-01-preview/examples/Output_Create_Blob_CSV.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,9 @@
"container": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
"timeFormat": "HH",
"blobPathPrefix": "my/path",
"blobWriteMode": "Once"
}
},
"serialization": {
Expand Down
3 changes: 2 additions & 1 deletion ...soft.StreamAnalytics/preview/2021-10-01-preview/examples/Output_Create_DataWarehouse.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,8 @@
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin",
"password": "password123"
"password": "password123",
"authenticationMode": "Msi"
}
}
}
Expand Down
3 changes: 2 additions & 1 deletion ...crosoft.StreamAnalytics/preview/2021-10-01-preview/examples/Output_Create_DocumentDB.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,8 @@
"database": "db01",
"collectionNamePattern": "collection",
"partitionKey": "key",
"documentId": "documentId"
"documentId": "documentId",
"authenticationMode": "Msi"
}
}
}
Expand Down
4 changes: 4 additions & 0 deletions ...soft.StreamAnalytics/preview/2021-10-01-preview/examples/Output_Create_EventHub_JSON.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,10 @@
"encoding": "UTF8",
"format": "Array"
}
},
"watermarkSettings": {
"watermarkMode": "SendCurrentPartitionWatermark",
"maxWatermarkDifferenceAcrossPartitions": "16:14:30"
}
}
}
Expand Down
57 changes: 57 additions & 0 deletions ....StreamAnalytics/preview/2021-10-01-preview/examples/Output_Create_GatewayMessageBus.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg7983",
"jobName": "sj2331",
"outputName": "output3022",
"output": {
"properties": {
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "ccf8b864-259e-43c5-a628-ba10858b2c07"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022",
"name": "output3022",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
},
"200": {
"headers": {
"ETag": "ccf8b864-259e-43c5-a628-ba10858b2c07"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022",
"name": "output3022",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
}
}
}
Loading