你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

az stream-analytics input

注意

此参考是 Azure CLI（版本 2.15.0 或更高版本）的流分析扩展的一部分。 该扩展将在首次运行 az stream-analytics input 命令时自动安装。 详细了解扩展。

使用流分析管理输入。

命令

名称	说明	类型	状态
az stream-analytics input create	创建输入或替换现有流式处理作业下已有的输入。	扩展	GA
az stream-analytics input delete	从流式处理作业中删除输入。	扩展	GA
az stream-analytics input list	列出指定流式处理作业下的所有输入。	扩展	GA
az stream-analytics input show	获取有关指定输入的详细信息。	扩展	GA
az stream-analytics input test	测试输入的数据源是否可供 Azure 流分析服务访问和使用。	扩展	GA
az stream-analytics input update	更新现有流式处理作业下的现有输入。 这可用于部分更新（即更新一两个属性）输入，而不会影响作业或输入定义的其余部分。	扩展	GA
az stream-analytics input wait	将 CLI 置于等待状态，直到满足流分析输入的条件。	扩展	GA

az stream-analytics input create

创建输入或替换现有流式处理作业下已有的输入。

az stream-analytics input create --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

示例

使用 CSV 序列化创建引用 Blob 输入

az stream-analytics input create --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

使用 JSON 序列化创建流事件中心输入

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"eventHubName\":\"sdkeventhub\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"someSharedAccessPolicyKey==\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

使用 Avro 序列化创建流IoT 中心输入

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"endpoint\":\"messages/events\",\"iotHubNamespace\":\"iothub\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"owner\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

使用 CSV 序列化创建流 Blob 输入

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"sourcePartitionCount\":16,\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--if-match

输入的 ETag。 省略此值以始终覆盖当前输入。 指定最后一次看到的 ETag 值，以防止意外覆盖并发更改。

--if-none-match

设置为“*”以允许创建新输入，但要防止更新现有输入。 其他值将导致 412 预条件失败响应。

--properties

与输入关联的属性。 PUT （CreateOrReplace） 请求时是必需的。 预期值：json-string/json-file/@json-file。

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input delete

从流式处理作业中删除输入。

az stream-analytics input delete --input-name
                                 --job-name
                                 --resource-group
                                 [--yes]

示例

删除输入

az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--yes -y

不提示确认。

默认值: False

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input list

列出指定流式处理作业下的所有输入。

az stream-analytics input list --job-name
                               --resource-group
                               [--select]

示例

列出流式处理作业中的所有输入

az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"

列出流式处理作业中的所有输入，并使用 $select OData 查询参数包括诊断信息

az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"

必需参数

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--select

$select OData 查询参数。 这是要包含在响应中的结构属性的逗号分隔列表，或“”以包含所有属性。默认情况下，除诊断之外，所有属性都会返回。目前仅接受“”作为有效值。

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input show

获取有关指定输入的详细信息。

az stream-analytics input show --input-name
                               --job-name
                               --resource-group

示例

使用 CSV 序列化获取引用 Blob 输入

az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

使用 JSON 序列化获取流事件中心输入

az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

使用 Avro 序列化获取流IoT 中心输入

az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

使用 CSV 序列化获取流 Blob 输入

az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input test

测试输入的数据源是否可供 Azure 流分析服务访问和使用。

az stream-analytics input test --input-name
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

示例

测试输入的连接

az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--no-wait

不等待长时间运行的操作完成。

默认值: False

--properties

与输入关联的属性。 PUT （CreateOrReplace） 请求时是必需的。 预期值：json-string/json-file/@json-file。

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input update

更新现有流式处理作业下的现有输入。 这可用于部分更新（即更新一两个属性）输入，而不会影响作业或输入定义的其余部分。

az stream-analytics input update --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--properties]

示例

更新引用 Blob 输入

az stream-analytics input update --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

更新流事件中心输入

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"differentConsumerGroupName\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

更新流IoT 中心输入

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"endpoint\":\"messages/operationsMonitoringEvents\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

更新流 Blob 输入

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"sourcePartitionCount\":32}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--if-match

输入的 ETag。 省略此值以始终覆盖当前输入。 指定最后一次看到的 ETag 值，以防止意外覆盖并发更改。

--properties

与输入关联的属性。 PUT （CreateOrReplace） 请求时是必需的。 预期值：json-string/json-file/@json-file。

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。

az stream-analytics input wait

将 CLI 置于等待状态，直到满足流分析输入的条件。

az stream-analytics input wait --input-name
                               --job-name
                               --resource-group
                               [--created]
                               [--custom]
                               [--deleted]
                               [--exists]
                               [--interval]
                               [--timeout]
                               [--updated]

示例

暂停执行下一行 CLI 脚本，直到成功创建流分析输入。

az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created

必需参数

--input-name --name -n

输入的名称。

--job-name

流式处理作业的名称。

--resource-group -g

资源组的名称。 可以使用 az configure --defaults group=<name> 配置默认组。

可选参数

--created

等待在“Succeeded”中使用“provisioningState”创建。

默认值: False

--custom

等待条件满足自定义 JMESPath 查询。 例如 provisioningState！='InProgress'， instanceView.statuses[？code=='PowerState/running']。

--deleted

等到删除为止。

默认值: False

--exists

等待资源存在。

默认值: False

--interval

轮询间隔（以秒为单位）。

默认值: 30

--timeout

最大等待（以秒为单位）。

默认值: 3600

--updated

等到 provisioningState 更新为“Succeeded”。

默认值: False

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

--output -o

输出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc

默认值: json

--query

JMESPath 查询字符串。 有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

提高日志记录详细程度。 使用 --debug 获取完整的调试日志。