您现在访问的是微软AZURE全球版技术文档网站,若需要访问由世纪互联运营的MICROSOFT AZURE中国区技术文档网站,请访问 https://docs.azure.cn.

az stream-analytics job

备注

此引用是适用于 Azure CLI流分析扩展的一部分,需要 2.3.1 或更高版本。 首次运行 az stream-analytics job 命令时,扩展将自动安装。 详细了解扩展。

用于管理流分析流式处理作业的命令。

命令

az stream-analytics job create

创建流式处理作业或替换现有的流式处理作业。

az stream-analytics job delete

删除流式处理作业。

az stream-analytics job list

列出指定资源组的所有流式处理作业。

az stream-analytics job show

获取有关指定的流式处理作业的详细信息。

az stream-analytics job start

启动流式处理作业。

az stream-analytics job stop

停止正在运行的流式处理作业。

az stream-analytics job update

更新现有流式处理作业。

az stream-analytics job wait

将 CLI 放在等待状态,直到满足流式处理作业的条件。

az stream-analytics job create

创建流式处理作业或替换现有的流式处理作业。

az stream-analytics job create --name
                               --resource-group
                               [--compatibility-level {1.0}]
                               [--data-locale]
                               [--events-late-arrival-max-delay]
                               [--events-outoforder-max-delay]
                               [--events-outoforder-policy {Adjust, Drop}]
                               [--location]
                               [--no-wait]
                               [--output-error-policy {Drop, Stop}]
                               [--sku {Standard}]
                               [--tags]

示例

创建流式处理作业

az stream-analytics job create --resource-group MyResourceGroup --name MyJobName \
--location "West US" --output-error-policy "Drop" --events-outoforder-policy "Drop" \
--events-outoforder-max-delay 5 --events-late-arrival-max-delay 16 --data-locale "en-US"

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--compatibility-level

控制流式处理作业的某些运行时行为。

接受的值: 1.0
默认值: 1.0
--data-locale

流分析作业的数据区域设置。 值应为集 中支持的 .NET 区域性的名称 https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx 。 如果未指定,则默认为"en-US"。

--events-late-arrival-max-delay

可容忍的最大延迟(以秒为单位),其中可能包括迟到事件。 支持的范围为 -1 到 1814399(20.23:59:59 天),-1 用于指定无限期等待。

--events-outoforder-max-delay

可容许的最大延迟(以秒为单位),其中无序事件可重新调整为有序事件。

--events-outoforder-policy

指示要应用于输入事件流中未按顺序到达的事件的策略。

接受的值: Adjust, Drop
--location -l

位置。 az account list-locations 中的值。 可以使用 az configure --defaults location=<location> 配置默认位置。

--no-wait

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

--output-error-policy

指示要应用于到达输出的事件的策略。

接受的值: Drop, Stop
--sku

SKU 的名称。

接受的值: Standard
默认值: Standard
--tags

空格分隔标记:key[=value] [key[=value] ...]。使用""清除现有标记。

az stream-analytics job delete

删除流式处理作业。

az stream-analytics job delete --name
                               --resource-group
                               [--no-wait]

示例

删除流式处理作业

az stream-analytics job delete --resource-group MyResourceGroup --name MyJobName

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--no-wait

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

az stream-analytics job list

列出指定资源组的所有流式处理作业。

az stream-analytics job list [--expand]
                             [--resource-group]

示例

列出当前订阅中所有流式处理作业

az stream-analytics job list

列出资源组的所有流式处理作业

az stream-analytics job list --resource-group MyResourceGroup

列出所有流式处理作业并展开其输入、输出、转换和函数

az stream-analytics job list --resource-group MyResourceGroup --expand

可选参数

--expand

展开流式处理作业的输入、转换、输出和函数。

--resource-group -g

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

az stream-analytics job show

获取有关指定的流式处理作业的详细信息。

az stream-analytics job show --name
                             --resource-group
                             [--expand]

