streams.md

流管理

Kuiper流命令行工具可用于管理流，例如创建、描述、显示和删除流定义。

创建流

该命令用于创建流。 有关流定义的更多详细信息，请参考流。

create stream $stream_name $stream_def | create stream -f $stream_def_file

• 在命令行中指定流定义。

示例：

# bin/cli create stream my_stream '(id bigint, name string, score float) WITH ( datasource = "topic/temperature", FORMAT = "json", KEY = "id");'
stream my_stream created

该命令创建一个名为``my_stream''的规则。

• 在文件中指定流定义。 如果流很复杂，或者流已经通过明确的格式写在文本文件中，则只需通过“-f”选项规定流定义。

示例：

# bin/cli create stream -f /tmp/my_stream.txt
stream my_stream created

以下是my_stream.txt的内容。

my_stream(id bigint, name string, score float)
    WITH ( datasource = "topic/temperature", FORMAT = "json", KEY = "id");

显示流

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

show streams

示例：

# bin/cli show streams
my_stream

描述流

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

describe stream $stream_name

示例：

# bin/cli describe stream my_stream
Fields
--------------------------------------------------------------------------------
id	bigint
name	string
score	float

FORMAT: json
KEY: id
DATASOURCE: topic/temperature

删除流

该命令用于删除流定义。

drop stream $stream_name

示例：

# bin/cli drop stream my_stream
stream my_stream dropped

查询流

该命令用于从流中查询数据。

query

示例：

# bin/cli query
kuiper > 

键入query子命令后，它会提示``kuiper>”，然后在命令提示符中键入SQL（有关如何使用Kuiper SQL的信息，请参阅Kuiper SQL 参考 ），然后按Enter。

结果将在控制台中打印。

kuiper > SELECT * FROM my_stream WHERE id > 10;
[{"...":"..." ....}]
...

• 输入 CTRL + C停止查询;
• 如果没有键入任何SQL，则可以键入quit或exit退出kuiper提示控制台。