你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
az stream-analytics function
注意
此参考是 Azure CLI(版本 2.15.0 或更高版本)的流分析扩展的一部分。 该扩展将在首次运行 az stream-analytics 函数 命令时自动安装。 详细了解扩展。
使用流分析管理函数。
命令
名称 | 说明 | 类型 | 状态 |
---|---|---|---|
az stream-analytics function create |
创建函数或替换现有流式处理作业下已有的函数。 |
扩展 | GA |
az stream-analytics function delete |
从流式处理作业中删除函数。 |
扩展 | GA |
az stream-analytics function inspect |
根据指定的参数检索函数的默认定义。 |
扩展 | GA |
az stream-analytics function list |
列出指定流式处理作业下的所有函数。 |
扩展 | GA |
az stream-analytics function show |
获取有关指定函数的详细信息。 |
扩展 | GA |
az stream-analytics function test |
测试为函数提供的信息是否有效。 这可以包括测试函数后面的基础 Web 服务的连接,或确保提供的函数代码语法正确。 |
扩展 | GA |
az stream-analytics function update |
更新现有流式处理作业下的现有函数。 这可用于部分更新(即更新一两个属性)函数,而不会影响作业或函数定义的其余部分。 |
扩展 | GA |
az stream-analytics function wait |
将 CLI 置于等待状态,直到满足流分析函数的条件。 |
扩展 | GA |
az stream-analytics function create
创建函数或替换现有流式处理作业下已有的函数。
az stream-analytics function create --function-name
--job-name
--resource-group
[--if-match]
[--if-none-match]
[--properties]
示例
创建 JavaScript 函数
az stream-analytics function create --properties "{\"type\":\"Scalar\",\"properties\":{\"binding\":{\"type\":\"Microsoft.StreamAnalytics/JavascriptUdf\",\"properties\":{\"script\":\"function (x, y) { return x + y; }\"}},\"inputs\":[{\"dataType\":\"Any\"}],\"output\":{\"dataType\":\"Any\"}}}" --function-name "function8197" --job-name "sj8653" --resource-group "sjrg1637"
创建 Azure ML 函数
az stream-analytics function create --properties "{\"type\":\"Scalar\",\"properties\":{\"binding\":{\"type\":\"Microsoft.MachineLearning/WebService\",\"properties\":{\"apiKey\":\"someApiKey==\",\"batchSize\":1000,\"endpoint\":\"someAzureMLEndpointURL\",\"inputs\":{\"name\":\"input1\",\"columnNames\":[{\"name\":\"tweet\",\"dataType\":\"string\",\"mapTo\":0}]},\"outputs\":[{\"name\":\"Sentiment\",\"dataType\":\"string\"}]}},\"inputs\":[{\"dataType\":\"nvarchar(max)\"}],\"output\":{\"dataType\":\"nvarchar(max)\"}}}" --function-name "function588" --job-name "sj9093" --resource-group "sjrg7"
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
函数的 ETag。 省略此值以始终覆盖当前函数。 指定最后一次看到的 ETag 值,以防止意外覆盖并发更改。
设置为“*”以允许创建新函数,但要防止更新现有函数。 其他值将导致 412 预条件失败响应。
与函数关联的属性。 预期值:json-string/json-file/@json-file。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function delete
从流式处理作业中删除函数。
az stream-analytics function delete --function-name
--job-name
--resource-group
[--yes]
示例
删除函数
az stream-analytics function delete --name "function8197" --job-name "sj8653" --resource-group "sjrg1637"
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
不提示确认。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function inspect
根据指定的参数检索函数的默认定义。
az stream-analytics function inspect --function-name
--job-name
--resource-group
[--ml-properties]
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
检索Azure 机器学习 Web 服务函数的默认函数定义所需的参数。
用法:--ml-properties execute-endpoint=XX
execute-endpoint:Azure 机器学习 Web 服务的 Request-Response 执行终结点。 在此处了解详细信息: https://docs.microsoft.com/en-us/azure/stream-analytics/machine-learning-udf
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function list
列出指定流式处理作业下的所有函数。
az stream-analytics function list --job-name
--resource-group
[--select]
示例
列出流式处理作业中的所有函数
az stream-analytics function list --job-name "sj8653" --resource-group "sjrg1637"
必需参数
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
$select OData 查询参数。 这是要包含在响应中的结构属性的逗号分隔列表,或“”以包含所有属性。默认情况下,除诊断之外,所有属性都会返回。目前仅接受“”作为有效值。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function show
获取有关指定函数的详细信息。
az stream-analytics function show --function-name
--job-name
--resource-group
示例
获取 JavaScript 函数
az stream-analytics function show --name "function8197" --job-name "sj8653" --resource-group "sjrg1637"
获取 Azure ML 函数
az stream-analytics function show --name "function588" --job-name "sj9093" --resource-group "sjrg7"
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function test
测试为函数提供的信息是否有效。 这可以包括测试函数后面的基础 Web 服务的连接,或确保提供的函数代码语法正确。
az stream-analytics function test --function-name
--job-name
--resource-group
[--no-wait]
[--properties]
示例
测试 JavaScript 函数的连接
az stream-analytics function test --function-name "function8197" --job-name "sj8653" --resource-group "sjrg1637"
测试 Azure ML 函数的连接
az stream-analytics function test --function-name "function588" --job-name "sj9093" --resource-group "sjrg7"
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
不等待长时间运行的操作完成。
与函数关联的属性。 预期值:json-string/json-file/@json-file。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function update
更新现有流式处理作业下的现有函数。 这可用于部分更新(即更新一两个属性)函数,而不会影响作业或函数定义的其余部分。
az stream-analytics function update --function-name
--job-name
--resource-group
[--if-match]
[--properties]
示例
更新 JavaScript 函数
az stream-analytics function update --properties "{\"type\":\"Scalar\",\"properties\":{\"binding\":{\"type\":\"Microsoft.StreamAnalytics/JavascriptUdf\",\"properties\":{\"script\":\"function (a, b) { return a * b; }\"}}}}" --function-name "function8197" --job-name "sj8653" --resource-group "sjrg1637"
更新 Azure ML 函数
az stream-analytics function update --properties "{\"type\":\"Scalar\",\"properties\":{\"binding\":{\"type\":\"Microsoft.MachineLearning/WebService\",\"properties\":{\"batchSize\":5000}}}}" --function-name "function588" --job-name "sj9093" --resource-group "sjrg7"
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
函数的 ETag。 省略此值以始终覆盖当前函数。 指定最后一次看到的 ETag 值,以防止意外覆盖并发更改。
与函数关联的属性。 预期值:json-string/json-file/@json-file。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。
az stream-analytics function wait
将 CLI 置于等待状态,直到满足流分析函数的条件。
az stream-analytics function wait --function-name
--job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
示例
暂停执行下一行 CLI 脚本,直到成功创建流分析函数。
az stream-analytics function wait --name "function588" --job-name "sj9093" --resource-group "sjrg7" --created
必需参数
函数的名称。
流式处理作业的名称。
资源组的名称。 可以使用 az configure --defaults group=<name>
配置默认组。
可选参数
等待在“Succeeded”中使用“provisioningState”创建。
等待条件满足自定义 JMESPath 查询。 例如 provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running']。
等到删除为止。
等待资源存在。
轮询间隔(以秒为单位)。
最大等待(以秒为单位)。
等到 provisioningState 更新为“Succeeded”。
全局参数
提高日志记录详细程度以显示所有调试日志。
显示此帮助消息并退出。
只显示错误,取消显示警告。
输出格式。
JMESPath 查询字符串。 有关更多信息和示例,请参阅 http://jmespath.org/。
订阅的名称或 ID。 可以使用 az account set -s NAME_OR_ID
配置默认订阅。
提高日志记录详细程度。 使用 --debug 获取完整的调试日志。