14
14
15
15
<#
16
16
. SYNOPSIS
17
- Nagative test. Get resources from an non-existing empty group .
17
+ Tests the common usages and scenarios of the cmdlets .
18
18
#>
19
19
function Test-TestStreamingAnalyticsE2E
20
20
{
21
- $resourceGroup = " StreamAnalytics-Default-West-US "
21
+ $resourceGroup = " ASASDK "
22
22
$jobName = " TestJobPS"
23
23
$inputName = " Input"
24
24
$outputName = " Output"
25
25
$transformationName = " transform1"
26
26
$functionName = " scoreTweet"
27
-
28
- # Create Job
27
+ $expectedContainerName = " samples"
28
+ $expectedTableName = " Samples"
29
+ $expectedStreamingUnits = 1
30
+ $expectedBatchSize = 10
31
+
32
+ # Gets should throw when the resource doesn't exist
33
+ Assert-Throws { Get-AzureRmStreamAnalyticsJob - Name $jobName - ResourceGroupName $resourceGroup }
34
+ Assert-Throws { Get-AzureRmStreamAnalyticsInput - Name $inputName - JobName $jobName - ResourceGroupName $resourceGroup }
35
+ Assert-Throws { Get-AzureRmStreamAnalyticsOutput - Name $outputName - JobName $jobName - ResourceGroupName $resourceGroup }
36
+ Assert-Throws { Get-AzureRmStreamAnalyticsTransformation - Name $transformationName - JobName $jobName - ResourceGroupName $resourceGroup }
37
+ Assert-Throws { Get-AzureRmStreamAnalyticsFunction - Name $functionName - JobName $jobName - ResourceGroupName $resourceGroup }
38
+
39
+ # Create Job
29
40
$actual = New-AzureRmStreamAnalyticsJob - File .\Resources\job.json - ResourceGroupName $resourceGroup - Name $jobName - Force
41
+ Assert-AreEqual $jobName $actual.JobName
42
+ Assert-AreEqual " West US" $actual.Location
43
+ Assert-AreEqual " Created" $actual.JobState
44
+ Assert-AreEqual " Succeeded" $actual.ProvisioningState
45
+ Assert-AreEqual $expectedContainerName $actual.Properties.Inputs [0 ].Properties.Datasource.Container
46
+ Assert-AreEqual $expectedTableName $actual.Properties.Outputs [0 ].Datasource.Table
47
+ Assert-AreEqual $expectedStreamingUnits $actual.Properties.Transformation.StreamingUnits
48
+ Assert-AreEqual $expectedBatchSize $actual.Properties.Functions [0 ].Properties.Binding.BatchSize
30
49
$expected = Get-AzureRmStreamAnalyticsJob - Name $jobName - ResourceGroupName $resourceGroup
31
- Assert-AreEqual $expected.Name $actual.Name
50
+ Assert-AreEqual $expected.JobName $actual.JobName
51
+ Assert-AreEqual $expected.Location $actual.Location
52
+ Assert-AreEqual $expected.JobState $actual.JobState
53
+ Assert-AreEqual $expected.ProvisioningState $actual.ProvisioningState
54
+ Assert-AreEqual $expected.Properties.Inputs [0 ].Properties.Datasource.Container $actual.Properties.Inputs [0 ].Properties.Datasource.Container
55
+ Assert-AreEqual $expected.Properties.Outputs [0 ].Properties.Datasource.Table $actual.Properties.Outputs [0 ].Properties.Datasource.Table
56
+ Assert-AreEqual $expected.Properties.Transformation.StreamingUnits $actual.Properties.Transformation.StreamingUnits
57
+ Assert-AreEqual $expected.Properties.Functions [0 ].Properties.Binding.BatchSize $actual.Properties.Functions [0 ].Properties.Binding.BatchSize
32
58
33
59
# Get Job Input
34
60
$actual = Get-AzureRmStreamAnalyticsInput - JobName $jobName - ResourceGroupName $resourceGroup
35
61
Assert-AreEqual $inputName $actual.Name
62
+ Assert-AreEqual $jobName $actual.JobName
63
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
64
+ Assert-AreEqual $expectedContainerName $actual.Properties.Datasource.Container
36
65
37
66
# Get Job Output
38
67
$actual = Get-AzureRmStreamAnalyticsOutput - JobName $jobName - ResourceGroupName $resourceGroup
39
68
Assert-AreEqual $outputName $actual.Name
69
+ Assert-AreEqual $jobName $actual.JobName
70
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
71
+ Assert-AreEqual $expectedTableName $actual.Properties.Datasource.Table
40
72
41
73
# Get Job transformation
42
74
$actual = Get-AzureRmStreamAnalyticsTransformation - JobName $jobName - Name $transformationName - ResourceGroupName $resourceGroup
43
75
Assert-AreEqual $transformationName $actual.Name
76
+ Assert-AreEqual $jobName $actual.JobName
77
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
78
+ Assert-AreEqual $expectedStreamingUnits $actual.Properties.StreamingUnits
44
79
45
80
# Get Job function
46
81
$actual = Get-AzureRmStreamAnalyticsFunction - JobName $jobName - Name $functionName - ResourceGroupName $resourceGroup
47
82
Assert-AreEqual $functionName $actual.Name
83
+ Assert-AreEqual $jobName $actual.JobName
84
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
85
+ Assert-AreEqual $expectedBatchSize $actual.Properties.Binding.BatchSize
48
86
49
87
# New Input (Patch)
50
88
$actual = New-AzureRmStreamAnalyticsInput - File .\Resources\Input.json - JobName $jobName - ResourceGroupName $resourceGroup - Force
51
89
Assert-AreEqual $inputName $actual.Name
90
+ Assert-AreEqual $jobName $actual.JobName
91
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
92
+ Assert-AreEqual $expectedContainerName $actual.Properties.Datasource.Container
52
93
53
94
# Test Input
54
95
$actual = Test-AzureRmStreamAnalyticsInput - JobName $jobName - Name Input - ResourceGroupName $resourceGroup
@@ -58,6 +99,9 @@ function Test-TestStreamingAnalyticsE2E
58
99
# New Output (Patch)
59
100
$actual = New-AzureRmStreamAnalyticsOutput - File .\Resources\Output.json - JobName $jobName - ResourceGroupName $resourceGroup - Force
60
101
Assert-AreEqual $outputName $actual.Name
102
+ Assert-AreEqual $jobName $actual.JobName
103
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
104
+ Assert-AreEqual $expectedTableName $actual.Properties.Datasource.Table
61
105
62
106
# Test Output
63
107
$actual = Test-AzureRmStreamAnalyticsOutput - JobName $jobName - Name $outputName - ResourceGroupName $resourceGroup
@@ -67,10 +111,16 @@ function Test-TestStreamingAnalyticsE2E
67
111
# Create transformation (Patch)
68
112
$actual = New-AzureRmStreamAnalyticsTransformation - File .\Resources\Transformation.json - JobName $jobName - ResourceGroupName $resourceGroup - Force
69
113
Assert-AreEqual $transformationName $actual.Name
114
+ Assert-AreEqual $jobName $actual.JobName
115
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
116
+ Assert-AreEqual $expectedStreamingUnits $actual.Properties.StreamingUnits
70
117
71
118
# New Function (Patch)
72
119
$actual = New-AzureRmStreamAnalyticsFunction - File .\Resources\Function.json - JobName $jobName - ResourceGroupName $resourceGroup - Force
73
120
Assert-AreEqual $functionName $actual.Name
121
+ Assert-AreEqual $jobName $actual.JobName
122
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
123
+ Assert-AreEqual $expectedBatchSize $actual.Properties.Binding.BatchSize
74
124
75
125
# Test Function
76
126
$actual = Test-AzureRmStreamAnalyticsFunction - JobName $jobName - Name $functionName - ResourceGroupName $resourceGroup
@@ -107,6 +157,9 @@ function Test-TestStreamingAnalyticsE2E
107
157
# Get Function Default Definition
108
158
$actual = Get-AzureRmStreamAnalyticsDefaultFunctionDefinition - File .\Resources\RetrieveDefaultFunctionDefinitionRequest.json - Name $functionName - JobName $jobName - ResourceGroupName $resourceGroup
109
159
Assert-AreEqual $functionName $actual.Name
160
+ Assert-AreEqual $jobName $actual.JobName
161
+ Assert-AreEqual $resourceGroup $actual.ResourceGroupName
162
+ Assert-AreEqual 1000 $actual.Properties.Binding.BatchSize
110
163
111
164
# Remove Function
112
165
$actual = Remove-AzureRmStreamAnalyticsFunction - JobName $jobName - Name $functionName - ResourceGroupName $resourceGroup
@@ -123,8 +176,16 @@ function Test-TestStreamingAnalyticsE2E
123
176
$expected = " True"
124
177
Assert-AreEqual $expected $actual
125
178
179
+ # Gets should throw when the resource doesn't exist
180
+ Assert-Throws { Get-AzureRmStreamAnalyticsInput - Name $inputName - JobName $jobName - ResourceGroupName $resourceGroup }
181
+ Assert-Throws { Get-AzureRmStreamAnalyticsOutput - Name $outputName - JobName $jobName - ResourceGroupName $resourceGroup }
182
+ Assert-Throws { Get-AzureRmStreamAnalyticsFunction - Name $functionName - JobName $jobName - ResourceGroupName $resourceGroup }
183
+
126
184
# Remove Job
127
185
$actual = Remove-AzureRmStreamAnalyticsJob - Name $jobName - ResourceGroupName $resourceGroup
128
186
$expected = " True"
129
187
Assert-AreEqual $expected $actual
188
+
189
+ # Gets should throw when the resource doesn't exist
190
+ Assert-Throws { Get-AzureRmStreamAnalyticsJob - Name $jobName - ResourceGroupName $resourceGroup }
130
191
}
0 commit comments