Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
4ed3847e
T
TDengine
项目概览
慢慢CG
/
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看板
提交
4ed3847e
编写于
9月 16, 2021
作者:
sangshuduo
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
minor typo fix.
上级
2324acf0
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
29 addition
and
28 deletion
+29
-28
src/kit/taosdemo/taosdemo.c
src/kit/taosdemo/taosdemo.c
+29
-28
未找到文件。
src/kit/taosdemo/taosdemo.c
浏览文件 @
4ed3847e
...
@@ -104,6 +104,7 @@ extern char configDir[];
...
@@ -104,6 +104,7 @@ extern char configDir[];
#define DATATYPE_BUFF_LEN (SMALL_BUFF_LEN*3)
#define DATATYPE_BUFF_LEN (SMALL_BUFF_LEN*3)
#define NOTE_BUFF_LEN (SMALL_BUFF_LEN*16)
#define NOTE_BUFF_LEN (SMALL_BUFF_LEN*16)
#define DEFAULT_NTHREADS 8
#define DEFAULT_TIMESTAMP_STEP 1
#define DEFAULT_TIMESTAMP_STEP 1
#define DEFAULT_INTERLACE_ROWS 0
#define DEFAULT_INTERLACE_ROWS 0
#define DEFAULT_DATATYPE_NUM 1
#define DEFAULT_DATATYPE_NUM 1
...
@@ -648,7 +649,7 @@ SArguments g_args = {
...
@@ -648,7 +649,7 @@ SArguments g_args = {
64
,
// binwidth
64
,
// binwidth
4
,
// columnCount, timestamp + float + int + float
4
,
// columnCount, timestamp + float + int + float
20
+
FLOAT_BUFF_LEN
+
INT_BUFF_LEN
+
FLOAT_BUFF_LEN
,
// lenOfOneRow
20
+
FLOAT_BUFF_LEN
+
INT_BUFF_LEN
+
FLOAT_BUFF_LEN
,
// lenOfOneRow
8
,
// num_of_connections/thread
DEFAULT_NTHREADS
,
// nthreads
0
,
// insert_interval
0
,
// insert_interval
DEFAULT_TIMESTAMP_STEP
,
// timestamp_step
DEFAULT_TIMESTAMP_STEP
,
// timestamp_step
1
,
// query_times
1
,
// query_times
...
@@ -750,19 +751,19 @@ static void printHelp() {
...
@@ -750,19 +751,19 @@ static void printHelp() {
char
indent
[
10
]
=
" "
;
char
indent
[
10
]
=
" "
;
printf
(
"%s
\n\n
"
,
"Usage: taosdemo [OPTION...]"
);
printf
(
"%s
\n\n
"
,
"Usage: taosdemo [OPTION...]"
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-f, --file=FILE"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-f, --file=FILE"
,
"
\t\t
"
,
"The meta file to the execution procedure.
Default is './meta.json'.
"
);
"The meta file to the execution procedure."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-u, --user=USER"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-u, --user=USER"
,
"
\t\t
"
,
"The user name to use when connecting to the server."
);
"The user name to use when connecting to the server."
);
#ifdef _TD_POWER_
#ifdef _TD_POWER_
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
"The password to use when connecting to the server.
D
efault is 'powerdb'"
);
"The password to use when connecting to the server.
By d
efault is 'powerdb'"
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-c, --config-dir=CONFIG_DIR"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-c, --config-dir=CONFIG_DIR"
,
"
\t
"
,
"Configuration directory.
D
efault is '/etc/power/'."
);
"Configuration directory.
By d
efault is '/etc/power/'."
);
#elif (_TD_TQ_ == true)
#elif (_TD_TQ_ == true)
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
"The password to use when connecting to the server.
D
efault is 'tqueue'"
);
"The password to use when connecting to the server.
By d
efault is 'tqueue'"
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-c, --config-dir=CONFIG_DIR"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-c, --config-dir=CONFIG_DIR"
,
"
\t
"
,
"Configuration directory.
D
efault is '/etc/tq/'."
);
"Configuration directory.
By d
efault is '/etc/tq/'."
);
#else
#else
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-p, --password"
,
"
\t\t
"
,
"The password to use when connecting to the server."
);
"The password to use when connecting to the server."
);
...
@@ -774,24 +775,24 @@ static void printHelp() {
...
@@ -774,24 +775,24 @@ static void printHelp() {
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-P, --port=PORT"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-P, --port=PORT"
,
"
\t\t
"
,
"The TCP/IP port number to use for the connection."
);
"The TCP/IP port number to use for the connection."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-I, --interface=INTERFACE"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-I, --interface=INTERFACE"
,
"
\t
"
,
"The interface (taosc, rest, and stmt) taosdemo uses.
Default is
'taosc'."
);
"The interface (taosc, rest, and stmt) taosdemo uses.
By default use
'taosc'."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-d, --database=DATABASE"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-d, --database=DATABASE"
,
"
\t
"
,
"Destination database.
D
efault is 'test'."
);
"Destination database.
By d
efault is 'test'."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-a, --replica=REPLICA"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-a, --replica=REPLICA"
,
"
\t\t
"
,
"Set the replica parameters of the database,
Default
1, min: 1, max: 3."
);
"Set the replica parameters of the database,
By default use
1, min: 1, max: 3."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-m, --table-prefix=TABLEPREFIX"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-m, --table-prefix=TABLEPREFIX"
,
"
\t
"
,
"Table prefix name.
Default is
'd'."
);
"Table prefix name.
By default use
'd'."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-s, --sql-file=FILE"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-s, --sql-file=FILE"
,
"
\t\t
"
,
"The select sql file."
);
"The select sql file."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-N, --normal-table"
,
"
\t\t
"
,
"Use normal table flag."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-N, --normal-table"
,
"
\t\t
"
,
"Use normal table flag."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-o, --output=FILE"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-o, --output=FILE"
,
"
\t\t
"
,
"Direct output to the named file.
Default is
'./output.txt'."
);
"Direct output to the named file.
By default use
'./output.txt'."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-q, --query-mode=MODE"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-q, --query-mode=MODE"
,
"
\t\t
"
,
"Query mode -- 0: SYNC, 1: ASYNC.
Default is
SYNC."
);
"Query mode -- 0: SYNC, 1: ASYNC.
By default use
SYNC."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-b, --data-type=DATATYPE"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-b, --data-type=DATATYPE"
,
"
\t
"
,
"The data_type of columns,
default
: FLOAT, INT, FLOAT."
);
"The data_type of columns,
By default use
: FLOAT, INT, FLOAT."
);
printf
(
"%s%s%s%s%d
\n
"
,
indent
,
"-w, --binwidth=WIDTH"
,
"
\t\t
"
,
printf
(
"%s%s%s%s%d
\n
"
,
indent
,
"-w, --binwidth=WIDTH"
,
"
\t\t
"
,
"The width of data_type 'BINARY' or 'NCHAR'.
Default is
"
,
"The width of data_type 'BINARY' or 'NCHAR'.
By default use
"
,
g_args
.
binwidth
);
g_args
.
binwidth
);
printf
(
"%s%s%s%s%d%s%d
\n
"
,
indent
,
"-l, --columns=COLUMNS"
,
"
\t\t
"
,
printf
(
"%s%s%s%s%d%s%d
\n
"
,
indent
,
"-l, --columns=COLUMNS"
,
"
\t\t
"
,
"The number of columns per record. Demo mode by default is "
,
"The number of columns per record. Demo mode by default is "
,
...
@@ -800,32 +801,32 @@ static void printHelp() {
...
@@ -800,32 +801,32 @@ static void printHelp() {
MAX_NUM_COLUMNS
);
MAX_NUM_COLUMNS
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
indent
,
indent
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
indent
,
indent
,
"
\t\t\t\t
All of the new column(s) type is INT. If use -b to specify column type, -l will be ignored."
);
"
\t\t\t\t
All of the new column(s) type is INT. If use -b to specify column type, -l will be ignored."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-T, --threads=NUMBER"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
%d.
\n
"
,
indent
,
"-T, --threads=NUMBER"
,
"
\t\t
"
,
"The number of threads.
Default is 10."
);
"The number of threads.
By default use "
,
DEFAULT_NTHREADS
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-i, --insert-interval=NUMBER"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-i, --insert-interval=NUMBER"
,
"
\t
"
,
"The sleep time (ms) between insertion.
D
efault is 0."
);
"The sleep time (ms) between insertion.
By d
efault is 0."
);
printf
(
"%s%s%s%s%d.
\n
"
,
indent
,
"-S, --time-step=TIME_STEP"
,
"
\t
"
,
printf
(
"%s%s%s%s%d.
\n
"
,
indent
,
"-S, --time-step=TIME_STEP"
,
"
\t
"
,
"The timestamp step between insertion.
D
efault is "
,
"The timestamp step between insertion.
By d
efault is "
,
DEFAULT_TIMESTAMP_STEP
);
DEFAULT_TIMESTAMP_STEP
);
printf
(
"%s%s%s%s%d.
\n
"
,
indent
,
"-B, --interlace-rows=NUMBER"
,
"
\t
"
,
printf
(
"%s%s%s%s%d.
\n
"
,
indent
,
"-B, --interlace-rows=NUMBER"
,
"
\t
"
,
"The interlace rows of insertion.
D
efault is "
,
"The interlace rows of insertion.
By d
efault is "
,
DEFAULT_INTERLACE_ROWS
);
DEFAULT_INTERLACE_ROWS
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-r, --rec-per-req=NUMBER"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-r, --rec-per-req=NUMBER"
,
"
\t
"
,
"The number of records per request.
D
efault is 30000."
);
"The number of records per request.
By d
efault is 30000."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-t, --tables=NUMBER"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-t, --tables=NUMBER"
,
"
\t\t
"
,
"The number of tables.
D
efault is 10000."
);
"The number of tables.
By d
efault is 10000."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-n, --records=NUMBER"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-n, --records=NUMBER"
,
"
\t\t
"
,
"The number of records per table.
D
efault is 10000."
);
"The number of records per table.
By d
efault is 10000."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-M, --random"
,
"
\t\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-M, --random"
,
"
\t\t\t
"
,
"The value of records generated are totally random."
);
"The value of records generated are totally random."
);
printf
(
"%s
\n
"
,
"
\t\t\t\t
The default is
to simulate power equipment scenario."
);
printf
(
"%s
\n
"
,
"
\t\t\t\t
By default
to simulate power equipment scenario."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-x, --aggr-func"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-x, --aggr-func"
,
"
\t\t
"
,
"Test aggregation funtions after insertion."
);
"Test aggregation fun
c
tions after insertion."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-y, --answer-yes"
,
"
\t\t
"
,
"
Default i
nput yes for prompt."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-y, --answer-yes"
,
"
\t\t
"
,
"
I
nput yes for prompt."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-O, --disorder=NUMBER"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-O, --disorder=NUMBER"
,
"
\t\t
"
,
"Insert order mode--0: In order, 1 ~ 50: disorder ratio.
D
efault is in order."
);
"Insert order mode--0: In order, 1 ~ 50: disorder ratio.
By d
efault is in order."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-R, --disorder-range=NUMBER"
,
"
\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-R, --disorder-range=NUMBER"
,
"
\t
"
,
"Out of order data's range
, ms,
default is 1000."
);
"Out of order data's range
. Unit is ms. By
default is 1000."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-g, --debug"
,
"
\t\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-g, --debug"
,
"
\t\t\t
"
,
"Print debug info."
);
"Print debug info."
);
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-?, --help
\t
"
,
"
\t\t
"
,
printf
(
"%s%s%s%s
\n
"
,
indent
,
"-?, --help
\t
"
,
"
\t\t
"
,
...
@@ -2433,7 +2434,7 @@ static int printfInsertMeta() {
...
@@ -2433,7 +2434,7 @@ static int printfInsertMeta() {
SHOW_PARSE_RESULT_START
();
SHOW_PARSE_RESULT_START
();
if
(
g_args
.
demo_mode
)
{
if
(
g_args
.
demo_mode
)
{
printf
(
"
\n
taosdemo is simulating data generated by power equipment
s
monitoring...
\n\n
"
);
printf
(
"
\n
taosdemo is simulating data generated by power equipment monitoring...
\n\n
"
);
}
else
{
}
else
{
printf
(
"
\n
taosdemo is simulating random data as you request..
\n\n
"
);
printf
(
"
\n
taosdemo is simulating random data as you request..
\n\n
"
);
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录