homestore /works/cvtt ownership moved to cvtt

docker/md_portal/start_docker_md_portal.sh

@@ -1,14 +1,14 @@
 #!/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
+    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
 }
 
 
@@ -21,31 +21,31 @@ 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
+    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}"

release_version.txt

@@ -1 +1 @@
-1.6.1,trading recorder -> docker
+1.6.4,homestore /works/cvtt ownership moved to cvtt

research/load_crypto_md.sh

@@ -69,7 +69,7 @@ if [ "${host}" == "cloud21" ] ; then
     SourceRootDir="/opt/store/cvtt/md_archive/crypto/${source}"
 elif [ "${host}" == "homestore" ]; then
     SourceHost=homestore.cvtt.vpn
-    SourceUser=oleg
+    SourceUser=cvtt
     SourceRootDir=/works/cvtt/md_archive/crypto/${source}
 else
     usage

research/load_eqty_md.sh

@@ -9,6 +9,7 @@ usage() {
   echo
   exit 1
 }
+
 if [[ "$(uname)" == "Darwin" ]]; then
     # macOS
     date='gdate'
@@ -22,6 +23,8 @@ host=homestore
 stocks=COIN,GBTC,SQ
 
 TargetDir="/opt/jupyter_gpu/data/eqty_md"
+# TargetDir="/tmp"  # -------= D E B U G
+
 mkdir -p ${TargetDir}
 
 Table=md_1min_bars
@@ -88,7 +91,6 @@ TargetFile=$(${date} -d ${md_date} "+%Y%m%d.eqty.mktdata.ohlcv.db")
 
 TargetFilePath="${TargetDir}/${TargetFile}"
 mv ${TargetFilePath} "${TargetFilePath}.saved.$(${date} '+%Y%m%d_%H%M%S')"
-touch ${TargetFilePath}
 
 # ---- temp dir
 echo ${SourceFile}
@@ -108,7 +110,7 @@ if [ "${host}" == "cloud21" ] ; then
     SourceRootDir="/opt/store/cvtt/md_archive/equity/alpaca_md"
 elif [ "${host}" == "homestore" ]; then
     SourceHost=homestore.cvtt.vpn
-    SourceUser=oleg
+    SourceUser=cvtt
     SourceRootDir="/works/cvtt/md_archive/equity/alpaca_md"
 else
     usage
@@ -146,6 +148,7 @@ function download_file {
     echo ${Cmd} && eval ${Cmd}
 
     DbFile=${tmp_dir}/${SourceFile}
+    touch ${TargetFilePath}
 
 
 # --- T E M P - for files older than 20240813
@@ -173,8 +176,10 @@ for stock in "${Stocks[@]}"; do
     download_file ${SourceFilePath}
 done
 
-chmod 600 ${TargetFilePath}
-ls -lh ${TargetFilePath}
+if [ -f ${TargetFilePath} ]; then
+    chmod 600
+    ls -lh ${TargetFilePath}
+fi
 
 # mkdir -p /tmp/aaa
 # cp -r ${tmp_dir}/* /tmp/aaa/

scripts/healthcheck/cvtt_ts_status_check.sh

@@ -0,0 +1,88 @@
+#!/bin/bash
+
+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 " [-N <name (dflt: ALPACA-SNDBX)>]"
+    echo
+    exit 1
+}
+
+
+Python="${HOME}/.pyenv/python3.10-venv/bin/python3.10"
+RootDir="${HOME}/prod"
+
+# **** D E B U G
+RootDir=/home/oleg/develop/cvtt2
+# **** D E B U G
+
+
+export PYTHONPATH=${RootDir}
+
+StatusChannel=Status-CVTT
+AlertChannel=Alerts-CVTT
+Sender=${RootDir}/ops/utils/send_mmost.sh
+ConfigService=http://cloud23.cvtt.vpn:6789
+Config=apps/cvtt_eqt_alpaca
+Name="ALPACA-SNDBX"
+
+echo $0 $* | /usr/bin/ts '[%Y-%m-%d %H:%M:%S]'
+
+while getopts ":s:c:n:" opt; do
+    case ${opt} in
+        c )
+            Config=$OPTARG
+            ;;
+        s )
+            ConfigService=$OPTARG
+            ;;
+        n )
+            Name=$OPTARG
+            ;;
+        \? )
+            echo "Invalid option: -$OPTARG" >&2
+            usage
+            ;;
+        : )
+            echo "Option -$OPTARG requires an argument." >&2
+            usage
+            ;;
+    esac
+done
+
+# ----- For DEBUGGING
+# Sender=cat
+# StatusChannel=
+
+tmpfile=$(mktemp)
+function cleanup {
+    # echo Cleaing up temporary files: ${TempFiles}
+    if [ "" != "${TempFiles}" ]; then
+        rm -f ${TempFiles}
+    fi
+}
+trap cleanup EXIT
+
+
+Cmd="${Python}"
+Cmd="${Cmd} ${RootDir}/cvttpy/apps/utils/services_checker.py"
+Cmd="${Cmd} --config=${ConfigService}/${Config}"
+Cmd="${Cmd} --log_level=ERROR"
+Cmd="${Cmd} --log_stdout"
+Cmd="${Cmd} | tee ${tmpfile} 2>&1"
+
+echo ${Cmd}
+eval ${Cmd}
+
+cat ${tmpfile}
+exit
+
+
+# echo "## :card_file_box: STORAGE HEALTH CHECK" >> ${tmpfile}
+# echo  >> ${tmpfile}
+# echo "| host | filesystem | usage |"  >> ${tmpfile}
+# echo "| --- | --- | --- |"  >> ${tmpfile}
+# cat ${tmpfile2} | sort -h -r | awk -F'%' '{printf "%s%%%s\n",$2,$3}' >> ${tmpfile}
+# cat ${tmpfile} |  ${Sender} ${StatusChannel}
+

