你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
New-AzStreamAnalyticsInput
创建输入或替换现有流式处理作业下已有的输入。
语法
New-AzStreamAnalyticsInput
-JobName <String>
-Name <String>
-ResourceGroupName <String>
-File <String>
[-SubscriptionId <String>]
[-IfMatch <String>]
[-IfNoneMatch <String>]
[-DefaultProfile <PSObject>]
[-WhatIf]
[-Confirm]
[<CommonParameters>]
说明
创建输入或替换现有流式处理作业下已有的输入。
示例
示例 1:使用文件定义创建作业输入
New-AzStreamAnalyticsInput -ResourceGroupName azure-rg-test -JobName sajob-02-pwsh -Name input-01 -File .\test\template-json\EventHub.json
Name Type ETag
---- ---- ----
input-01 Microsoft.StreamAnalytics/streamingjobs/inputs 6c9f5122-44b9-45bf-81c9-5349a9dd8851
此命令从文件EventHub.json创建输入。
(下面是“EventHub.json”的示例){ “properties”: { “type”: “Stream”, “serialization”: { “type”: “Json”, “properties”: { “encoding”: “UTF8” } }, “compression”: { “type”: “None” }, “datasource”: { “type”: “Microsoft.EventHub/EventHub”, “properties”: { “serviceBusNamespace”: “xxxxxxxxxxxxxxxxx”, “sharedAccessPolicyName”: “xxxxxxxxxxxxxxxxxxx”, “sharedAccessPolicyKey”: “xxxx”, “authenticationMode”: “ConnectionString”, “eventHubName”: “xxxx”, “consumerGroupName”: “xxxx” } }
示例 2:使用文件定义创建作业输入
New-AzStreamAnalyticsInput -ResourceGroupName azure-rg-test -JobName sajob-02-pwsh -Name input-01 -File .\test\template-json\IotHub.json
Name Type ETag
---- ---- ----
input-01 Microsoft.StreamAnalytics/streamingjobs/inputs 6c9f5122-44b9-45bf-81c9-5349a9dd8851
此命令从文件IotHub.json创建输入。
(下面是“IotHub.json”的示例){ “properties”: { “type”: “Stream”, “serialization”: { “type”: “Json”, “properties”: { “encoding”: “UTF8” } }, “compression”: { “type”: “None” }, “partitionKey”: “”, “datasource”: { “type”: “Microsoft.Devices/IotHubs”, “properties”: { “iotHubNamespace”: “xxxxxxxxxxxxxx”, “sharedAccessPolicyName”: “xxxxxxxxxxxxxx”, “sharedAccessPolicyKey”: “xxxxx”, “consumerGroupName”: “$Default”, “endpoint”: “messages/events” } } } }
参数
-Confirm
提示你在运行 cmdlet 之前进行确认。
类型: | SwitchParameter |
别名: | cf |
Position: | Named |
默认值: | None |
必需: | False |
接受管道输入: | False |
接受通配符: | False |
-DefaultProfile
用于与 Azure 通信的凭据、帐户、租户和订阅。
类型: | PSObject |
别名: | AzureRMContext, AzureCredential |
Position: | Named |
默认值: | None |
必需: | False |
接受管道输入: | False |
接受通配符: | False |
-File
流式处理作业的名称。
类型: | String |
Position: | Named |
默认值: | None |
必需: | True |
接受管道输入: | False |
接受通配符: | False |
-IfMatch
输入的 ETag。 省略此值以始终覆盖当前输入。 指定最后一次看到的 ETag 值,以防止意外覆盖并发更改。
类型: | String |
Position: | Named |
默认值: | None |
必需: | False |
接受管道输入: | False |
接受通配符: | False |
-IfNoneMatch
设置为“*”以允许创建新输入,但要防止更新现有输入。 其他值将导致 412 预条件失败响应。
类型: | String |
Position: | Named |
默认值: | None |
必需: | False |
接受管道输入: | False |
接受通配符: | False |
-JobName
流式处理作业的名称。
类型: | String |
Position: | Named |
默认值: | None |
必需: | True |
接受管道输入: | False |
接受通配符: | False |
-Name
输入的名称。
类型: | String |
别名: | InputName |
Position: | Named |
默认值: | None |
必需: | True |
接受管道输入: | False |
接受通配符: | False |
-ResourceGroupName
资源组的名称。 此名称不区分大小写。
类型: | String |
Position: | Named |
默认值: | None |
必需: | True |
接受管道输入: | False |
接受通配符: | False |
-SubscriptionId
目标订阅的 ID。
类型: | String |
Position: | Named |
默认值: | (Get-AzContext).Subscription.Id |
必需: | False |
接受管道输入: | False |
接受通配符: | False |
-WhatIf
显示运行该 cmdlet 时会发生什么情况。 cmdlet 未运行。
类型: | SwitchParameter |
别名: | wi |
Position: | Named |
默认值: | None |
必需: | False |
接受管道输入: | False |
接受通配符: | False |