add opentsdbTestWriteLoop.sh
This commit is contained in:
parent
09dd9aabb9
commit
035a9ab943
|
@ -17,7 +17,7 @@ function runTest {
|
||||||
|
|
||||||
for r in ${!rowsPerRequest[@]}; do
|
for r in ${!rowsPerRequest[@]}; do
|
||||||
for c in `seq 1 $clients`; do
|
for c in `seq 1 $clients`; do
|
||||||
avgRPR[$r, $c]=0
|
avgRPR[$r,$c]=0
|
||||||
done
|
done
|
||||||
done
|
done
|
||||||
|
|
||||||
|
@ -46,7 +46,6 @@ function runTest {
|
||||||
avgRPR[$r,$c]=`echo "scale=4; $totalRPR / $NUM_LOOP" | bc`
|
avgRPR[$r,$c]=`echo "scale=4; $totalRPR / $NUM_LOOP" | bc`
|
||||||
printTo "r:$r c:$c avgRPR:${avgRPR[$r,$c]}"
|
printTo "r:$r c:$c avgRPR:${avgRPR[$r,$c]}"
|
||||||
done
|
done
|
||||||
|
|
||||||
done
|
done
|
||||||
|
|
||||||
printf "R/R, "
|
printf "R/R, "
|
||||||
|
@ -79,9 +78,14 @@ while : ; do
|
||||||
verbose=true
|
verbose=true
|
||||||
shift ;;
|
shift ;;
|
||||||
|
|
||||||
|
-n)
|
||||||
|
NUM_LOOP=$2
|
||||||
|
shift 2;;
|
||||||
|
|
||||||
-c)
|
-c)
|
||||||
clients=$2
|
clients=$2
|
||||||
shift 2;;
|
shift 2;;
|
||||||
|
|
||||||
*)
|
*)
|
||||||
break ;;
|
break ;;
|
||||||
esac
|
esac
|
||||||
|
|
|
@ -0,0 +1,99 @@
|
||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
DATA_DIR=/mnt/root/testdata
|
||||||
|
NUM_LOOP=1
|
||||||
|
NUM_OF_FILES=100
|
||||||
|
|
||||||
|
rowsPerRequest=(1 10 50 100 500 1000 2000)
|
||||||
|
|
||||||
|
function printTo {
|
||||||
|
if $verbose ; then
|
||||||
|
echo $1
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
function runTest {
|
||||||
|
declare -A avgRPR
|
||||||
|
|
||||||
|
for r in ${!rowsPerRequest[@]}; do
|
||||||
|
for c in `seq 1 $clients`; do
|
||||||
|
avgRPR[$r, $c]=0
|
||||||
|
done
|
||||||
|
done
|
||||||
|
|
||||||
|
for r in ${!rowsPerRequest[@]}; do
|
||||||
|
for c in `seq 1 $clients`; do
|
||||||
|
totalRPR=0
|
||||||
|
OUT_FILE=opentsdbWrite-rows${rowsPerRequest[$r]}-clients$c.out
|
||||||
|
for i in `seq 1 $NUM_LOOP`; do
|
||||||
|
printTo "loop i:$i java -jar \
|
||||||
|
$TSDBTEST_DIR/opentsdbtest/target/opentsdbtest-1.0-SNAPSHOT-jar-with-dependencies.jar \
|
||||||
|
-dataDir $DATA_DIR \
|
||||||
|
-numOfFiles $NUM_OF_FILES \
|
||||||
|
-writeClients $c \
|
||||||
|
-rowsPerRequest $r"
|
||||||
|
java -jar \
|
||||||
|
$TSDBTEST_DIR/opentsdbtest/target/opentsdbtest-1.0-SNAPSHOT-jar-with-dependencies.jar \
|
||||||
|
-dataDir $DATA_DIR \
|
||||||
|
-numOfFiles $NUM_OF_FILES \
|
||||||
|
-writeClients $c \
|
||||||
|
-rowsPerRequest ${rowsPerRequest[$r]} \
|
||||||
|
2>&1 | tee $OUT_FILE
|
||||||
|
RPR=`cat $OUT_FILE | grep speed | awk '{print $(NF-1)}'`
|
||||||
|
totalRPR=`echo "scale=4; $totalRPR + $RPR" | bc`
|
||||||
|
printTo "r:$r rows:${rowsPerRequest[$r]}, clients:$c, i:$i RPR:$RPR"
|
||||||
|
done
|
||||||
|
avgRPR[$r,$c]=`echo "scale=4; $totalRPR / $NUM_LOOP" | bc`
|
||||||
|
printTo "r:$r c:$c avgRPR:${avgRPR[$r, $c]}"
|
||||||
|
done
|
||||||
|
done
|
||||||
|
|
||||||
|
printf "R/R, "
|
||||||
|
for c in `seq 1 $clients`; do
|
||||||
|
if [ "$c" == "1" ]; then
|
||||||
|
printf "$c client, "
|
||||||
|
else
|
||||||
|
printf "$c clients, "
|
||||||
|
fi
|
||||||
|
done
|
||||||
|
printf "\n"
|
||||||
|
|
||||||
|
for r in ${!rowsPerRequest[@]}; do
|
||||||
|
printf "${rowsPerRequest[$r]}, "
|
||||||
|
for c in `seq 1 $clients`; do
|
||||||
|
printf "${avgRPR[$r,$c]}, "
|
||||||
|
done
|
||||||
|
printf "\n"
|
||||||
|
done
|
||||||
|
}
|
||||||
|
|
||||||
|
################ Main ################
|
||||||
|
|
||||||
|
verbose=false
|
||||||
|
clients=1
|
||||||
|
|
||||||
|
while : ; do
|
||||||
|
case $1 in
|
||||||
|
-v)
|
||||||
|
verbose=true
|
||||||
|
shift ;;
|
||||||
|
|
||||||
|
-n)
|
||||||
|
NUM_LOOP=$2
|
||||||
|
shift 2;;
|
||||||
|
|
||||||
|
-c)
|
||||||
|
clients=$2
|
||||||
|
shift 2;;
|
||||||
|
|
||||||
|
*)
|
||||||
|
break ;;
|
||||||
|
esac
|
||||||
|
done
|
||||||
|
|
||||||
|
WORK_DIR=/mnt/root/TDengine
|
||||||
|
TSDBTEST_DIR=$WORK_DIR/tests/comparisonTest/opentsdb
|
||||||
|
|
||||||
|
runTest
|
||||||
|
|
||||||
|
printTo "Test done!"
|
|
@ -1,7 +1,7 @@
|
||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
|
|
||||||
DATA_DIR=/mnt/root/testdata
|
DATA_DIR=/mnt/root/testdata
|
||||||
NUM_LOOP=5
|
NUM_LOOP=1
|
||||||
NUM_OF_FILES=100
|
NUM_OF_FILES=100
|
||||||
|
|
||||||
rowsPerRequest=(1 100 500 1000 2000)
|
rowsPerRequest=(1 100 500 1000 2000)
|
||||||
|
@ -37,7 +37,7 @@ function runTest {
|
||||||
-rowsPerRequest $r"
|
-rowsPerRequest $r"
|
||||||
RPR=`$TDTEST_DIR/tdengineTest \
|
RPR=`$TDTEST_DIR/tdengineTest \
|
||||||
-dataDir $DATA_DIR \
|
-dataDir $DATA_DIR \
|
||||||
-numOfFiles 1 \
|
-numOfFiles $NUM_OF_FILES \
|
||||||
-w -clients $c \
|
-w -clients $c \
|
||||||
-rowsPerRequest $r \
|
-rowsPerRequest $r \
|
||||||
| grep speed | awk '{print $(NF-1)}'`
|
| grep speed | awk '{print $(NF-1)}'`
|
||||||
|
@ -80,6 +80,10 @@ while : ; do
|
||||||
verbose=true
|
verbose=true
|
||||||
shift ;;
|
shift ;;
|
||||||
|
|
||||||
|
-n)
|
||||||
|
NUM_LOOP=$2
|
||||||
|
shift 2;;
|
||||||
|
|
||||||
master)
|
master)
|
||||||
master=true
|
master=true
|
||||||
develop=false
|
develop=false
|
||||||
|
@ -93,18 +97,19 @@ while : ; do
|
||||||
-c)
|
-c)
|
||||||
clients=$2
|
clients=$2
|
||||||
shift 2;;
|
shift 2;;
|
||||||
|
|
||||||
*)
|
*)
|
||||||
break ;;
|
break ;;
|
||||||
esac
|
esac
|
||||||
done
|
done
|
||||||
|
|
||||||
if $master ; then
|
if $master ; then
|
||||||
echo "Test master branch.."
|
printTo "Test master branch.."
|
||||||
cp /mnt/root/cfg/master/taos.cfg /etc/taos/taos.cfg
|
cp /mnt/root/cfg/master/taos.cfg /etc/taos/taos.cfg
|
||||||
WORK_DIR=/mnt/root/TDengine.master
|
WORK_DIR=/mnt/root/TDengine.master
|
||||||
else
|
else
|
||||||
echo "Test develop branch.."
|
printTo "Test develop branch.."
|
||||||
cp /mnt/root/cfg/10billion/taos.cfg /etc/taos/taos.cfg
|
cp /mnt/root/cfg/perftest/taos.cfg /etc/taos/taos.cfg
|
||||||
WORK_DIR=/mnt/root/TDengine
|
WORK_DIR=/mnt/root/TDengine
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
@ -113,4 +118,4 @@ TDTEST_DIR=$WORK_DIR/tests/comparisonTest/tdengine
|
||||||
|
|
||||||
runTest
|
runTest
|
||||||
|
|
||||||
echo "Test done!"
|
printTo "Test done!"
|
||||||
|
|
Loading…
Reference in New Issue