eKuiper REST api 允许您管理模式，例如创建、删除和列出模式。

创建模式

该API接受JSON内容以创建新的模式。 每种模式类型都有一个独立的端点。当前模式类型仅有一种 protobuf。模式由名称标识。名称必须唯一。

  1. POST http://localhost:9081/schemas/protobuf

模式内容在请求体上的请求示例：

  1. {
  2.   "name": "schema1",
  3.   "content": "message Book {required string title = 1; required int32 price = 2;}"
  4. }

模式内容在文件上的请求示例：

  1. {
  2.   "name": "schema2",
  3.   "file": "file:///tmp/ekuiper/internal/schema/test/test2.proto"
  4. }

参数

  1. name：模式的唯一名称。
  2. 模式的内容，可选用 file 或 content 参数来指定。模式创建后，模式内容将写入 etc/schemas/$shcema_type/$schema_name 文件中。
    • file：模式文件的 URL。URL 支持 http 和 https 以及 file 模式。当使用 file 模式时，该文件必须在 eKuiper 服务器所在的机器上。它必须是模式类型对应的格式。例如 protobuf 模式的文件扩展名应为 .proto。
    • content：模式文件的内容。

显示模式

该 API 用于显示服务器中为模式类型定义的所有模式。

  1. GET http://localhost:9081/schemas/protobuf

响应示例：

  1. ["schema1","schema2"]

描述模式

该 API 用于打印模式的详细定义。

  1. GET http://localhost:9081/schemas/protobuf/{name}

路径参数 name 是模式的名称。

响应示例：

  1. {
  2.   "type": "protobuf",
  3.   "name": "schema1",
  4.   "content": "message Book {required string title = 1; required int32 price = 2;}",
  5.   "file": "ekuiper\\etc\\schemas\\protobuf\\schema1.proto"
  6. }

删除模式

该 API 用于删除模式。

  1. DELETE http://localhost:9081/schemas/protobuf/{name}

修改模式

该 API 用于修改模式，其消息体格式与创建时相同。

  1. PUT http://localhost:9081/schemas/protobuf/{name}
  3. {
  4.   "name": "schema2",
  5.   "file": "http://ahot.com/test2.proto"
  6. }