示例

获取流式处理作业

az stream-analytics job show --resource-group MyResourceGroup --name MyJobName

获取流式处理作业并展开其输入、输出、转换和函数

az stream-analytics job show --resource-group MyResourceGroup --name MyJobName --expand

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--expand

展开流式处理作业的输入、转换、输出和函数。

az stream-analytics job start

启动流式处理作业。

az stream-analytics job start --name
                              --resource-group
                              [--no-wait]
                              [--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
                              [--output-start-time]

示例

使用 LastOutputEventTime 输出启动模式启动流式处理作业

az stream-analytics job start --resource-group MyResourceGroup --name MyJobName --output-start-mode LastOutputEventTime

使用 JobStartTime 输出启动模式启动流式处理作业

az stream-analytics job start --resource-group MyResourceGroup --name MyJobName --output-start-mode JobStartTime

使用 CustomTime 输出启动模式启动流式处理作业

az stream-analytics job start --resource-group MyResourceGroup --name MyJobName --output-start-mode CustomTime --output-start-time 2020-01-01T00:00:00Z

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--no-wait

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

--output-start-mode

输出启动模式。

接受的值: CustomTime, JobStartTime, LastOutputEventTime
默认值: JobStartTime
--output-start-time

如果 --output-start-mode 设置为 CustomTime,则 输出开始时间必须具有 值。

az stream-analytics job stop

停止正在运行的流式处理作业。

az stream-analytics job stop --name
                             --resource-group
                             [--no-wait]

示例

停止流式处理作业

az stream-analytics job stop --resource-group MyResourceGroup --name MyJobName

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--no-wait

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

az stream-analytics job update

更新现有流式处理作业。

az stream-analytics job update --name
                               --resource-group
                               [--data-locale]
                               [--events-late-arrival-max-delay]
                               [--events-outoforder-max-delay]
                               [--events-outoforder-policy {Adjust, Drop}]
                               [--output-error-policy {Drop, Stop}]
                               [--tags]

示例

更新流式处理作业

az stream-analytics job update --resource-group MyResourceGroup --name MyJobName \
--events-outoforder-max-delay 21 --events-late-arrival-max-delay 13

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--data-locale

流分析作业的数据区域设置。 值应为集 中支持的 .NET 区域性的名称 https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx

--events-late-arrival-max-delay

可容忍的最大延迟(以秒为单位),其中可能包括迟到事件。 支持的范围为 -1 到 1814399(20.23:59:59 天),-1 用于指定无限期等待。

--events-outoforder-max-delay

可容许的最大延迟(以秒为单位),其中无序事件可重新调整为有序事件。

--events-outoforder-policy

指示要应用于输入事件流中未按顺序到达的事件的策略。

接受的值: Adjust, Drop
--output-error-policy

指示要应用于到达输出的事件的策略。

接受的值: Drop, Stop
--tags

空格分隔标记:key[=value] [key[=value] ...]。使用""清除现有标记。

az stream-analytics job wait

将 CLI 放在等待状态,直到满足流式处理作业的条件。

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

示例

暂停执行下一行 CLI 脚本,直到成功预配流式处理作业。

az stream-analytics job wait --resource-group MyResourceGroup --name MyJobName --created

必需参数

--name -n

流式处理作业的名称。

--resource-group -g

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

可选参数

--created

等到创建时"provisioningState"位于"Succeeded"。

--custom

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

--deleted

等到删除。

--exists

等待资源存在。

--expand

$expand OData 查询参数。 这是要包括在响应中的其他流式处理作业属性的逗号分隔列表,超出此参数不存在时返回的默认集。 默认集是除"inputs"、"transformation"、"outputs"和"functions"外的所有流式处理作业属性。

--interval

轮询间隔(以秒为单位)。

默认值: 30
--timeout

最大等待时间(以秒表示)。

默认值: 3600
--updated

等待,直到使用 provisioningState 更新为"Succeeded"。