Release Pipeline¶
发布指定流数据处理任务。
前提条件¶
已通过流数据处理服务创建和配置流数据处理任务，并获取到流数据处理任务的ID。
请求格式¶
POST https://{apigw-address}/streaming/v2.0/streaming/pipeline/{pipelineId}?action=release
请求参数（URI）¶
名称 |
位置（Path/Query） |
必需/可选 |
数据类型 |
描述 |
|---|---|---|---|---|
pipelineId |
Path |
必需 |
String |
流数据处理任务ID，可通过 EnOS管理门口 > 流数据处理 > 流运维 页面查看，或通过调用 List Pipelines 接口获取。 |
orgId |
Query |
必需 |
String |
用户所属的组织ID。如何获取orgId信息>> |
响应参数¶
名称 |
数据类型 |
描述 |
|---|---|---|
data |
String |
运行成功返回空字符串。 |
错误码¶
代码 |
错误信息 |
描述 |
|---|---|---|
61108 |
Stream processing job does not exit. |
流数据处理任务不存在。 |
61169 |
Failed to release the stream processing job because it is not stopped or paused. |
发布流数据处理任务失败，因为该任务未处于停止或暂停状态。 |
示例¶
请求示例¶
url: https://{apigw-address}/streaming/v2.0/streaming/pipeline/{pipelineId}?action=release
method: POST
返回示例¶
{
"code": 0,
"msg": "OK",
}
SDK 示例¶
你可以在 Github 上获取流数据处理的 SDK 示例：