Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
4bdc1dd5
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
未验证
提交
4bdc1dd5
编写于
8月 12, 2022
作者:
L
Liu Jicong
提交者:
GitHub
8月 12, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #16070 from taosdata/docs/td-15880-2
docs: update 06-stream.md for stream-computing
上级
3319c093
8485b69c
变更
1
显示空白变更内容
内联
并排
Showing
1 changed file
with
22 addition
and
22 deletion
+22
-22
docs/zh/07-develop/06-stream.md
docs/zh/07-develop/06-stream.md
+22
-22
未找到文件。
docs/zh/07-develop/06-stream.md
浏览文件 @
4bdc1dd5
...
...
@@ -22,7 +22,7 @@ stream_options: {
## 示例一
企业电表的数据经常都是成百上千亿条的,那么想要将这些分散、凌乱的数据清洗或转换都需要比较长的时间,很难做到高效性和实时性,以下例子中,通过流计算可以将
过去 12 小时电表电压大于 220V 的数据清洗掉,然后以小时为窗口整合并计算出每个窗口中电流的最大值,并
将结果输出到指定的数据表中。
企业电表的数据经常都是成百上千亿条的,那么想要将这些分散、凌乱的数据清洗或转换都需要比较长的时间,很难做到高效性和实时性,以下例子中,通过流计算可以将
电表电压大于 220V 的数据清洗掉,然后以 5 秒为窗口整合并计算出每个窗口中电流的最大值,最后
将结果输出到指定的数据表中。
### 创建 DB 和原始数据表
...
...
@@ -44,19 +44,19 @@ CREATE TABLE d1004 USING meters TAGS ("California.LosAngeles", 3);
### 创建流
```
sql
create
stream
current_stream
into
current_stream_output_stb
as
select
_wstart
as
start
,
_wend
as
end
,
max
(
current
)
as
max_current
from
meters
where
voltage
<=
220
and
ts
>
now
-
12
h
interval
(
1
h
);
create
stream
current_stream
into
current_stream_output_stb
as
select
_wstart
as
start
,
_wend
as
end
,
max
(
current
)
as
max_current
from
meters
where
voltage
<=
220
interval
(
5
s
);
```
### 写入数据
```
sql
insert
into
d1001
values
(
now
-
13
h
,
10
.
30000
,
219
,
0
.
31000
);
insert
into
d1001
values
(
now
-
11
h
,
12
.
60000
,
218
,
0
.
33000
);
insert
into
d1001
values
(
now
-
10
h
,
12
.
30000
,
221
,
0
.
31000
);
insert
into
d1002
values
(
now
-
9
h
,
10
.
30000
,
218
,
0
.
25000
);
insert
into
d1003
values
(
now
-
8
h
,
11
.
80000
,
221
,
0
.
28000
);
insert
into
d1003
values
(
now
-
7
h
,
13
.
40000
,
223
,
0
.
29000
);
insert
into
d1004
values
(
now
-
6
h
,
10
.
80000
,
223
,
0
.
29000
);
insert
into
d1004
values
(
now
-
5
h
,
11
.
50000
,
221
,
0
.
35000
);
insert
into
d1001
values
(
"2018-10-03 14:38:05.000"
,
10
.
30000
,
219
,
0
.
31000
);
insert
into
d1001
values
(
"2018-10-03 14:38:15.000"
,
12
.
60000
,
218
,
0
.
33000
);
insert
into
d1001
values
(
"2018-10-03 14:38:16.800"
,
12
.
30000
,
221
,
0
.
31000
);
insert
into
d1002
values
(
"2018-10-03 14:38:16.650"
,
10
.
30000
,
218
,
0
.
25000
);
insert
into
d1003
values
(
"2018-10-03 14:38:05.500"
,
11
.
80000
,
221
,
0
.
28000
);
insert
into
d1003
values
(
"2018-10-03 14:38:16.600"
,
13
.
40000
,
223
,
0
.
29000
);
insert
into
d1004
values
(
"2018-10-03 14:38:05.000"
,
10
.
80000
,
223
,
0
.
29000
);
insert
into
d1004
values
(
"2018-10-03 14:38:06.500"
,
11
.
50000
,
221
,
0
.
35000
);
```
### 查询以观查结果
...
...
@@ -65,9 +65,9 @@ insert into d1004 values(now-5h, 11.50000, 221, 0.35000);
taos
>
select
start
,
end
,
max_current
from
current_stream_output_stb
;
start
|
end
|
max_current
|
===========================================================================
20
22
-
08
-
12
04
:
00
:
00
.
000
|
2022
-
08
-
12
05
:
00
:
00
.
000
|
12
.
6
0000
|
20
22
-
08
-
12
06
:
00
:
00
.
000
|
2022
-
08
-
12
07
:
00
:
00
.
000
|
10
.
3
0000
|
Query
OK
,
2
rows
in
database
(
0
.
0
09580
s
)
20
18
-
10
-
03
14
:
38
:
05
.
000
|
2018
-
10
-
03
14
:
38
:
10
.
000
|
10
.
3
0000
|
20
18
-
10
-
03
14
:
38
:
15
.
000
|
2018
-
10
-
03
14
:
38
:
20
.
000
|
12
.
6
0000
|
Query
OK
,
2
rows
in
database
(
0
.
0
18762
s
)
```
## 示例二
...
...
@@ -93,13 +93,13 @@ create stream power_stream into power_stream_output_stb as select ts, concat_ws(
taos
>
select
ts
,
meter_location
,
active_power
,
reactive_power
from
power_stream_output_stb
;
ts
|
meter_location
|
active_power
|
reactive_power
|
===================================================================================================================
20
22
-
08
-
12
11
:
25
:
32
.
579
|
California
.
LosAngeles
.
d1003
|
2506
.
240411679
|
720
.
680274962
|
20
22
-
08
-
12
12
:
25
:
32
.
586
|
California
.
LosAngeles
.
d1003
|
2863
.
424274422
|
854
.
482390839
|
20
22
-
08
-
12
13
:
25
:
32
.
594
|
California
.
LosAngeles
.
d1004
|
2307
.
834596289
|
688
.
687331847
|
20
22
-
08
-
12
14
:
25
:
32
.
601
|
California
.
LosAngeles
.
d1004
|
2387
.
415754896
|
871
.
474763418
|
20
22
-
08
-
12
10
:
25
:
32
.
566
|
California
.
SanFrancisco
.
d1002
|
2175
.
595991997
|
555
.
520860397
|
20
22
-
08
-
12
06
:
25
:
32
.
534
|
California
.
SanFrancisco
.
d1001
|
2148
.
178871730
|
688
.
120784090
|
20
22
-
08
-
12
08
:
25
:
32
.
546
|
California
.
SanFrancisco
.
d1001
|
2598
.
589176205
|
890
.
081451418
|
20
22
-
08
-
12
09
:
25
:
32
.
555
|
California
.
SanFrancisco
.
d1001
|
2588
.
728381186
|
829
.
240910475
|
Query
OK
,
8
rows
in
database
(
0
.
01
3775
s
)
20
18
-
10
-
03
14
:
38
:
05
.
000
|
California
.
LosAngeles
.
d1004
|
2307
.
834596289
|
688
.
687331847
|
20
18
-
10
-
03
14
:
38
:
06
.
500
|
California
.
LosAngeles
.
d1004
|
2387
.
415754896
|
871
.
474763418
|
20
18
-
10
-
03
14
:
38
:
05
.
500
|
California
.
LosAngeles
.
d1003
|
2506
.
240411679
|
720
.
680274962
|
20
18
-
10
-
03
14
:
38
:
16
.
600
|
California
.
LosAngeles
.
d1003
|
2863
.
424274422
|
854
.
482390839
|
20
18
-
10
-
03
14
:
38
:
05
.
000
|
California
.
SanFrancisco
.
d1001
|
2148
.
178871730
|
688
.
120784090
|
20
18
-
10
-
03
14
:
38
:
15
.
000
|
California
.
SanFrancisco
.
d1001
|
2598
.
589176205
|
890
.
081451418
|
20
18
-
10
-
03
14
:
38
:
16
.
800
|
California
.
SanFrancisco
.
d1001
|
2588
.
728381186
|
829
.
240910475
|
20
18
-
10
-
03
14
:
38
:
16
.
650
|
California
.
SanFrancisco
.
d1002
|
2175
.
595991997
|
555
.
520860397
|
Query
OK
,
8
rows
in
database
(
0
.
01
4753
s
)
```
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录