fix

doc/supervisord.conf.example

@@ -0,0 +1,61 @@
+[supervisord]
+environment=PYTHONPATH="/home/cvtt/prod"
+autostart=true
+autorestart=unexpected
+startretries=3
+logfile=/var/log/supervisor/supervisord_cvtt.log
+
+[supervisorctl]
+
+[inet_http_server]
+port = 127.0.0.1:9001
+
+[rpcinterface:supervisor]
+supervisor.rpcinterface_factory = supervisor.rpcinterface:make_main_rpcinterface
+
+[program:coinbase_rec_cvttdata]
+directory=/home/cvtt/prod
+command=/home/cvtt/.pyenv/python3.10-venv/bin/python3 -u /home/cvtt/prod/cvttpy/apps/md/md_recorder.py
+        --config=http://cloud16.cvtt.vpn:6789/apps/md_recorder
+        --active_exchanges=COINBASE_AT
+        --instruments=COINBASE:PAIR-BTC-USD,COINBASE:PAIR-ETH-USD,COINBASE:PAIR-LTC-USD,COINBASE:PAIR-XRP-USD
+        --db_credentials_key=TSDB_MD_CVTTDATA
+        --admin_port=7223
+        --log_level=INFO
+        --log_file=/home/cvtt/prod/logs/%%T.MD_REC.COINBASE.CVTTDATA.log
+autostart=true
+autorestart=true
+startretries=1
+startsecs=3
+user=cvtt
+#
+[program:bnbfut_rec_cvttdata]
+directory=/home/cvtt/prod
+command=/home/cvtt/.pyenv/python3.10-venv/bin/python3 -u /home/cvtt/prod/cvttpy/apps/md/md_recorder.py
+        --config=http://cloud16.cvtt.vpn:6789/apps/md_recorder
+        --active_exchanges=BNBFUT
+        --instruments=BNBFUT:PERP-BTC-USDT,BNBFUT:PERP-ETH-USDT
+        --db_credentials_key=TSDB_MD_CVTTDATA
+        --admin_port=7224
+        --log_level=INFO
+        --log_file=/home/cvtt/prod/logs/%%T.MD_REC.BNBFUT.CVTTDATA.log
+autostart=true
+autorestart=true
+startretries=1
+startsecs=3
+user=cvtt
+
+[program:md_rec_monitor]
+directory=/home/cvtt/prod
+command=/home/cvtt/.pyenv/python3.10-venv/bin/python3 -u /home/cvtt/prod/cvttpy/apps/md/md_rec_monitor.py
+        --config=http://cloud16.cvtt.vpn:6789/apps/md_rec_monitor
+        --db=CVTTDATA
+        --admin_port=7225
+        --log_level=INFO
+        --log_file=/home/cvtt/prod/logs/%%T.MD_REC.MONITOR.CVTTDATA.log
+autostart=true
+autorestart=true
+startretries=1
+startsecs=3
+user=cvtt
+

docker/config_service.sh

@@ -1,14 +0,0 @@
-#!/bin/bash
-
-Cmd="docker run"
-Cmd="${Cmd} -d"
-Cmd="${Cmd} --rm"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --name=cvtt_config_service"
-Cmd="${Cmd} -p 6789:6789"
-Cmd="${Cmd} -v /home/cvtt/prod/config_service/data:/app/data"
-Cmd="${Cmd} -v /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} cloud21.cvtt.vpn:5500/config_service:latest"
-
-echo ${Cmd}
-eval ${Cmd}

docker/market_data/hist/alpaca_md_day.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-date_to_load=${1}
+date_to_load=${1} # YYYY-MM-DD
 
 DockerRegistry=cloud21.cvtt.vpn:5500
 DockerImage=${DockerRegistry}/alpaca_md_day #:latest