scripts/mkt_data/checklists/crypto_md_chcklst.sh

@@ -25,8 +25,8 @@ run_checklist() {
 
     declare -A Commands
     Commands=(
-        ["homestore:cloud21"]="ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cloud21/${yr}/${mn} | tail -5"
-        ["homestore:cvttdata"]="ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cvttdata/${yr}/${mn} | tail -5"
+        ["homestore:cloud21"]="ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/crypto/cloud21/${yr}/${mn} | tail -5"
+        ["homestore:cvttdata"]="ssh cvtt@homestore.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"
         ["gpushnik"]="ssh oleg@gpushnik.cvtt.vpn 'ls -l /opt/jupyter_gpu/data/crypto_md | tail -10'"

scripts/mkt_data/checklists/eqty_md_chcklst.sh

@@ -24,9 +24,9 @@ run_checklist() {
     yr=$(date -d 'yesterday' '+%Y')
 
     declare -A Commands
-    Commands["homestore"]="ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3"
+    Commands["homestore"]="ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3"
     Commands["homestore"]+="; echo"
-    Commands["homestore"]+="; ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/N/NVDA/${yr} | tail -3"
+    Commands["homestore"]+="; ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/N/NVDA/${yr} | tail -3"
 
     Commands["cloud21"]="ssh cvtt@cloud21.cvtt.vpn ls -l /opt/store/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3"
     Commands["cloud21"]+="; echo"
@@ -52,20 +52,19 @@ function cleanup {
 trap cleanup EXIT
 
 echo "## :fire: EQUITY MD HEALTH CHECK" >> ${tmpfile}
-echo  '```' >> ${tmpfile}
-run_checklist  >> ${tmpfile}
-echo  '```' >> ${tmpfile}
+echo  '```' | tee -a ${tmpfile}
+run_checklist  | tee -a ${tmpfile}
+echo  '```' | tee -a ${tmpfile}
 
+echo "Sending result to ${Sender} ${StatusChannel}"
 cat ${tmpfile} |  ${Sender} ${StatusChannel}
 
-
-
 exit
 # homestore
 echo homestore
-ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3
+ssh cvtt@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/A/AAPL/${yr} | tail -3
 echo
-ssh oleg@homestore.cvtt.vpn ls -l /works/cvtt/md_archive/equity/alpaca_md/N/NVDA/${yr} | tail -3
+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

scripts/mkt_data/sync_market_data.sh

@@ -2,7 +2,7 @@
 
 Source=/home/cvtt/prod/archive/md_archive/
 Targets=
-Targets="${Targets} oleg@homestore.cvtt.vpn:/works/cvtt/md_archive/"
+Targets="${Targets} cvtt@homestore.cvtt.vpn:/works/cvtt/md_archive/"
 Targets="${Targets} cvtt@cloud21.cvtt.vpn:/opt/store/cvtt/md_archive/"