# 流管理
eKuiper 流命令行工具可用于管理流，例如创建、描述、显示和删除流定义。
# 创建流
该命令用于创建流。有关流定义的更多详细信息，请参考流。
create stream $stream_name '$stream_def' | create stream -f $stream_def_file
1
- 在命令行中指定流定义。
示例：
# bin/kuiper create stream my_stream '(id bigint, name string, score float) WITH ( datasource = "topic/temperature", FORMAT = "json", KEY = "id")'
stream my_stream created
1
2
2
该命令创建一个名为 my_stream 的流。
- 在文件中指定流定义。 如果流很复杂，或者流已经通过明确的格式写在文本文件中，则只需通过
-f选项规定流定义。
示例：
# bin/kuiper create stream -f /tmp/my_stream.txt
stream my_stream created
1
2
2
以下是my_stream.txt的内容。
my_stream(id bigint, name string, score float)
WITH ( datasource = "topic/temperature", FORMAT = "json", KEY = "id");
1
2
2
# 显示流
该命令用于显示服务器中定义的所有流。
show streams
1
示例：
# bin/kuiper show streams
my_stream
1
2
2
# 描述流
该命令用于打印流的详细定义。
describe stream $stream_name
1
示例：
# bin/kuiper describe stream my_stream
Fields
--------------------------------------------------------------------------------
id bigint
name string
score float
FORMAT: json
KEY: id
DATASOURCE: topic/temperature
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
# 删除流
该命令用于删除流定义。
drop stream $stream_name
1
示例：
# bin/kuiper drop stream my_stream
stream my_stream dropped
1
2
2
# 查询流
该命令用于从流中查询数据。
query
1
示例：
# bin/kuiper query
kuiper >
1
2
2
键入 query 子命令后，它会提示 kuiper>，然后在命令提示符中键入 SQLs （有关如何使用eKuiper SQL的信息，请参阅 eKuiper SQL 参考 ），然后按回车。
结果将在控制台中打印。
kuiper > SELECT * FROM my_stream WHERE id > 10;
[{"...":"..." ....}]
...
1
2
3
2
3
- 输入
CTRL + C停止查询; - 如果没有键入任何 SQL，则可以键入
quit或exit退出kuiper提示控制台。