@@ -46,7 +46,7 @@ get_prev_business_day() {
 export -f get_prev_business_day
 
 if [ -z ${date_to_load} ] ; then
-    echo "Yesterday data has priority. Running historical container will be stopped"
+    echo "Date is not specified. Yesterday data has priority. Running historical container will be stopped"
     Cmd="docker stop ${ContainerName}"
     echo ${Cmd} && eval ${Cmd}
     Cmd="docker kill ${ContainerName}"
@@ -62,6 +62,7 @@ if [ -z ${date_to_load} ] ; then
         exit 3
     fi
 else
+    date_to_load=$(date -d ${date_to_load} '+%Y-%m-%d') #expected format
     echo "Historical run ${date_to_load}"
     if is_container_running "$ContainerName"; then
         echo "Container ${ContainerName} is already running."

docker/market_data/hist/load_alpaca_hbar.sh

@@ -0,0 +1,105 @@
+#!/bin/bash
+
+usage() {
+  echo "Usage: $0  -N <num_symbols> [-L <LogDir>] [-d <YYYYMMDD Date>]"
+  exit 1
+}
+
+is_container_running() {
+    local container_name=$1
+
+    if [ "$(docker ps --filter "name=^/${container_name}$" --filter "status=running" -q)" ]; then
+        return 0  # true
+    else
+        return 1  # false
+    fi
+}
+
+export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+
+is_business_day() {
+    dt=${1}
+
+    open_time=$(curl -s "${CalendarURL}&start=${dt}&end=${dt}" | jq '.[] | .open_time')
+    if [ -n  "${open_time}" ]; then
+        return 0
+    else
+        return 1
+    fi
+
+}
+export -f is_business_day
+
+get_prev_business_day() {
+    Start=${1}
+    while true; do
+        if is_business_day ${Start}; then
+            break
+        fi
+        echo "${Start} is not business day in US" >&2
+        Start=$(date -d "${Start} - 1 day" "+%Y-%m-%d")
+    done
+    echo ${Start}
+}
+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
+# ----- Settings
+
+while getopts ":d:N:L:" opt; do
+  case ${opt} in
+    d )
+      date_to_load=$OPTARG
+      ;;
+    N )
+      NumSymbols=$OPTARG
+      ;;
+    L )
+      LogDir=$OPTARG
+      ;;
+    \? )
+      echo "Invalid option: -$OPTARG" >&2
+      usage
+      ;;
+    : )
+      echo "Option -$OPTARG requires an argument." >&2
+      usage
+      ;;
+  esac
+done
+
+if is_container_running "$ContainerName"; then
+    echo "Container ${ContainerName} is already running."
+    exit 3
+fi
+
+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'))
+    echo "Historical Data for ${date_to_load}"
+fi
+
+echo "date_to_load=${date_to_load}"
+
+Cmd="docker run"
+Cmd="${Cmd} --pull=always"
+Cmd="${Cmd} --network=host"
+Cmd="${Cmd} --name=${ContainerName}"
+Cmd="${Cmd} --rm"
+Cmd="${Cmd} --volume=${LogDir}:/logs"
+Cmd="${Cmd} ${DockerImage}"
+Cmd="${Cmd} -d ${date_to_load}"
+if [ -n "${NumSymbols}" ]; then
+    Cmd="${Cmd} -N ${NumSymbols}"
+fi
+
+echo $Cmd
+eval $Cmd
+
+if [ "$?" != "0" ] ; then
+    exit 1 # if killed we do not save last day
+fi

docker/market_data/hist/load_alpaca_qat.sh

