OPS-10

VERSION

@@ -1 +1 @@
-1.9.9.F2,docker build imagages script fix
+2.0.7,OPS-10

build/docker_images_builder.sh

@@ -19,7 +19,7 @@ fi
 RegistryService=cloud21.cvtt.vpn:5500
 RegistryProtocol=http
 
-ConfigUrl=http://cloud23.cvtt.vpn:6789/admin/docker_images
+ConfigUrl=http://cloud16.cvtt.vpn:6789/admin/docker_images
 
 
 ReleaseHost="cloud21.cvtt.vpn"

cronjobs/save_cronjobs.sh

@@ -9,7 +9,7 @@ get_user_hosts() {
     local User=${1}
     local Domain=${2}
 
-    Cmd="curl -s http://cloud23.cvtt.vpn:6789/admin/cvtt_hosts"
+    Cmd="curl -s http://cloud16.cvtt.vpn:6789/admin/cvtt_hosts"
     Cmd="${Cmd} | ${HOME}/bin/hjson -j"
     Cmd="${Cmd} | jq -r"
     Cmd="${Cmd} --arg domain \"${Domain}\""

docker/market_data/hist/__DEPRECATED__/alpaca_md_day.sh

@@ -17,7 +17,7 @@ is_container_running() {
     fi
 }
 
-export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+export CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
 
 is_business_day() {
     dt=${1}

docker/market_data/hist/crypto_md_day.sh

@@ -1,22 +1,39 @@
 #!/bin/bash
+usage() {
+    echo "Usage: ${0} <docker_image_tag> <host> [<date>]"
+    exit 1
+}
 
-host=${1}
-date=${2}
-
+# ------- Settings
 DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/crypto_md_day
+# ------- Settings
+
+ImageTag=${1}
+host=${2}
+date=${3}
+
+if [ -z ${ImageTag} ] ; then
+    usage
+fi
+
+if [ -z ${host} ] ; then
+    usage
+fi
 
 if [ -z ${date} ] ; then
     date=$(date -d "yesterday" +%Y%m%d)
 fi
 
+DockerImage=${DockerRegistry}/crypto_md_day:${ImageTag}
+
+
 Cmd="docker run"
 Cmd+=" --pull=always"
 Cmd+=" --network=host"
 Cmd+=" --name=crypto_md_day.${host}.${date}"
 Cmd+=" --rm"
 Cmd+=" --volume=${HOME}/.creds:/.creds"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
 Cmd+=" ${DockerImage}"
 Cmd+=" -h ${host}"
 Cmd+=" -d ${date}"

docker/market_data/hist/load_alpaca_hbar.sh

@@ -1,7 +1,7 @@
 #!/bin/bash
 
 usage() {
-  echo "Usage: $0  -N <num_symbols> [-L <LogDir>] [-d <YYYYMMDD Date>]"
+  echo "Usage: $0  -N <num_symbols> [-L <LogDir>] [-d <YYYYMMDD Date>] [-t <docker_image_tag>]"
   exit 1
 }
 
@@ -15,7 +15,7 @@ is_container_running() {
     fi
 }
 
-export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+export CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
 
 is_business_day() {
     dt=${1}
@@ -45,12 +45,12 @@ export -f get_prev_business_day
 
 # ----- Settings
 DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/alpaca_hbar #:latest
 ContainerName=alpaca_hbar
 LogDir=/home/cvtt/prod/logs
+ImageTag=0.1.7
 # ----- Settings
 
-while getopts ":d:N:L:" opt; do
+while getopts ":d:N:L:t:" opt; do
   case ${opt} in
     d )
       date_to_load=$OPTARG
@@ -61,6 +61,9 @@ while getopts ":d:N:L:" opt; do
     L )
       LogDir=$OPTARG
       ;;
+    t )
+      ImageTag=$OPTARG
+      ;;
     \? )
       echo "Invalid option: -$OPTARG" >&2
       usage
