add influxdbTestWriteLoop.sh
This commit is contained in:
parent
f2bf418725
commit
aa33984c28
|
@ -4,7 +4,7 @@ DATA_DIR=/mnt/root/testdata
|
||||||
NUM_LOOP=1
|
NUM_LOOP=1
|
||||||
NUM_OF_FILES=100
|
NUM_OF_FILES=100
|
||||||
|
|
||||||
rowsPerRequest=(1 100 500 1000 2000)
|
rowsPerRequest=(1 100 1000 10000 20000 50000 100000)
|
||||||
|
|
||||||
function printTo {
|
function printTo {
|
||||||
if $verbose ; then
|
if $verbose ; then
|
||||||
|
@ -13,17 +13,21 @@ function printTo {
|
||||||
}
|
}
|
||||||
|
|
||||||
function runTest {
|
function runTest {
|
||||||
printf "R/R, "
|
declare -A avgRPR
|
||||||
|
|
||||||
|
for r in ${!rowsPerRequest[@]}; do
|
||||||
for c in `seq 1 $clients`; do
|
for c in `seq 1 $clients`; do
|
||||||
if [ "$c" == "1" ]; then
|
avgRPR[$r, $c]=0
|
||||||
printf "$c client, "
|
done
|
||||||
else
|
|
||||||
printf "$c clients, "
|
|
||||||
fi
|
|
||||||
done
|
done
|
||||||
printf "\n"
|
|
||||||
|
|
||||||
for r in ${rowsPerRequest[@]}; do
|
for r in ${rowsPerRequest[@]}; do
|
||||||
|
if [ "$r" == "1" ] || [ "$r" == "100" ] || [ "$r" == "1000" ]; then
|
||||||
|
NUM_OF_FILES=$clients
|
||||||
|
else
|
||||||
|
NUM_OF_FILES=100
|
||||||
|
fi
|
||||||
|
|
||||||
printf "$r, "
|
printf "$r, "
|
||||||
for c in `seq 1 $clients`; do
|
for c in `seq 1 $clients`; do
|
||||||
totalRPR=0
|
totalRPR=0
|
||||||
|
@ -39,13 +43,30 @@ function runTest {
|
||||||
-numOfFiles $NUM_OF_FILES \
|
-numOfFiles $NUM_OF_FILES \
|
||||||
-writeClients $c \
|
-writeClients $c \
|
||||||
-rowsPerRequest $r 2>&1 \
|
-rowsPerRequest $r 2>&1 \
|
||||||
| tee $OUTPUT_FILE
|
> $OUTPUT_FILE
|
||||||
RPR=`cat $OUTPUT_FILE | grep speed | awk '{print $(NF-1)}'`
|
RPR=`cat $OUTPUT_FILE | grep speed | awk '{print $(NF-1)}'`
|
||||||
totalRPR=`echo "scale=4; $totalRPR + $RPR" | bc`
|
totalRPR=`echo "scale=4; $totalRPR + $RPR" | bc`
|
||||||
printTo "rows:$r, clients:$c, i:$i RPR:$RPR"
|
printTo "rows:$r, clients:$c, i:$i RPR:$RPR"
|
||||||
done
|
done
|
||||||
avgRPR=`echo "scale=4; $totalRPR / $NUM_LOOP" | bc`
|
avgRPR[$r,$c]=`echo "scale=4; $totalRPR / $NUM_LOOP" | bc`
|
||||||
printf "$avgRPR, "
|
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
|
done
|
||||||
printf "\n"
|
printf "\n"
|
||||||
done
|
done
|
||||||
|
|
Loading…
Reference in New Issue