@@ -0,0 +1,108 @@
+#!/bin/bash
+
+usage() {
+  echo "Usage: $0  -S <symbols> [-L <LogDir>] [-d <YYYYMMDD Date>]"
+  exit 1
+}
+
+is_container_running() {
+    local container_name=$1
+
+    if [ "$(docker ps --filter "name=^/${container_name}$" --filter "status=running" -q)" ]; then
+        return 0  # true
+    else
+        return 1  # false
+    fi
+}
+
+export CalendarURL=http://cloud23.cvtt.vpn:8000/api/v1/markets/hours?mic=XNYS
+
+is_business_day() {
+    dt=${1}
+
+    open_time=$(curl -s "${CalendarURL}&start=${dt}&end=${dt}" | jq '.[] | .open_time')
+    if [ -n  "${open_time}" ]; then
+        return 0
+    else
+        return 1
+    fi
+
+}
+export -f is_business_day
+
+get_prev_business_day() {
+    Start=${1}
+    while true; do
+        if is_business_day ${Start}; then
+            break
+        fi
+        echo "${Start} is not business day in US" >&2
+        Start=$(date -d "${Start} - 1 day" "+%Y-%m-%d")
+    done
+    echo ${Start}
+}
+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
+# ----- Settings
+
+while getopts ":d:S:L:" opt; do
+  case ${opt} in
+    d )
+      date_to_load=$OPTARG
+      ;;
+    S )
+      Symbols=$OPTARG
+      ;;
+    L )
+      LogDir=$OPTARG
+      ;;
+    \? )
+      echo "Invalid option: -$OPTARG" >&2
+      usage
+      ;;
+    : )
+      echo "Option -$OPTARG requires an argument." >&2
+      usage
+      ;;
+  esac
+done
+
+if [ -z ${Symbols}  ] ; then
+    echo "symbols are not specified"
+    usage
+fi
+
+if is_container_running "$ContainerName"; then
+    echo "Container ${ContainerName} is already running."
+    exit 3
+fi
+
+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'))
+    echo "Historical Data for ${date_to_load}"
+fi
+
+echo "date_to_load=${date_to_load}"
+
+Cmd="docker run"
+Cmd="${Cmd} --pull=always"
+Cmd="${Cmd} --network=host"
+Cmd="${Cmd} --name=${ContainerName}"
+Cmd="${Cmd} --rm"
+Cmd="${Cmd} --volume=${LogDir}:/logs"
+Cmd="${Cmd} ${DockerImage}"
+Cmd="${Cmd} -d ${date_to_load}"
+Cmd="${Cmd} -S ${Symbols}"
+
+echo $Cmd
+eval $Cmd
+
+if [ "$?" != "0" ] ; then
+    exit 1 # if killed we do not save last day
+fi

docker/market_data/md_portal/__UNUSED__/.env

@@ -1,2 +0,0 @@
-ROOT_DIR=/home/cvtt/prod
-ADMIN_PORT=7220

docker/market_data/md_portal/__UNUSED__/docker-compose.yml

@@ -1,20 +0,0 @@
-version: '3.8'
-
-#==================================================
-# Relies on the file `.env` content for varables:
-#    ROOT_DIR
-#    JUPYTER_PORT
-#==================================================
-services:
-  md_portal:
-    image: cloud21.cvtt.vpn:5500/md_portal:latest
-    network_mode: host
-    container_name: md_portal
-    restart: unless-stopped
-    environment:
-      - JUPYTER_ENABLE_LAB=yes
-    volumes:
-      - ${ROOT_DIR}/logs:/logs
-    ports:
-      - "${ADMIN_PORT}:${ADMIN_PORT}"
-    shm_size: "8gb"

docker/market_data/md_portal/start_docker_md_portal.sh

@@ -1,73 +0,0 @@
-#!/bin/bash
-
-usage() {
-    echo -n "Usage: ${0}"
-    echo -n " [-C <config (dflt: apps/cvtt_eqt_alpaca)>]"
-    echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-    echo -n " [-e <active_exchanges (ALPACA_SNBOX)>]"
-    echo -n " [-a <admin_port (7220)>]"
-    echo -n " [-n <portal_name (MD_PORTAL_ALPACA)>]"
-    echo
-    exit 1
-}
-
-
-args=${*}
-
-Config=apps/cvtt_eqt_alpaca
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX
-PortalName=MD_PORTAL_ALPACA_SNDBX
-AdminPort=7220
-
-while getopts ":C:c:e:a:n:" opt; do
-    case ${opt} in
-        C )
-            Config=$OPTARG
-            ;;
-        c )
-            ConfigServer=$OPTARG
-            ;;
-        e )
-            ActiveExchanges=$OPTARG
-            ;;
-        a )
-            AdminPort=$OPTARG
-            ;;
-        n )
-            PortalName=$OPTARG
-            ;;
-        \? )
-            echo "Invalid option: -$OPTARG" >&2
-            usage
-            ;;
-        : )
-            echo "Option -$OPTARG requires an argument." >&2
-            usage
-            ;;
-    esac
-done
-
-echo "Config=${Config}"
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "PortalName=${PortalName}"
-echo "AdminPort=${AdminPort}"
-
-
-ImageName=md_portal
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}.${PortalName}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

docker/market_data/misc/relative_liquidity.sh