@@ -72,6 +75,9 @@ while getopts ":d:N:L:" opt; do
   esac
 done
 
+DockerImage=${DockerRegistry}/alpaca_hbar:${ImageTag} #:latest
+
+
 if is_container_running "$ContainerName"; then
     echo "Container ${ContainerName} is already running."
     exit 3
@@ -92,7 +98,7 @@ Cmd+=" --name=${ContainerName}"
 Cmd+=" --rm"
 Cmd+=" --volume=${LogDir}:/logs"
 Cmd+=" --volume=${HOME}/.creds:/.creds"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
 Cmd+=" ${DockerImage}"
 Cmd+=" -d ${date_to_load}"
 if [ -n "${NumSymbols}" ]; then

docker/market_data/hist/load_alpaca_qat.sh

@@ -1,7 +1,7 @@
 #!/bin/bash
 
 usage() {
-  echo "Usage: $0  -S <symbols> [-L <LogDir>] [-d <YYYYMMDD Date>]"
+  echo "Usage: $0  -S <symbols> [-L <LogDir>] [-d <YYYYMMDD Date>] [-t <docker_image_tag>]"
   exit 1
 }
 
@@ -15,7 +15,7 @@ is_container_running() {
     fi
 }
 
-export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+export CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
 
 is_business_day() {
     dt=${1}
@@ -45,12 +45,12 @@ export -f get_prev_business_day
 
 # ----- Settings
 DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/alpaca_qat #:latest
 ContainerName=alpaca_qat
 LogDir=/home/cvtt/prod/logs
+ImageTag=0.1.7
 # ----- Settings
 
-while getopts ":d:S:L:" opt; do
+while getopts ":d:S:L:t:" opt; do
   case ${opt} in
     d )
       date_to_load=$OPTARG
@@ -61,6 +61,9 @@ while getopts ":d:S:L:" opt; do
     L )
       LogDir=$OPTARG
       ;;
+    t )
+      ImageTag=$OPTARG
+      ;;
     \? )
       echo "Invalid option: -$OPTARG" >&2
       usage
@@ -82,6 +85,8 @@ if is_container_running "$ContainerName"; then
     exit 3
 fi
 
+DockerImage=${DockerRegistry}/alpaca_qat:${ImageTag} #:latest
+
 if [ -z "${date_to_load}" ]; then
     echo "date_to_load is empty"
     date_to_load=$(get_prev_business_day $(date  -d "yesterday" '+%Y-%m-%d'))
@@ -97,7 +102,7 @@ Cmd+=" --name=${ContainerName}"
 Cmd+=" --rm"
 Cmd+=" --volume=${LogDir}:/logs"
 Cmd+=" --volume=${HOME}/.creds:/.creds"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
 Cmd+=" ${DockerImage}"
 Cmd+=" -d ${date_to_load}"
 Cmd+=" -S ${Symbols}"

docker/market_data/recorder/md_recorder.sh

@@ -3,7 +3,7 @@
 ValidJobs=('BNBFUT_CLD21' 'BNBSPOT_CLD21' 'COINBASE_CLD21' 'BNBFUT_CVTTDATA' 'BNBSPOT_CVTTDATA' 'COINBASE_CVTTDATA')
 # runs on host to start container
 usage() {
-  echo "Usage: $0 <job_name; one of (${ValidJobs[@]})>"
+  echo "Usage: $0 <job_name; one of (${ValidJobs[@]})> [image_tag]"
   exit 1
 }
 
@@ -35,6 +35,12 @@ if  ! is_valid "${job}"; then
     usage
 fi
 
+ImageTag=${2}
+if [ "${ImageTag}" == "" ] ; then
+    ImageTag="1.6.9"
+fi
+
+DockerImage=cloud21.cvtt.vpn:5500/md_recorder:${ImageTag}
 ContainerName="md_recorder.${job}"
 
 if is_container_running "$ContainerName"; then
