Skip to content

Commit

Permalink
[Stream Analytics] Add Azure Function and Blob Input MSI (Azure#17697)
Browse files Browse the repository at this point in the history
* 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>
  • Loading branch information
2 people authored and FredericHeem committed Mar 7, 2022
1 parent 269c7f3 commit 7d23094
Show file tree
Hide file tree
Showing 108 changed files with 904 additions and 123 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,71 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "azureFunction1",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.AzureFunction",
"properties": {
"functionAppName": "functionappforasaautomation",
"functionName": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
},
"body": {
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
"name": "azureFunction1",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.AzureFunction",
"properties": {
"functionAppName": "functionappforasaautomation",
"functionName": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
},
"etag": "7b912929-346d-432e-9495-6972dbd63179"
}
}
},
"200": {
"headers": {
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
},
"body": {
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
"name": "azureFunction1",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.AzureFunction",
"properties": {
"functionAppName": "functionappforasaautomation",
"functionName": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
},
"etag": "7b912929-346d-432e-9495-6972dbd63179"
}
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,69 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "dwOutput",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.Sql/Server/DataWarehouse",
"properties": {
"table": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin",
"password": "password123"
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
"name": "dwOutput",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Sql/Server/DataWarehouse",
"properties": {
"table": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin",
"password": "password123"
}
}
}
}
},
"200": {
"headers": {
"ETag": "731a47c6-ff67-4439-bde6-a2a3da4c1ecf"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
"name": "dwOutput",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Sql/Server/DataWarehouse",
"properties": {
"table": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin",
"password": "password123"
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,16 @@
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "output958"
"outputName": "azureFunction1"
},
"responses": {
"200": {
"headers": {
"ETag": "2409b6d1-c99c-405b-9a14-ea7833637038"
},
"body": {
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/kunAll0908npm2/outputs/AzureFunction1",
"name": "AzureFunction1",
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
"name": "azureFunction1",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,16 @@
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "output958"
"outputName": "dwOutput"
},
"responses": {
"200": {
"headers": {
"ETag": "2409b6d1-c99c-405b-9a14-ea7833637038"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/kunAll0908npm2/outputs/SynapseformerlySQLDW1",
"name": "SynapseformerlySQLDW1",
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
"name": "dwOutput",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "azureFunction1",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.AzureFunction",
"properties": {
"functionName": "differentFunctionName"
}
}
}
}
},
"responses": {
"200": {
"headers": {
"ETag": "f489d6f3-fcd5-4bcb-b642-81e987ee16d6"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
"name": "azureFunction1",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.AzureFunction",
"properties": {
"functionAppName": "functionappforasaautomation",
"functionName": "differentFunctionName",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "dwOutput",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.Sql/Server/Database",
"properties": {
"table": "differentTable"
}
}
}
}
},
"responses": {
"200": {
"headers": {
"ETag": "f489d6f3-fcd5-4bcb-b642-81e987ee16d6"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
"name": "dwOutput",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Sql/Server/DataWarehouse",
"properties": {
"table": "differentTable",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin"
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -743,6 +743,10 @@
"timeFormat": {
"type": "string",
"description": "The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead."
},
"authenticationMode": {
"$ref": "../../common/v1/definitions.json#/definitions/AuthenticationMode",
"description": "Authentication Mode. "
}
}
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,12 @@
"Create a DocumentDB output": {
"$ref": "./examples/Output_Create_DocumentDB.json"
},
"Create an Azure Data Warehouse output": {
"$ref": "./examples/Output_Create_DataWarehouse.json"
},
"Create an Azure Function output": {
"$ref": "./examples/Output_Create_AzureFunction.json"
},
"Create an Event Hub output with JSON serialization": {
"$ref": "./examples/Output_Create_EventHub_JSON.json"
},
Expand Down Expand Up @@ -163,6 +169,12 @@
"Update a DocumentDB output": {
"$ref": "./examples/Output_Update_DocumentDB.json"
},
"Update an Azure Data Warehouse output": {
"$ref": "./examples/Output_Update_DataWarehouse.json"
},
"Update an Azure Function output": {
"$ref": "./examples/Output_Update_AzureFunction.json"
},
"Update an Event Hub output with JSON serialization": {
"$ref": "./examples/Output_Update_EventHub.json"
},
Expand Down Expand Up @@ -580,13 +592,7 @@
{
"$ref": "./inputs.json#/definitions/BlobDataSourceProperties"
}
],
"properties": {
"authenticationMode": {
"$ref": "../../common/v1/definitions.json#/definitions/AuthenticationMode",
"description": "Authentication Mode."
}
}
]
},
"AzureTableOutputDataSource": {
"description": "Describes an Azure Table output data source.",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg7",
"jobName": "sj9093",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2017-04-01-preview",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg1637",
"jobName": "sj8653",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg1637",
"jobName": "sj8653",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg7",
"jobName": "sj9093",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg1637",
"jobName": "sj8653",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg1637",
"jobName": "sj8653"
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg7",
"jobName": "sj9093",
Expand Down
Loading

0 comments on commit 7d23094

Please sign in to comment.