Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
bcfb8b1f
T
TDengine
项目概览
taosdata
/
TDengine
大约 1 年 前同步成功
通知
1184
Star
22015
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看板
体验新版 GitCode,发现更多精彩内容 >>
提交
bcfb8b1f
编写于
6月 25, 2021
作者:
haoranc
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-4369]<test>: add testcase of resubscibe and json file
上级
84d3a5e7
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
59 addition
and
2 deletion
+59
-2
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubAC1endAfter1.json
...s/taosdemoAllTest/Resubjson/subSyncResubAC1endAfter1.json
+0
-0
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubAC1endAfterMin1.json
...aosdemoAllTest/Resubjson/subSyncResubAC1endAfterMin1.json
+0
-0
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1.json
...tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1.json
+0
-0
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1endAfter0.json
...sdemoAllTest/Resubjson/subSyncResubACMinus1endAfter0.json
+0
-0
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1endAfterNo0.json
...emoAllTest/Resubjson/subSyncResubACMinus1endAfterNo0.json
+0
-0
tests/pytest/tools/taosdemoAllTest/subSyncResFileNull.json
tests/pytest/tools/taosdemoAllTest/subSyncResFileNull.json
+49
-0
tests/pytest/tools/taosdemoAllTest/taosdemoTestSubWithJson.py
...s/pytest/tools/taosdemoAllTest/taosdemoTestSubWithJson.py
+10
-2
未找到文件。
tests/pytest/tools/taosdemoAllTest/
sub
Resubjson/subSyncResubAC1endAfter1.json
→
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubAC1endAfter1.json
浏览文件 @
bcfb8b1f
文件已移动
tests/pytest/tools/taosdemoAllTest/
sub
Resubjson/subSyncResubAC1endAfterMin1.json
→
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubAC1endAfterMin1.json
浏览文件 @
bcfb8b1f
文件已移动
tests/pytest/tools/taosdemoAllTest/
sub
Resubjson/subSyncResubACMinus1.json
→
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1.json
浏览文件 @
bcfb8b1f
文件已移动
tests/pytest/tools/taosdemoAllTest/
sub
Resubjson/subSyncResubACMinus1endAfter0.json
→
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1endAfter0.json
浏览文件 @
bcfb8b1f
文件已移动
tests/pytest/tools/taosdemoAllTest/
sub
Resubjson/subSyncResubACMinus1endAfterNo0.json
→
tests/pytest/tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1endAfterNo0.json
浏览文件 @
bcfb8b1f
文件已移动
tests/pytest/tools/taosdemoAllTest/subSyncResFileNull.json
0 → 100644
浏览文件 @
bcfb8b1f
{
"filetype"
:
"subscribe"
,
"cfgdir"
:
"/etc/taos"
,
"host"
:
"127.0.0.1"
,
"port"
:
6030
,
"user"
:
"root"
,
"password"
:
"taosdata"
,
"databases"
:
"db"
,
"confirm_parameter_prompt"
:
"no"
,
"specified_table_query"
:
{
"concurrent"
:
2
,
"mode"
:
"sync"
,
"interval"
:
0
,
"restart"
:
"no"
,
"keepProgress"
:
"no"
,
"resubAfterConsume"
:
-1
,
"endAfterConsume"
:
1
,
"sqls"
:
[
{
"sql"
:
"select * from stb00_0"
,
"result"
:
""
},
{
"sql"
:
"select ts from stb00_1"
,
"result"
:
""
}]
},
"super_table_query"
:
{
"stblname"
:
"stb0"
,
"threads"
:
2
,
"mode"
:
"sync"
,
"interval"
:
10000
,
"restart"
:
"no"
,
"keepProgress"
:
"no"
,
"resubAfterConsume"
:
-1
,
"endAfterConsume"
:
1
,
"sqls"
:
[
{
"sql"
:
"select * from xxxx where ts >= '2021-02-25 10:00:01.000' "
,
"result"
:
""
},
{
"sql"
:
"select * from xxxx where ts > '2021-02-25 10:00:04.000' "
,
"result"
:
""
}]
}
}
\ No newline at end of file
tests/pytest/tools/taosdemoAllTest/taosdemoTestSubWithJson.py
浏览文件 @
bcfb8b1f
...
...
@@ -116,9 +116,17 @@ class TDTestCase:
assert
os
.
system
(
"%staosdemo -f tools/taosdemoAllTest/subSyncSpecMaxsql100.json"
%
binPath
)
!=
0
assert
os
.
system
(
"%staosdemo -f tools/taosdemoAllTest/subSyncSuperMaxsql100.json"
%
binPath
)
!=
0
# # result files is null
# os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdataMaxsql100.json" % binPath)
# os.system("%staosdemo -f tools/taosdemoAllTest/subSyncResFileNull.json" % binPath)
# # assert os.system("%staosdemo -f tools/taosdemoAllTest/subSyncResFileNull.json" % binPath) != 0
# resubAfterConsume= -1 endAfter=-1 ;
os
.
system
(
'kill -9 `ps aux|grep "subSyncResubACMinus1.json" |grep -v "grep"|awk
\'
{print $2}
\'
` '
)
os
.
system
(
"nohup %staosdemo -f tools/taosdemoAllTest/
sub
Resubjson/subSyncResubACMinus1.json & "
%
binPath
)
os
.
system
(
"nohup %staosdemo -f tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1.json & "
%
binPath
)
sleep
(
2
)
query_pid1
=
int
(
subprocess
.
getstatusoutput
(
'ps aux|grep "subSyncResubACMinus1.json" |grep -v "grep"|awk
\'
{print $2}
\'
'
)[
1
])
print
(
"get sub1 process'pid"
)
...
...
@@ -138,7 +146,7 @@ class TDTestCase:
# # resubAfterConsume= -1 endAfter=0 ;
# os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdataMaxsql100.json" % binPath)
# os.system('kill -9 `ps aux|grep "subSyncResubACMinus1endAfter0.json" |grep -v "grep"|awk \'{print $2}\'` ')
# os.system("nohup %staosdemo -f tools/taosdemoAllTest/
sub
Resubjson/subSyncResubACMinus1endAfter0.json & " % binPath)
# os.system("nohup %staosdemo -f tools/taosdemoAllTest/Resubjson/subSyncResubACMinus1endAfter0.json & " % binPath)
# sleep(2)
# query_pid1 = int(subprocess.getstatusoutput('ps aux|grep "subSyncResubACMinus1endAfter0.json" |grep -v "grep"|awk \'{print $2}\'')[1])
# print("get sub2 process'pid")
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录