@@ -47,13 +53,13 @@ Cmd="docker run"
 Cmd+=" -d"
 Cmd+=" --rm"
 Cmd+=" --network=host"
-Cmd+=" --pull=always"
+# Cmd+=" --pull=always"
 Cmd+=" --name=${ContainerName}"
 Cmd+=" -v /home/cvtt/.creds:/.creds"
 Cmd+=" -v /home/cvtt/prod/data:/app/data"
 Cmd+=" -v /home/cvtt/prod/logs:/logs"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
-Cmd+=" cloud21.cvtt.vpn:5500/md_recorder:latest"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
+Cmd+=" ${DockerImage}"
 Cmd+=" ${job}"
 
 echo ${Cmd}

docker/market_data/recorder/md_recorder_monitor.sh

@@ -52,7 +52,7 @@ Cmd+=" --pull=always"
 Cmd+=" --name=${ContainerName}"
 Cmd+=" -v /home/cvtt/.creds:/.creds"
 Cmd+=" -v /home/cvtt/prod/logs:/logs"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
 Cmd+=" cloud21.cvtt.vpn:5500/md_recorder_monitor:latest"
 Cmd+=" ${Instance} ${AdminPort}"
 

docker/research/crypto_exch_stats.sh

@@ -8,7 +8,7 @@ Cmd+=" --network=host"
 Cmd+=" --name=crypto_exch_stats"
 Cmd+=" --volume=${HOME}/prod/data:/app/data"
 Cmd+=" --volume=${HOME}/prod/logs:/logs"
-Cmd+=" -e CONFIG_SERVICE=cloud23.cvtt.vpn:6789"
+Cmd+=" -e CONFIG_SERVICE=cloud16.cvtt.vpn:6789"
 Cmd+=" cloud21.cvtt.vpn:5500/crypto_exch_stats:latest"
 
 echo ${Cmd}

research/prepare_eqt_simdata.sh

