Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
Mz丶苗
TDengine
提交
ef901f10
T
TDengine
项目概览
Mz丶苗
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
ef901f10
编写于
12月 03, 2020
作者:
B
Bomin Zhang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-2309]<feature>: add config option to enable/disable stream (continuous query)
上级
fd0c6ade
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
51 addition
and
11 deletion
+51
-11
documentation20/webdocs/markdowndocs/administrator-ch.md
documentation20/webdocs/markdowndocs/administrator-ch.md
+1
-0
packaging/cfg/taos.cfg
packaging/cfg/taos.cfg
+4
-1
src/common/inc/tglobal.h
src/common/inc/tglobal.h
+3
-0
src/common/src/tglobal.c
src/common/src/tglobal.c
+13
-0
src/cq/src/cqMain.c
src/cq/src/cqMain.c
+18
-0
src/vnode/src/vnodeMain.c
src/vnode/src/vnodeMain.c
+12
-10
未找到文件。
documentation20/webdocs/markdowndocs/administrator-ch.md
浏览文件 @
ef901f10
...
...
@@ -95,6 +95,7 @@ TDengine系统后台服务由taosd提供,可以在配置文件taos.cfg里修
-
logKeepDays:日志文件的最长保存时间。大于0时,日志文件会被重命名为taosdlog.xxx,其中xxx为日志文件最后修改的时间戳,单位为秒。默认值:0天。
-
maxSQLLength:单条SQL语句允许最长限制。默认值:65380字节。
-
telemetryReporting: 是否允许 TDengine 采集和上报基本使用信息,0表示不允许,1表示允许。 默认值:1。
-
stream: 是否启用连续查询(流计算功能),0表示不允许,1表示允许。 默认值:1。
**注意:**
对于端口,TDengine会使用从serverPort起13个连续的TCP和UDP端口号,请务必在防火墙打开。因此如果是缺省配置,需要打开从6030都6042共13个端口,而且必须TCP和UDP都打开。
...
...
packaging/cfg/taos.cfg
浏览文件 @
ef901f10
...
...
@@ -260,4 +260,7 @@
# maxBinaryDisplayWidth 30
# enable/disable telemetry reporting
# telemetryReporting 1
\ No newline at end of file
# telemetryReporting 1
# enable/disable stream (continuous query)
# stream 1
src/common/inc/tglobal.h
浏览文件 @
ef901f10
...
...
@@ -125,6 +125,9 @@ extern char tsMonitorDbName[];
extern
char
tsInternalPass
[];
extern
int32_t
tsMonitorInterval
;
// stream
extern
int32_t
tsEnableStream
;
// internal
extern
int32_t
tsPrintAuth
;
extern
int32_t
tscEmbedded
;
...
...
src/common/src/tglobal.c
浏览文件 @
ef901f10
...
...
@@ -161,6 +161,9 @@ char tsMonitorDbName[TSDB_DB_NAME_LEN] = "log";
char
tsInternalPass
[]
=
"secretkey"
;
int32_t
tsMonitorInterval
=
30
;
// seconds
// stream
int32_t
tsEnableStream
=
1
;
// internal
int32_t
tsPrintAuth
=
0
;
int32_t
tscEmbedded
=
0
;
...
...
@@ -1015,6 +1018,16 @@ static void doInitGlobalConfig(void) {
cfg
.
unitType
=
TAOS_CFG_UTYPE_NONE
;
taosInitConfigOption
(
cfg
);
cfg
.
option
=
"stream"
;
cfg
.
ptr
=
&
tsEnableStream
;
cfg
.
valType
=
TAOS_CFG_VTYPE_INT32
;
cfg
.
cfgType
=
TSDB_CFG_CTYPE_B_CONFIG
|
TSDB_CFG_CTYPE_B_SHOW
;
cfg
.
minValue
=
0
;
cfg
.
maxValue
=
1
;
cfg
.
ptrLength
=
1
;
cfg
.
unitType
=
TAOS_CFG_UTYPE_NONE
;
taosInitConfigOption
(
cfg
);
cfg
.
option
=
"httpEnableRecordSql"
;
cfg
.
ptr
=
&
tsHttpEnableRecordSql
;
cfg
.
valType
=
TAOS_CFG_VTYPE_INT32
;
...
...
src/cq/src/cqMain.c
浏览文件 @
ef901f10
...
...
@@ -69,6 +69,9 @@ static void cqProcessStreamRes(void *param, TAOS_RES *tres, TAOS_ROW row);
static
void
cqCreateStream
(
SCqContext
*
pContext
,
SCqObj
*
pObj
);
void
*
cqOpen
(
void
*
ahandle
,
const
SCqCfg
*
pCfg
)
{
if
(
tsEnableStream
==
0
)
{
return
NULL
;
}
SCqContext
*
pContext
=
calloc
(
sizeof
(
SCqContext
),
1
);
if
(
pContext
==
NULL
)
{
terrno
=
TAOS_SYSTEM_ERROR
(
errno
);
...
...
@@ -99,6 +102,9 @@ void *cqOpen(void *ahandle, const SCqCfg *pCfg) {
}
void
cqClose
(
void
*
handle
)
{
if
(
tsEnableStream
==
0
)
{
return
;
}
SCqContext
*
pContext
=
handle
;
if
(
handle
==
NULL
)
return
;
...
...
@@ -129,6 +135,9 @@ void cqClose(void *handle) {
}
void
cqStart
(
void
*
handle
)
{
if
(
tsEnableStream
==
0
)
{
return
;
}
SCqContext
*
pContext
=
handle
;
if
(
pContext
->
dbConn
||
pContext
->
master
)
return
;
...
...
@@ -147,6 +156,9 @@ void cqStart(void *handle) {
}
void
cqStop
(
void
*
handle
)
{
if
(
tsEnableStream
==
0
)
{
return
;
}
SCqContext
*
pContext
=
handle
;
cInfo
(
"vgId:%d, stop all CQs"
,
pContext
->
vgId
);
if
(
pContext
->
dbConn
==
NULL
||
pContext
->
master
==
0
)
return
;
...
...
@@ -174,6 +186,9 @@ void cqStop(void *handle) {
}
void
*
cqCreate
(
void
*
handle
,
uint64_t
uid
,
int32_t
tid
,
char
*
sqlStr
,
STSchema
*
pSchema
)
{
if
(
tsEnableStream
==
0
)
{
return
NULL
;
}
SCqContext
*
pContext
=
handle
;
SCqObj
*
pObj
=
calloc
(
sizeof
(
SCqObj
),
1
);
...
...
@@ -203,6 +218,9 @@ void *cqCreate(void *handle, uint64_t uid, int32_t tid, char *sqlStr, STSchema *
}
void
cqDrop
(
void
*
handle
)
{
if
(
tsEnableStream
==
0
)
{
return
;
}
SCqObj
*
pObj
=
handle
;
SCqContext
*
pContext
=
pObj
->
pContext
;
...
...
src/vnode/src/vnodeMain.c
浏览文件 @
ef901f10
...
...
@@ -267,16 +267,18 @@ int32_t vnodeOpen(int32_t vnode, char *rootDir) {
return
terrno
;
}
SCqCfg
cqCfg
=
{
0
};
sprintf
(
cqCfg
.
user
,
"_root"
);
strcpy
(
cqCfg
.
pass
,
tsInternalPass
);
strcpy
(
cqCfg
.
db
,
pVnode
->
db
);
cqCfg
.
vgId
=
vnode
;
cqCfg
.
cqWrite
=
vnodeWriteToCache
;
pVnode
->
cq
=
cqOpen
(
pVnode
,
&
cqCfg
);
if
(
pVnode
->
cq
==
NULL
)
{
vnodeCleanUp
(
pVnode
);
return
terrno
;
if
(
tsEnableStream
)
{
SCqCfg
cqCfg
=
{
0
};
sprintf
(
cqCfg
.
user
,
"_root"
);
strcpy
(
cqCfg
.
pass
,
tsInternalPass
);
strcpy
(
cqCfg
.
db
,
pVnode
->
db
);
cqCfg
.
vgId
=
vnode
;
cqCfg
.
cqWrite
=
vnodeWriteToCache
;
pVnode
->
cq
=
cqOpen
(
pVnode
,
&
cqCfg
);
if
(
pVnode
->
cq
==
NULL
)
{
vnodeCleanUp
(
pVnode
);
return
terrno
;
}
}
STsdbAppH
appH
=
{
0
};
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录