# 流管理

eKuiper REST api 可用于管理流，例如创建、描述、显示和删除流定义。

## 创建流

该 API 用于创建流。 有关流定义的更多详细信息，请参考[流](../../sqls/streams.md)。

```shell
POST http://localhost:9081/streams
```
请求示例，请求命令是带有 `sql` 字段的 json 字符串。

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

该 API 可以运行任何流 sql 语句，而不仅可以创建流。

## 显示流

该 API 用于显示服务器中定义的所有流。

```shell
GET http://localhost:9081/streams
```

响应示例：

```json
["mystream"]
```

## 描述流

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

```shell
GET http://localhost:9081/streams/{id}}
```

响应示例：

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

## 获取数据结构

该 API 用于获取流的数据结构，该数据结构为合并物理 schema 和逻辑 schema后推断出的实际定义结构。

```shell
GET http://localhost:9081/streams/{id}/schema
```

数据格式为类 Json Schema 的结构。示例如下：

```json
{
    "id": {
        "type": "bigint"
	},
    "name": {
        "type": "string"
	},
    "age": {
        "type": "bigint"
	},
    "hobbies": {
        "type": "struct",
        "properties": {
          "indoor": {
            "type": "array",
            "items": {
              "type": "string"
            }
          },
          "outdoor": {
            "type": "array",
            "items": {
              "type": "string"
            }
          }
        }
    }
}
```


## 更新流

该 API 用于更新流定义。

```shell
PUT http://localhost:9081/streams/{id}
```

路径参数  `id` 是原有流定义的 id 或名称。

请求示例，请求命令是带有 `sql` 字段的 json 字符串。

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

## 删除流

该 API 用于删除流定义。

```shell
DELETE http://localhost:9081/streams/{id}
```