@@ -15,7 +15,7 @@ is_business_day() {
     dt=${1}
     date=$(date -d "${dt}" +"%Y-%m-%d")
 
-    CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+    CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
     URL="${CalendarURL}&start=${date}&end=${date}"
     open_time=$(curl -s "${URL}" | jq '.[] | .open_time')
     if [ -n  "${open_time}" ]; then

scripts/__DEPRECATED__/archive_yesterday_md.sh

@@ -31,7 +31,7 @@ echo "Schemas=${Schemas}"
 Cmd=
 Cmd="${Python}"
 Cmd="${Cmd} ${RootDir}/cvttpy/research/utils/archive_ts_md.py"
-Cmd="${Cmd} --config=http://cloud23.cvtt.vpn:6789/apps/md_recorder"
+Cmd="${Cmd} --config=http://cloud16.cvtt.vpn:6789/apps/md_recorder"
 Cmd="${Cmd} --db_credentials_key=${CredKey}"
 Cmd="${Cmd} --date=${yesterday}"
 Cmd="${Cmd} --schemas=${Schemas}"

scripts/healthcheck/cvtt_ts_status_check.sh

@@ -3,7 +3,7 @@
 usage() {
     echo -n "Usage: ${0}"
     echo -n " [-c <config (dflt: apps/cvtt_eqt_alpaca)>]"
-    echo -n " [-s <config_serverice (dflt: http://cloud23.cvtt.vpn:6789)>]"
+    echo -n " [-s <config_serverice (dflt: http://cloud16.cvtt.vpn:6789)>]"
     echo -n " [-N <name (dflt: ALPACA-SNDBX)>]"
     echo
     exit 1
@@ -23,7 +23,7 @@ export PYTHONPATH=${RootDir}
 StatusChannel=Status-CVTT
 AlertChannel=Alerts-CVTT
 Sender=${RootDir}/ops/utils/send_mmost.sh
-ConfigService=http://cloud23.cvtt.vpn:6789
+ConfigService=http://cloud16.cvtt.vpn:6789
 Config=apps/cvtt_eqt_alpaca
 Name="ALPACA-SNDBX"
 

scripts/healthcheck/hosts_check.sh

@@ -13,7 +13,7 @@ RootDir="${HOME}/prod"
 
 AlertChannel=Alerts-CVTT
 Sender=${RootDir}/ops/utils/send_mmost.sh
-ConfigUrl=http://cloud23.cvtt.vpn:6789/admin/cvtt_hosts
+ConfigUrl=http://cloud16.cvtt.vpn:6789/admin/cvtt_hosts
 
 HOSTS_CONFIG=$(curl -s ${ConfigUrl} | ${HOME}/bin/hjson -j)
 

scripts/healthcheck/services_check.sh

@@ -12,7 +12,7 @@ RootDir="${HOME}/prod"
 
 AlertChannel=Alerts-CVTT
 Sender=${RootDir}/ops/utils/send_mmost.sh
-ConfigUrl=http://cloud23.cvtt.vpn:6789/admin/cvtt_services
+ConfigUrl=http://cloud16.cvtt.vpn:6789/admin/cvtt_services
 
 SERVICES_CONFIG=$(curl -s ${ConfigUrl} | ${HOME}/bin/hjson -j)
 

scripts/healthcheck/storage_health_check.sh

@@ -18,7 +18,7 @@ get_user_hosts() {
     local User=${1}
     local Domain=${2}
 
-    Cmd="curl -s http://cloud23.cvtt.vpn:6789/admin/cvtt_hosts"
+    Cmd="curl -s http://cloud16.cvtt.vpn:6789/admin/cvtt_hosts"
     Cmd+=" | ${HOME}/bin/hjson -j"
     Cmd+=" | jq -r"
     Cmd+=" --arg domain \"${Domain}\""

scripts/mkt_data/alpaca_hist_md/alpaca_md.sh

@@ -4,7 +4,7 @@ Start=${1}
 NumJobs=${2}
 InstListFile=${3}
 
-export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+export CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
 
 is_business_day() {
     dt=${1}
@@ -46,7 +46,7 @@ echo "Start=${Start} End=${End} NumJobs=${NumJobs}"
 
 export PYTHONPATH=/home/cvtt/prod
 export Python=/home/cvtt/.pyenv/python3.12-venv/bin/python3
-export Config=http://cloud23.cvtt.vpn:6789/apps/minimal_md
+export Config=http://cloud16.cvtt.vpn:6789/apps/minimal_md
 export PyScript=/home/cvtt/prod/cvttpy/exchanges/alpaca/hist_md/hist_md_bars.py
 
 export OutputDir=/home/cvtt/prod/archive/md_archive/equity/alpaca_md # Local

scripts/mkt_data/alpaca_hist_md/load_rel_liq.sh

@@ -5,7 +5,7 @@ export PYTHONPATH=${HOME}/prod
 Python=${HOME}/.pyenv/python3.12-venv/bin/python3
 Script=${HOME}/prod/cvttpy/exchanges/alpaca/hist_md/rl_calc_loader.py
 DbFile=${HOME}/prod/data/rel_liquidity.db
-Config=http://cloud23.cvtt.vpn:6789/apps/minimal_md_eqt
+Config=http://cloud16.cvtt.vpn:6789/apps/minimal_md_eqt
 
 Cmd="${Python}"
 Cmd="${Cmd} ${Script}"

scripts/mkt_data/alpaca_hist_md/run_alpaca_hist_md.sh

@@ -3,7 +3,7 @@
 is_business_day() {
     dt=${1}
 
-    CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+    CalendarURL=https://trading-calendar.cvtt.net/api/v1/markets/hours?mic=XNYS
     open_time=$(curl -s "${CalendarURL}&start=${dt}&end=${dt}" | jq '.[] | .open_time')
     if [ -n  "${open_time}" ]; then
         return 0

scripts/mkt_data/checklists/crypto_md_chcklst.sh

@@ -27,8 +27,10 @@ run_checklist() {
     Commands=(
         ["hs01:cloud21"]="ssh cvtt@hs01.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cloud21/${yr}/${mn} | tail -5"
         ["hs01:cvttdata"]="ssh cvtt@hs01.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cvttdata/${yr}/${mn} | tail -5"
-        ["cloud21:cloud21"]="ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/crypto/cloud21/${yr}/${mn} | tail -5"
-        ["cloud21:cvttdata"]="ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/crypto/cvttdata/${yr}/${mn} | tail -5"
+        ["hs01:sim"]="ssh cvtt@hs01.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/sim/ | tail -5"
+        ["cloud21:cloud21"]="ssh cvtt@cloud21.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cloud21/${yr}/${mn} | tail -5"
+        ["cloud21:cvttdata"]="ssh cvtt@cloud21.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cvttdata/${yr}/${mn} | tail -5"
+        ["cloud21:sim"]="ssh cvtt@cloud21.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/sim | tail -5"
         ["gpushnik"]="ssh oleg@gpushnik.cvtt.vpn 'ls -l /opt/jupyter_gpu/data/crypto_md | tail -10'"
     )
 

scripts/mkt_data/checklists/eqty_md_chcklst.sh

@@ -29,12 +29,14 @@ run_checklist() {
         Commands["hs01"]+="ssh cvtt@hs01.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/${yr}/${sym} | tail -3; "
     done
     Commands["hs01"]+="echo"
+    Commands["hs01:sim"]="ssh cvtt@hs01.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/sim | tail -5" 
 
     Commands["cloud21"]=""
     for sym in ${CheckSymbols}; do
-        Commands["cloud21"]+="ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/equity/alpaca_md/${yr}/${sym} | tail -3; "
+        Commands["cloud21"]+="ssh cvtt@cloud21.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/${yr}/${sym} | tail -3; "
     done
     Commands["cloud21"]+="echo"
+    Commands["cloud21:sim"]="ssh cvtt@cloud21.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/sim | tail -5" 
 
     Commands["gpushnik"]="ssh oleg@gpushnik.cvtt.vpn 'ls -l /opt/jupyter_gpu/data/eqty_md | tail -10'"
 
@@ -46,6 +48,13 @@ run_checklist() {
     done
 }
 
+tmpfile=$(mktemp)
+function cleanup {
+    cd ${HOME}
+    rm -f ${tmpfile}
+}
+trap cleanup EXIT
+
 # run_checklist
 
 tmpfile=$(mktemp)

scripts/mkt_data/crypto_hist_md/exchanges_trading_stats.sh

@@ -4,7 +4,7 @@ export PYTHONPATH=/home/cvtt/prod
 
 Cmd="/home/cvtt/.pyenv/python3.12-venv/bin/python3"
 Cmd="${Cmd} /home/cvtt/prod/cvttpy/apps/research/exchange_trading_stats.py"
-Cmd="${Cmd} --config=http://cloud23.cvtt.vpn:6789/apps/tests/listen_market_data"
+Cmd="${Cmd} --config=http://cloud16.cvtt.vpn:6789/apps/tests/listen_market_data"
 Cmd="${Cmd} --active_exchanges=OKX,GEMINI,BITSTAMP,COINBASE_AT,BNBSPOT,KRAKEN"
 Cmd="${Cmd} --instruments=OKX:PAIR-BTC-USDT,GEMINI:PAIR-BTC-USD,BITSTAMP:PAIR-BTC-USD,COINBASE:PAIR-BTC-USD,BNBSPOT:PAIR-BTC-USDT,KRAKEN:PAIR-BTC-USD"
 Cmd="${Cmd} --db_file=/home/cvtt/prod/data/exchange_trading_stats.db"