@@ -1,14 +0,0 @@
-#!/bin/bash
-
-Cmd="docker run"
-Cmd="${Cmd} -d"
-#Cmd="${Cmd} --rm"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --name=relative_liquidity_svc"
-Cmd="${Cmd} -p 5678:5678"
-Cmd="${Cmd} -v /home/cvtt/prod/data:/app/data"
-Cmd="${Cmd} -v /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} cloud21.cvtt.vpn:5500/relative_liquidity:latest"
-
-echo ${Cmd}
-eval ${Cmd}

docker/market_data/misc/trading_calendar.sh

@@ -1,12 +0,0 @@
-#!/bin/bash
-
-#Cmd="docker pull apptasticsoftware/trading-calendar:latest"
-#echo ${Cmd} && eval ${Cmd}
-
-Cmd="docker run"
-Cmd="${Cmd} -d"
-Cmd="${Cmd} --rm"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --name trading-calendar"
-Cmd="${Cmd} -p 8000:80 apptasticsoftware/trading-calendar"
-echo ${Cmd} && eval ${Cmd}

docker/trading/executor/start_docker_executor.sh

@@ -1,61 +0,0 @@
-#!/bin/bash
-
-usage() {
-  echo -n "Usage: $0"
-  echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-  echo -n " [-e <active_exchanges (ALPACA_SNDBX-MDPORTAL)>]"
-  echo -n " [-a <admin_port (7222)>"]
-  echo
-  exit 1
-}
-
-args=${*}
-
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX-MDPORTAL
-AdminPort=7222
-Book=""
-
-while getopts ":c:e:a:" opt; do
-  case ${opt} in
-    c )
-      ConfigServer=$OPTARG
-      ;;
-    e )
-      ActiveExchanges=$OPTARG
-      ;;
-    a )
-      AdminPort=$OPTARG
-      ;;
-    \? )
-      echo "Invalid option: -$OPTARG" >&2
-      usage
-      ;;
-    : )
-      echo "Option -$OPTARG requires an argument." >&2
-      usage
-      ;;
-  esac
-done
-
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "AdminPort=${AdminPort}"
-
-
-ImageName=executor
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

docker/trading/quant/start_docker_quant.sh

@@ -1,86 +0,0 @@
-#!/bin/bash
-
-usage() {
-  echo -n "Usage: $0"
-  echo -n " -b <book>"
-
-  echo -n " -S <strategy> (dflt: TRDALGO_001)"
-
-  echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-  echo -n " [-e <active_exchanges (ALPACA_SNDBX-MDPORTAL)>]"
-  echo -n " [-a <admin_port (7224)>"]
-  echo
-  exit 1
-}
-
-args=${*}
-
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX-MDPORTAL
-AdminPort=7224
-Strategy=DAILY_STOCK_001
-Book=""
-
-
-while getopts ":b:c:e:a:S:" opt; do
-  case ${opt} in
-    c )
-      ConfigServer=$OPTARG
-      ;;
-    e )
-      ActiveExchanges=$OPTARG
-      ;;
-    a )
-      AdminPort=$OPTARG
-      ;;
-    b )
-      Book=$OPTARG
-      ;;
-    S )
-      Strategy=$OPTARG
-      ;;
-    \? )
-      echo "Invalid option: -$OPTARG" >&2
-      usage
-      ;;
-    : )
-      echo "Option -$OPTARG requires an argument." >&2
-      usage
-      ;;
-  esac
-done
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "Book=${Book}"
-echo "Strategy=${Strategy}"
-echo "AdminPort=${AdminPort}"
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-
-ImageName=quant
-
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}.${Book}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

docker/trading/risk_mgr/start_docker_risk_mgr.sh

