Skip to content

Commit f32aa04

Browse files
roslynluRoslyn Lu
andauthored
[Stream Analytics] Add Azure Function and Blob Input MSI (#17697)
* 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 Co-authored-by: Roslyn Lu <roslu@microsoft.com>
1 parent 9f48fea commit f32aa04

File tree

108 files changed

+904
-123
lines changed

Some content is hidden

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

108 files changed

+904
-123
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,71 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"outputName": "azureFunction1",
8+
"output": {
9+
"properties": {
10+
"datasource": {
11+
"type": "Microsoft.AzureFunction",
12+
"properties": {
13+
"functionAppName": "functionappforasaautomation",
14+
"functionName": "HttpTrigger2",
15+
"apiKey": null,
16+
"maxBatchSize": 256,
17+
"maxBatchCount": 100
18+
}
19+
}
20+
}
21+
}
22+
},
23+
"responses": {
24+
"201": {
25+
"headers": {
26+
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
27+
},
28+
"body": {
29+
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
30+
"name": "azureFunction1",
31+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
32+
"properties": {
33+
"datasource": {
34+
"type": "Microsoft.AzureFunction",
35+
"properties": {
36+
"functionAppName": "functionappforasaautomation",
37+
"functionName": "HttpTrigger2",
38+
"apiKey": null,
39+
"maxBatchSize": 256,
40+
"maxBatchCount": 100
41+
}
42+
},
43+
"etag": "7b912929-346d-432e-9495-6972dbd63179"
44+
}
45+
}
46+
},
47+
"200": {
48+
"headers": {
49+
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
50+
},
51+
"body": {
52+
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
53+
"name": "azureFunction1",
54+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
55+
"properties": {
56+
"datasource": {
57+
"type": "Microsoft.AzureFunction",
58+
"properties": {
59+
"functionAppName": "functionappforasaautomation",
60+
"functionName": "HttpTrigger2",
61+
"apiKey": null,
62+
"maxBatchSize": 256,
63+
"maxBatchCount": 100
64+
}
65+
},
66+
"etag": "7b912929-346d-432e-9495-6972dbd63179"
67+
}
68+
}
69+
}
70+
}
71+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,69 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"outputName": "dwOutput",
8+
"output": {
9+
"properties": {
10+
"datasource": {
11+
"type": "Microsoft.Sql/Server/DataWarehouse",
12+
"properties": {
13+
"table": "test2",
14+
"server": "asatestserver",
15+
"database": "zhayaSQLpool",
16+
"user": "tolladmin",
17+
"password": "password123"
18+
}
19+
}
20+
}
21+
}
22+
},
23+
"responses": {
24+
"201": {
25+
"headers": {
26+
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
27+
},
28+
"body": {
29+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
30+
"name": "dwOutput",
31+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
32+
"properties": {
33+
"datasource": {
34+
"type": "Microsoft.Sql/Server/DataWarehouse",
35+
"properties": {
36+
"table": "test2",
37+
"server": "asatestserver",
38+
"database": "zhayaSQLpool",
39+
"user": "tolladmin",
40+
"password": "password123"
41+
}
42+
}
43+
}
44+
}
45+
},
46+
"200": {
47+
"headers": {
48+
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
49+
},
50+
"body": {
51+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
52+
"name": "dwOutput",
53+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
54+
"properties": {
55+
"datasource": {
56+
"type": "Microsoft.Sql/Server/DataWarehouse",
57+
"properties": {
58+
"table": "test2",
59+
"server": "asatestserver",
60+
"database": "zhayaSQLpool",
61+
"user": "tolladmin",
62+
"password": "password123"
63+
}
64+
}
65+
}
66+
}
67+
}
68+
}
69+
}

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2017-04-01-preview/examples/Output_Get_AzureFunction.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,16 @@
44
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
55
"resourceGroupName": "sjrg",
66
"jobName": "sjName",
7-
"outputName": "output958"
7+
"outputName": "azureFunction1"
88
},
99
"responses": {
1010
"200": {
1111
"headers": {
1212
"ETag": "2409b6d1-c99c-405b-9a14-ea7833637038"
1313
},
1414
"body": {
15-
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/kunAll0908npm2/outputs/AzureFunction1",
16-
"name": "AzureFunction1",
15+
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
16+
"name": "azureFunction1",
1717
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
1818
"properties": {
1919
"datasource": {

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2017-04-01-preview/examples/Output_Get_DataWarehouse.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,16 @@
44
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
55
"resourceGroupName": "sjrg",
66
"jobName": "sjName",
7-
"outputName": "output958"
7+
"outputName": "dwOutput"
88
},
99
"responses": {
1010
"200": {
1111
"headers": {
1212
"ETag": "2409b6d1-c99c-405b-9a14-ea7833637038"
1313
},
1414
"body": {
15-
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/kunAll0908npm2/outputs/SynapseformerlySQLDW1",
16-
"name": "SynapseformerlySQLDW1",
15+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
16+
"name": "dwOutput",
1717
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
1818
"properties": {
1919
"datasource": {
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"outputName": "azureFunction1",
8+
"output": {
9+
"properties": {
10+
"datasource": {
11+
"type": "Microsoft.AzureFunction",
12+
"properties": {
13+
"functionName": "differentFunctionName"
14+
}
15+
}
16+
}
17+
}
18+
},
19+
"responses": {
20+
"200": {
21+
"headers": {
22+
"ETag": "f489d6f3-fcd5-4bcb-b642-81e987ee16d6"
23+
},
24+
"body": {
25+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
26+
"name": "azureFunction1",
27+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
28+
"properties": {
29+
"datasource": {
30+
"type": "Microsoft.AzureFunction",
31+
"properties": {
32+
"functionAppName": "functionappforasaautomation",
33+
"functionName": "differentFunctionName",
34+
"apiKey": null,
35+
"maxBatchSize": 256,
36+
"maxBatchCount": 100
37+
}
38+
}
39+
}
40+
}
41+
}
42+
}
43+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
{
2+
"parameters": {
3+
"api-version": "2017-04-01-preview",
4+
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
5+
"resourceGroupName": "sjrg",
6+
"jobName": "sjName",
7+
"outputName": "dwOutput",
8+
"output": {
9+
"properties": {
10+
"datasource": {
11+
"type": "Microsoft.Sql/Server/Database",
12+
"properties": {
13+
"table": "differentTable"
14+
}
15+
}
16+
}
17+
}
18+
},
19+
"responses": {
20+
"200": {
21+
"headers": {
22+
"ETag": "f489d6f3-fcd5-4bcb-b642-81e987ee16d6"
23+
},
24+
"body": {
25+
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
26+
"name": "dwOutput",
27+
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
28+
"properties": {
29+
"datasource": {
30+
"type": "Microsoft.Sql/Server/DataWarehouse",
31+
"properties": {
32+
"table": "differentTable",
33+
"server": "asatestserver",
34+
"database": "zhayaSQLpool",
35+
"user": "tolladmin"
36+
}
37+
}
38+
}
39+
}
40+
}
41+
}
42+
}

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2017-04-01-preview/inputs.json

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -743,6 +743,10 @@
743743
"timeFormat": {
744744
"type": "string",
745745
"description": "The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead."
746+
},
747+
"authenticationMode": {
748+
"$ref": "../../common/v1/definitions.json#/definitions/AuthenticationMode",
749+
"description": "Authentication Mode. "
746750
}
747751
}
748752
},

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2017-04-01-preview/outputs.json

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,12 @@
5353
"Create a DocumentDB output": {
5454
"$ref": "./examples/Output_Create_DocumentDB.json"
5555
},
56+
"Create an Azure Data Warehouse output": {
57+
"$ref": "./examples/Output_Create_DataWarehouse.json"
58+
},
59+
"Create an Azure Function output": {
60+
"$ref": "./examples/Output_Create_AzureFunction.json"
61+
},
5662
"Create an Event Hub output with JSON serialization": {
5763
"$ref": "./examples/Output_Create_EventHub_JSON.json"
5864
},
@@ -163,6 +169,12 @@
163169
"Update a DocumentDB output": {
164170
"$ref": "./examples/Output_Update_DocumentDB.json"
165171
},
172+
"Update an Azure Data Warehouse output": {
173+
"$ref": "./examples/Output_Update_DataWarehouse.json"
174+
},
175+
"Update an Azure Function output": {
176+
"$ref": "./examples/Output_Update_AzureFunction.json"
177+
},
166178
"Update an Event Hub output with JSON serialization": {
167179
"$ref": "./examples/Output_Update_EventHub.json"
168180
},
@@ -580,13 +592,7 @@
580592
{
581593
"$ref": "./inputs.json#/definitions/BlobDataSourceProperties"
582594
}
583-
],
584-
"properties": {
585-
"authenticationMode": {
586-
"$ref": "../../common/v1/definitions.json#/definitions/AuthenticationMode",
587-
"description": "Authentication Mode."
588-
}
589-
}
595+
]
590596
},
591597
"AzureTableOutputDataSource": {
592598
"description": "Describes an Azure Table output data source.",

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"parameters": {
3-
"api-version": "2020-03-01",
3+
"api-version": "2021-10-01-preview",
44
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
55
"resourceGroupName": "sjrg7",
66
"jobName": "sj9093",

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"parameters": {
3-
"api-version": "2017-04-01-preview",
3+
"api-version": "2021-10-01-preview",
44
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
55
"resourceGroupName": "sjrg",
66
"jobName": "sjName",

0 commit comments

Comments
 (0)