Get Pipeline Offset and Lag¶

获取指定流数据处理任务的Offset和Lag。

前提条件¶

已通过流数据处理服务创建流数据处理任务，并且流数据处理任务处于运行状态。

请求格式¶

GET https://{apigw-address}/streaming/v2.0/streaming/pipeline/{pipelineId}/offset-lag

请求参数（URI）¶

名称	位置（Path/Query）	必需/可选	数据类型	描述
pipelineId	Path	必需	String	流数据处理任务ID，可通过 EnOS管理门口 > 流数据处理 > 流运维页面查看，或通过调用 List Pipelines 接口获取。
orgId	Query	必需	String	用户所属的组织ID。如何获取orgId信息>>

响应参数¶

名称	数据类型	描述
data	List<JSONObject>	返回流数据处理任务的Offset和Lag信息。详见 data

data¶

名称	数据类型	描述
pipelineId	String	流数据处理任务ID。
topicName	String	Kafka Topic 名称。
lagAndOffset	JSONObject	流数据处理任务的 Lag 和 Offset 详细信息。详见 Lag and Offset

Lag and Offset¶

名称	数据类型	描述
lag	String	当前时间点的 Lag。
offset	String	当前时间点的 Offset。
ts	Long	时间戳。

错误码¶

代码	错误信息	描述
61108	Stream processing job does not exist.	流数据处理任务不存在。
99000	Internal Server Error.	服务内部错。

示例¶

请求示例¶

url: https://{apigw-address}/streaming/v2.0/streaming/pipeline/{pipelineId}/offset-lag?orgId=yourOrgId

method: GET

返回示例¶

{
  "code": 0,
  "msg": "OK",
  "data": {
    "topicName": "MEASURE_POINT_INTERNAL_o15517683199241",
    "lagAndOffset": [
      {
        "lag": 0,
        "offset": 6094977,
        "ts": 1616759448328
      },
      {
        "lag": 0,
        "offset": 6094977,
        "ts": 1616759673388
      }
    ],
    "pipelineId": "565c0114-9585-4372-86d1-50dde5ab8ce4"
  }
}

SDK 示例¶

你可以在 Github 上获取流数据处理的 SDK 示例：

Java
Python