流数据处理服务 API 概述¶
流数据处理服务为应用开发者提供流数据处理任务的查询和管理等功能。有关 EnOS 流数据处理服务的详细信息，参见 流数据处理。
有关 EnOS API 和 EnOS 提供的接口详细信息，参见 有关 EnOS API。
有关如何调用 EnOS API 的信息，参见 EnOS API 快速入门。
API 列表¶
| 操作名称 | 描述 | 适用于 EnOS Cloud | 适用于 EnOS Edge |
|---|---|---|---|
| Get Stage State | 查询指定流数据处理任务中某个指定算子的中间状态数据。 | √ | × |
| Delete Stage State | 删除指定流数据处理任务中某个指定算子的中间状态数据。 | √ | × |
| List Pipelines | 获取组织内所有流数据处理任务列表。 | √ | × |
| Get Pipeline Details | 获取指定流数据处理任务的详细信息。 | √ | × |
| Operate Pipeline | 对流数据处理任务执行保存、发布、启动、暂停、停止操作。 | √ | × |
| Get Pipeline Offset and Lag | 获取指定流数据处理任务的Offset和Lag。 | √ | × |
| Reset Pipeline Offset | 重置指定流数据处理任务的Kafka Offset。 | √ | × |