流数据处理服务 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。

×