调用UpdatePipelines,更新Logstash管道信息。

调试

您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。

请求头

该接口使用公共请求头,无特殊请求头。请参见公共请求参数文档。

请求语法

PUT /openapi/logstashes/{InstanceId}/pipelines HTTP/1.1

请求参数

名称 类型 位置 是否必选 示例值 描述
InstanceId String Path ls-cn-oew1qbgl****

Logstash实例ID。

trigger Boolean Query false

是否立即部署。

clientToken String Query 5A2CFF0E-5718-45B5-9D4D-70B3FF****

用于保证请求的幂等性。由客户端生成该参数值,要保证在不同请求间唯一,最大不超过64个ASCII字符。

String Body [ { "pipelineId": "test", "config": "input {\n\n}\nfilter {\n\n}\noutput {\n \n}" } ]

指定更新的管道信息。

RequestBody

RequestBody中还需填入JSON格式的pipeline数组,用来指定更新的管道信息。

名称

类型

是否必选

示例值

描述

pipelineId

String

pipeline-test

待更新的管道的ID。

description

String

this is a test

管道描述。

config

String

input { } filter { } output { }

管道具体配置。

workers

Integer

2

管道工作线程数。

batchSize

Integer

125

管道批大小。

batchDelay

Integer

50

管道批延迟。单位ms。

queueType

String

MEMORY

队列类型。支持MEMORY和PERSISTED。

pipelineStatus

String

RUNNING

管道状态,trigger为true时必填。支持NOT_DEPLOYED、RUNNING和DELETED。

queueMaxBytes

Integer

1024

队列最大字节数。

queueCheckPointWrites

Integer

1024

队列检查点写入数。

示例如下。


[
    {
        "pipelineId": "test",
        "config": "input {\n\n}\nfilter {\n\n}\noutput {\n \n}"
    }
]

返回数据

名称 类型 示例值 描述
Result Boolean true

返回结果:

  • true:更新成功
  • false:更新失败
RequestId String 5FFD9ED4-C2EC-4E89-B22B-1ACB6FE1****

请求ID。

示例

请求示例

PUT /openapi/logstashes/ls-cn-oew1qbgl****/pipelines?clientToken=5A2CFF0E-5718-45B5-9D4D-70B3FF****&trigger=false HTTP/1.1
公共请求头
[
{"pipelineId":"test", "config":"input {\n\n}\nfilter {\n\n}\noutput {\n \n}"},

{"pipelineId":"test1", "config":"input {\n\n}\nfilter {\n\n}\noutput {\n  \n}"}
]

正常返回示例

JSON格式

HTTP/1.1 200 OK
Content-Type:application/json

{
  "Result" : true,
  "RequestId" : "734F9DEC-74AC-4D6E-B97F-FFDAA90B****"
}

错误码

访问错误中心查看更多错误码。