@@ -1,74 +0,0 @@
-#!/bin/bash
-
-usage() {
-  echo -n "Usage: $0"
-  echo -n " -b <book>"
-  echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-  echo -n " [-e <active_exchanges (ALPACA_SNDBX-MDPORTAL)>]"
-  echo -n " [-a <admin_port (7223)>"]
-  echo
-  exit 1
-}
-
-
-args=${*}
-
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX-MDPORTAL
-AdminPort=7223
-Book=""
-
-
-while getopts ":b:c:e:a:" opt; do
-  case ${opt} in
-    c )
-      ConfigServer=$OPTARG
-      ;;
-    e )
-      ActiveExchanges=$OPTARG
-      ;;
-    a )
-      AdminPort=$OPTARG
-      ;;
-    b )
-      Book=$OPTARG
-      ;;
-    \? )
-      echo "Invalid option: -$OPTARG" >&2
-      usage
-      ;;
-    : )
-      echo "Option -$OPTARG requires an argument." >&2
-      usage
-      ;;
-  esac
-done
-
-
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "Book=${Book}"
-echo "AdminPort=${AdminPort}"
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-
-ImageName=risk_mgr
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}.${Book}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

docker/trading/trader/start_docker_trader.sh

@@ -1,87 +0,0 @@
-#!/bin/bash
-
-usage() {
-  echo -n "Usage: $0"
-  echo -n " -b <book>"
-
-  echo -n " -A <algo> (dflt: TRDALGO_001)"
-
-  echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-  echo -n " [-e <active_exchanges (ALPACA_SNDBX-MDPORTAL)>]"
-  echo -n " [-a <admin_port (7223)>"]
-  echo
-  exit 1
-}
-
-
-args=${*}
-
-# ConfigServer=cloud16.cvtt.vpn
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX-MDPORTAL
-AdminPort=7226
-Algo=TRDALGO_001
-Book=""
-
-
-while getopts ":b:c:e:a:" opt; do
-  case ${opt} in
-    c )
-      ConfigServer=$OPTARG
-      ;;
-    e )
-      ActiveExchanges=$OPTARG
-      ;;
-    a )
-      AdminPort=$OPTARG
-      ;;
-    b )
-      Book=$OPTARG
-      ;;
-    A )
-      Algo=$OPTARG
-      ;;
-    \? )
-      echo "Invalid option: -$OPTARG" >&2
-      usage
-      ;;
-    : )
-      echo "Option -$OPTARG requires an argument." >&2
-      usage
-      ;;
-  esac
-done
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "Book=${Book}"
-echo "Algo=${Algo}"
-echo "AdminPort=${AdminPort}"
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-
-ImageName=trader
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}.${Book}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

docker/trading/trading_recorder/start_docker_trading_recorder.sh

@@ -1,81 +0,0 @@
-#!/bin/bash
-
-usage() {
-  echo -n "Usage: $0"
-  echo -n " -b <book>"
-  echo -n " [-C <config (dflt: apps/cvtt_eqt_alpaca)>]"
-  echo -n " [-c <config_server (dflt: cloud23.cvtt.vpn:6789)>]"
-  echo -n " [-e <active_exchanges (ALPACA_SNDBX-MDPORTAL)>]"
-  echo -n " [-a <admin_port (7223)>"]
-  echo
-  exit 1
-}
-
-
-args=${*}
-
-# ConfigServer=cloud16.cvtt.vpn
-ConfigServer=cloud23.cvtt.vpn:6789
-ActiveExchanges=ALPACA_SNDBX-MDPORTAL
-AdminPort=7225
-Book=""
-Config=apps/cvtt_eqt_alpaca
-
-while getopts ":C:b:c:e:a:" opt; do
-  case ${opt} in
-    c )
-      ConfigServer=$OPTARG
-      ;;
-    e )
-      ActiveExchanges=$OPTARG
-      ;;
-    a )
-      AdminPort=$OPTARG
-      ;;
-    b )
-      Book=$OPTARG
-      ;;
-    \? )
-      echo "Invalid option: -$OPTARG" >&2
-      usage
-      ;;
-    : )
-      echo "Option -$OPTARG requires an argument." >&2
-      usage
-      ;;
-  esac
-done
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-echo "Config=${Config}"
-echo "ConfigServer=${ConfigServer}"
-echo "ActiveExchanges=${ActiveExchanges}"
-echo "Book=${Book}"
-echo "AdminPort=${AdminPort}"
-
-if [ "${Book}" == "" ]; then
-    echo "Book is missing"
-    usage
-fi
-
-
-ImageName=trading_recorder
-DockerRegistry=cloud21.cvtt.vpn:5500
-DockerImage=${DockerRegistry}/${ImageName}
-
-Cmd="docker run"
-Cmd="${Cmd} --detach"
-Cmd="${Cmd} --restart=unless-stopped"
-Cmd="${Cmd} --pull=always"
-Cmd="${Cmd} --network=host"
-Cmd="${Cmd} --name=${ImageName}.${Book}"
-Cmd="${Cmd} --volume /home/cvtt/prod/logs:/logs"
-Cmd="${Cmd} ${DockerImage}"
-Cmd="${Cmd} ${args}"
-
-echo $Cmd
-eval $Cmd

