# 表管理

eKuiper 支持 REST api 方式管理表，例如创建、描述、显示和删除。

# 创建表

该 API 用于创建表。更详细的表定义信息请参考tables。

POST http://localhost:9081/tables

请求示例，请求是一个带有 sql 字段的 json 字符串。

{"sql":"create table my_table (id bigint, name string, score float) WITH ( datasource = \"lookup.json\", FORMAT = \"json\", KEY = \"id\")"}

这个API可以运行任何表的sql语句，不仅仅是建表。

# 查看所有的表

此API 用于显示 eKuiper 中定义的所有表

GET http://localhost:9081/tables

返回示例:

["mytable"]

# 查看表的详细信息

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

GET http://localhost:9081/tables/{id}}

返回示例:

{
  "Name": "demo",
  "StreamFields": [
    {
      "Name": "temperature",
      "FieldType": {
        "Type": 2
      }
    },
    {
      "Name": "ts",
      "FieldType": {
        "Type": 1
      }
    }
  ],
  "Options": {
    "DATASOURCE": "lookup.json",
    "FORMAT": "JSON"
  }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

# 更新表

该 API 用于更新表的定义。

PUT http://localhost:9081/tables/{id}

路径参数 id 是旧表的 id 或名称。请求示例，请求是一个带有 sql 字段的 json 字符串。

{"sql":"create table my_table (id bigint, name string, score float) WITH ( datasource = \"topic/temperature\", FORMAT = \"json\", KEY = \"id\")"}

# 删除表

该 API 用于删除表。

DELETE http://localhost:9081/tables/{id}

← 流管理规则管理 →