Skip to content

Commit feaa424

Browse files
flyingangel2013flyingangel2013
committed
modify
1 parent 5b60179 commit feaa424

File tree

1 file changed

+39
-21
lines changed

1 file changed

+39
-21
lines changed

‎test/cases/13-StreamProcessing/03-TriggerMode/test_state_2.py

Lines changed: 39 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -50,15 +50,15 @@ def test_stream_state_trigger(self):
5050

5151
streams = [
5252
self.StreamItem(sql1, self.checks1),
53-
self.StreamItem(sql2, self.checks2),
54-
self.StreamItem(sql3, self.checks3),
55-
self.StreamItem(sql4, self.checks4),
53+
# self.StreamItem(sql2, self.checks2),
54+
# self.StreamItem(sql3, self.checks3),
55+
# self.StreamItem(sql4, self.checks4),
5656
]
5757

5858
for stream in streams:
5959
tdSql.execute(stream.sql)
60-
# tdStream.checkStreamStatus()
61-
time.sleep(3)
60+
tdStream.checkStreamStatus()
61+
# time.sleep(3)
6262

6363
tdLog.info(f"=============== write query data")
6464
sqls = [
@@ -119,8 +119,8 @@ def test_stream_state_trigger(self):
119119
sql5 = "create stream s5 state_window(cint) true_for(5s) from ct1 into res_truefor_ct1 (firstts, num_v, cnt_v, avg_v) as select first(_c0), _twrownum, count(*), avg(cuint) from %%trows;"
120120

121121
tdSql.execute(sql5)
122-
# tdStream.checkStreamStatus("s5")
123-
time.sleep(3)
122+
tdStream.checkStreamStatus("s5")
123+
# time.sleep(3)
124124

125125
tdLog.info(f"=============== continue write data into ct1 for true_for(5s)")
126126
sqls = [
@@ -143,8 +143,8 @@ def test_stream_state_trigger(self):
143143
sql6 = "create stream s6 state_window(cint) from ct1 options(fill_history) into res_fill_all_ct1 (firstts, num_v, cnt_v, avg_v) as select first(_c0), _twrownum, count(*), avg(cuint) from %%trows;"
144144

145145
tdSql.execute(sql6)
146-
# tdStream.checkStreamStatus("s6")
147-
time.sleep(3)
146+
tdStream.checkStreamStatus("s6")
147+
# time.sleep(3)
148148

149149
tdLog.info(f"=============== continue write data into ct1 for new real data ")
150150
sqls = [
@@ -165,8 +165,8 @@ def test_stream_state_trigger(self):
165165
# set start_time
166166
sql7 = "create stream s7 state_window(cint) true_for(5s) from ct1 options(fill_history('2025-01-02 00:00:10')) into res_fill_part_ct1 (firstts, num_v, cnt_v, avg_v) as select first(_c0), _twrownum, count(*), avg(cuint) from %%trows;"
167167
tdSql.execute(sql7)
168-
# tdStream.checkStreamStatus("s7")
169-
time.sleep(3)
168+
tdStream.checkStreamStatus("s7")
169+
# time.sleep(3)
170170

171171
tdLog.info(f"=============== continue write data into ct1 for new real data ")
172172
sqls = [
@@ -189,37 +189,55 @@ def test_stream_state_trigger(self):
189189
tdLog.info(f"=============== create sub table")
190190
tdSql.execute(f"create table ct5 using stb tags(1);")
191191

192-
sql8 = "create stream s8 state_window(cint) from ct5 options(max_delay(3s)) into res_max_delay_ct1 (lastts, firstts, num_v, cnt_v, avg_v) as select last_row(_c0), first(_c0), _twrownum, count(*), avg(cuint) from %%trows;"
192+
sql8 = "create stream s8 state_window(cint) from ct5 options(max_delay(3s)) into res_max_delay_ct5 (lastts, firstts, num_v, cnt_v, avg_v) as select last_row(_c0), first(_c0), _twrownum, count(*), avg(cuint) from %%trows;"
193193

194194
tdSql.execute(sql8)
195-
# tdStream.checkStreamStatus("s8")
196-
time.sleep(3)
195+
tdStream.checkStreamStatus("s8")
196+
time.sleep(10)
197197

198198
tdLog.info(f"=============== continue write data into ct5 for new real data ")
199199
sqls = [
200200
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:10', 1, 0);",
201201
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:11', 1, 0);",
202202
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:12', 1, 1);",
203+
]
204+
tdSql.executes(sqls)
205+
time.sleep(4)
206+
sqls = [
203207
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:13', 1, 1);",
204208
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:14', 1, 1);",
205209
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:15', 2, 2);",
206210
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:16', 2, 2);",
207211
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:17', 2, 2);",
212+
]
213+
tdSql.executes(sqls)
214+
time.sleep(4)
215+
sqls = [
208216
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:18', 2, 2);",
209-
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:19', 2, 3);",
210-
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:20', 1, 0);",
211-
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:21', 1, 0);",
217+
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:19', 2, 2);",
218+
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:20', 1, 1);",
219+
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:21', 1, 1);",
212220
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:22', 1, 1);",
221+
]
222+
tdSql.executes(sqls)
223+
time.sleep(4)
224+
sqls = [
213225
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:23', 1, 1);",
214226
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:24', 1, 1);",
215227
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:25', 2, 2);",
216228
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:26', 2, 2);",
217229
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:27', 2, 2);",
230+
]
231+
tdSql.executes(sqls)
232+
time.sleep(4)
233+
sqls = [
218234
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:28', 2, 2);",
219-
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:29', 2, 3);",
235+
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:29', 2, 2);",
236+
"insert into ct5 using stb tags(1) values ('2025-01-04 00:00:30', 3, 3);",
220237
]
221-
tdSql.executes(sqls)
222-
self.checks6(3) # max_delay 觸發的結果時間戳 ，與 最後窗口關閉 的結果時間戳 是一樣的嗎？ 如果是，需要配合 通知 來測試。
238+
tdSql.executes(sqls)
239+
time.sleep(1)
240+
self.checks6(3)
223241

224242
# max_delay + true_for
225243

@@ -447,7 +465,7 @@ def checks6(self, check_idx):
447465
)
448466
tdLog.info(f"=============== check s6-2 result success !!!!!!!! =====================")
449467
elif 3 == check_idx:
450-
result_sql = "select lastts, firstts, num_v, cnt_v, avg_v from res_max_delay_ct1"
468+
result_sql = "select lastts, firstts, num_v, cnt_v, avg_v from res_max_delay_ct5"
451469
tdSql.checkResultsByFunc(
452470
sql=result_sql,
453471
func=lambda: tdSql.getRows() == 6

0 commit comments

Comments
 (0)