release_version.txt

@@ -1 +1 @@
-1.6.5,python 3.12, etc.
+1.7.5.fx1,using new(rust) alpaca market data structure for hbar

research/load_eqty_md.sh

@@ -167,10 +167,10 @@ EOF
 echo "Loading files"
 for stock in "${Stocks[@]}"; do
     StockLetter="${stock:0:1}"
-    SourceFile=$(${date} -d ${md_date} "+%Y%m%d.${stock}.1min.db")
+    SourceFile=$(${date} -d ${md_date} "+%Y%m%d.${stock}.alpaca_1m_bars.db")
 
     SourceFileZip="${SourceFile}.gz"
-    SourceFilePath=$(${date} -d ${md_date} "+${SourceRootDir}/${StockLetter}/${stock}/%Y/${SourceFileZip}")
+    SourceFilePath=$(${date} -d ${md_date} "+${SourceRootDir}/%Y/${StockLetter}/${stock}/${SourceFileZip}")
     echo ${SourceFilePath}
 
     download_file ${SourceFilePath}
@@ -180,6 +180,3 @@ if [ -f ${TargetFilePath} ]; then
     chmod 600
     ls -lh ${TargetFilePath}
 fi
-
-# mkdir -p /tmp/aaa
-# cp -r ${tmp_dir}/* /tmp/aaa/

scripts/healthcheck/storage_health_check.sh

@@ -69,7 +69,9 @@ function storage_check() {
         Cmd="ssh -p ${port} $host"
         Cmd="${Cmd} eval \"df -hTl"
         Cmd="${Cmd} -x squashfs"
-        Cmd="${Cmd} | grep -v tmpfs"
+        Cmd="${Cmd} -x tmpfs"
+        Cmd="${Cmd} -x vfat"
+        Cmd="${Cmd} -x devtmpfs"
         Cmd="${Cmd} | grep -v Filesystem\""
 
         IFS=$'\n' ; lines=$(eval ${Cmd})

scripts/mkt_data/checklists/crypto_md_chcklst.sh

@@ -47,7 +47,7 @@ function cleanup {
 }
 trap cleanup EXIT
 
-echo "## :hearts: CRYPTO MD HEALTH CHECK" >> ${tmpfile}
+echo "## :hearts: CRYPTO MD HEALTH CHECK (cvtt-md.cvtt.vpn)" >> ${tmpfile}
 echo  '```' >> ${tmpfile}
 run_checklist  >> ${tmpfile}
 echo  '```' >> ${tmpfile}

scripts/mkt_data/checklists/eqty_md_chcklst.sh

@@ -51,25 +51,10 @@ function cleanup {
 }
 trap cleanup EXIT
 
-echo "## :fire: EQUITY MD HEALTH CHECK" >> ${tmpfile}
+echo "## :fire: EQUITY MD HEALTH CHECK (cryptoval4)" >> ${tmpfile}
 echo  '```' | tee -a ${tmpfile}
 run_checklist  | tee -a ${tmpfile}
 echo  '```' | tee -a ${tmpfile}
 
 echo "Sending result to ${Sender} ${StatusChannel}"
-cat ${tmpfile} |  ${Sender} ${StatusChannel}
+cat ${tmpfile} |  ${Sender} ${StatusChannel}
-
-exit
-# homestore
-echo homestore
-ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3
-echo
-ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/N/NVDA/${yr} | tail -3
-
-echo cloud21
-ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3
-echo
-ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/equity/alpaca_md/N/NVDA/${yr} | tail -3
-
-echo "------ gpushnik"
-ssh oleg@gpushnik.cvtt.vpn 'ls -l /opt/jupyter_gpu/data/eqty_md | tail -10'