161 lines
3.3 KiB
Bash
Executable File
161 lines
3.3 KiB
Bash
Executable File
#!/bin/bash
|
|
Script="${0} ${*}"
|
|
|
|
function usage {
|
|
echo "Usage: ${0} --inst_set=<setting #> [--restart] [--stop] [--once] [--sleep_sec=<num_seconds>]"
|
|
exit 1
|
|
}
|
|
|
|
for arg in "${@}"
|
|
do
|
|
case ${arg} in
|
|
--restart)
|
|
Restart=Y
|
|
shift
|
|
;;
|
|
--stop)
|
|
Stop="Y"
|
|
shift
|
|
;;
|
|
--once)
|
|
Once="Y"
|
|
shift
|
|
;;
|
|
--inst_set=*)
|
|
InstrSet="${arg#*=}"
|
|
shift
|
|
;;
|
|
--sleep_sec=*)
|
|
SleepSec="${arg#*=}"
|
|
shift
|
|
;;
|
|
-*|--*)
|
|
usage
|
|
;;
|
|
*)
|
|
;;
|
|
esac
|
|
done
|
|
|
|
|
|
declare -A InstrSetInstrs
|
|
InstrSetInstrs[1]=PAIR-BTC-USD
|
|
InstrSetInstrs[2]=PAIR-ETH-USD
|
|
InstrSetInstrs[3]=PAIR-DOGE-USD,PAIR-AVAX-USD,PAIR-USDT-USD,PAIR-MATIC-USD
|
|
InstrSetInstrs[4]=PAIR-BCH-USD,PAIR-LTC-USD,PAIR-UNI-USD,PAIR-AAVE-USD,PAIR-LINK-USD,PAIR-SOL-USD
|
|
|
|
|
|
if [ "${InstrSet}" == "" ]
|
|
then
|
|
usage
|
|
fi
|
|
|
|
if [ "${SleepSec}" == "" ]
|
|
then
|
|
SleepSec=3
|
|
fi
|
|
|
|
Instruments=${InstrSetInstrs[${InstrSet}]}
|
|
if [ "${Instruments}" == "" ]
|
|
then
|
|
echo "Unrecognized instrument settings: ${InstrSet}"
|
|
usage
|
|
fi
|
|
|
|
# -------------------- S e t t i n g s
|
|
RootDir=/home/cvtt/prod
|
|
ConfigFile="${RootDir}/md_recorder/config/md_recorder.cfg"
|
|
|
|
AdminPort="720${InstrSet}"
|
|
Exchange=COINBASE-MD
|
|
CredKey=TSDB_COINBS_1
|
|
Name=md_recorder_coinbase
|
|
# -------------------- S e t t i n g s
|
|
|
|
LogFile="${RootDir}/logs/$(date '+%Y%m%d_%H%M%S').${name}_${InstrSet}.log"
|
|
|
|
source ${HOME}/.pyenv/python3.10-venv/bin/activate
|
|
export PYTHONPATH=${RootDir}
|
|
|
|
Cmd="nohup"
|
|
Cmd="${Cmd} python3"
|
|
Cmd="${Cmd} ${RootDir}/cvttpy/apps/md_recorder.py"
|
|
Cmd="${Cmd} --config=${ConfigFile}"
|
|
Cmd="${Cmd} --active_exchanges=${Exchange}"
|
|
Cmd="${Cmd} --instruments=${Instruments}"
|
|
Cmd="${Cmd} --admin_port=${AdminPort}"
|
|
Cmd="${Cmd} --log_level=INFO"
|
|
Cmd="${Cmd} --log_file=${LogFile}"
|
|
Cmd="${Cmd} --credentials_key=TSDB_COINBS_1"
|
|
Cmd="${Cmd} &"
|
|
|
|
function start_it {
|
|
echo ${Cmd}
|
|
eval ${Cmd} &
|
|
sleep 10
|
|
}
|
|
|
|
|
|
function check_it {
|
|
|
|
if !(timeout 3 curl -s localhost:${AdminPort}/ping > /dev/null)
|
|
then
|
|
echo "${Script} doesn't respond. restarting..."
|
|
pids=$(ps -ef | grep "admin_port=${AdminPort}" | grep -v grep | tr -s ' ' |cut -d' ' -f2)
|
|
echo pids=${pids}
|
|
if [ "${pids}" != "" ]
|
|
then
|
|
kill -9 ${pids}
|
|
fi
|
|
start_it
|
|
fi
|
|
}
|
|
|
|
function kill_it {
|
|
pids=$(ps -ef |grep "inst_set=${InstrSet}" |grep $(basename ${0}) |grep -v ${$} |grep -v grep |tr -s ' ' |cut -d' ' -f2)
|
|
|
|
if [ "${pids}" != "" ]
|
|
then
|
|
echo "Killing ${pids} ..."
|
|
kill -9 ${pids}
|
|
fi
|
|
while (timeout 3 curl -s localhost:${AdminPort}/ping > /dev/null)
|
|
do
|
|
echo "Shutting down localhost:${AdminPort}/shutdown ..."
|
|
timeout 5 curl -s localhost:${AdminPort}/shutdown
|
|
|
|
pids=$(ps -ef | grep "admin_port=${AdminPort}" | grep -v grep | tr -s ' ' |cut -d' ' -f2)
|
|
echo pids=${pids}
|
|
if [ "${pids}" != "" ]
|
|
then
|
|
kill -9 ${pids}
|
|
fi
|
|
done
|
|
}
|
|
|
|
if [ "${Stop}" == "Y" ] ; then
|
|
kill_it
|
|
exit 0
|
|
fi
|
|
|
|
if [ "${Once}" == "Y" ] ; then
|
|
start_it
|
|
exit 0
|
|
fi
|
|
|
|
|
|
if [ "${Restart}" == "Y" ]
|
|
then
|
|
kill_it
|
|
fi
|
|
|
|
start_it
|
|
while true
|
|
do
|
|
check_it
|
|
echo "${Script} is checked" | /usr/bin/ts '[%Y-%m-%d %H:%M:%S]'
|
|
sleep ${SleepSec}
|
|
done
|
|
|
|
|