xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #18491 from taosdata/fix/TD-20318 

test: add tmq case
This commit is contained in:
Shengliang Guan 2022-11-27 19:38:27 +08:00 committed by GitHub
parent d6a23a404d 2dc23cdfe5
commit 83f1f8d93f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 25 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/parallel_test/cases.task
View File

@ -690,16 +690,16 @@
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData1.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData1.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumerGroup.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumerGroup.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqShow.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqShow.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqAlterSchema.py ,,,system-test,python3 ./test.py -f 7-tmq/tmqAlterSchema.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb1.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-mutilVg.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-mutilVg.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-1ctb.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb-1ctb.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-1ctb.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-1ctb.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-1ctb-funcNFilter.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb-1ctb-funcNFilter.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg-mutilCtb-funcNFilter.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg-mutilCtb-funcNFilter.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg-mutilCtb.py ,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb-mutilVg-mutilCtb.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-1ctb-funcNFilter.py ,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-1ctb-funcNFilter.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-mutilVg-mutilCtb-funcNFilter.py ,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1-mutilVg-mutilCtb-funcNFilter.py

2
tests/pytest/util/common.py
View File

@ -737,7 +737,7 @@ class TDCom:
if (platform.system().lower() == 'windows'): if (platform.system().lower() == 'windows'):
os.system("TASKKILL /F /IM %s.exe"%processorName) os.system("TASKKILL /F /IM %s.exe"%processorName)
else: else:
os.system('pkill %s'%processorName) os.system("unset LD_PRELOAD; pkill %s " % processorName)
def is_json(msg): def is_json(msg):

13
tests/system-test/7-tmq/tmqShow.py
View File

@ -126,13 +126,20 @@ class TDTestCase:
pThread = tmqCom.asyncInsertData(paraDict) pThread = tmqCom.asyncInsertData(paraDict)
tmqCom.getStartConsumeNotifyFromTmqsim() tmqCom.getStartConsumeNotifyFromTmqsim()
#time.sleep(5)
for i in range(0, 10, 1):
tdLog.info("check show consumers") tdLog.info("check show consumers")
tdSql.query("show consumers") tdSql.query("show consumers")
# tdLog.info(tdSql.queryResult) # tdLog.info(tdSql.queryResult)
rows = tdSql.getRows() rows = tdSql.getRows()
tdLog.info("show consumers rows: %d"%rows) tdLog.info("show consumers rows: %d" % rows)
if rows != len(topicNameList):
if rows == len(topicNameList):
tdLog.info("show consumers rows not match %d:%d" %
(rows, len(topicNameList)))
time.sleep(1)
break
if (rows == 9):
tdLog.exit("show consumers rows error") tdLog.exit("show consumers rows error")
for i in range(0, 10, 1): for i in range(0, 10, 1):