Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8eb52d718f | |||
| a0cf2531e6 | |||
| ada2a74eb6 | |||
| 7dec83b190 | |||
| 2b2056171e | |||
| 913d971663 |
@@ -0,0 +1,43 @@
|
|||||||
|
-------------------------------------
|
||||||
|
C R Y P T O M A R K E T D A T A
|
||||||
|
-------------------------------------
|
||||||
|
============
|
||||||
|
Exchanges
|
||||||
|
============
|
||||||
|
| Coinbase
|
||||||
|
| Binance Spot
|
||||||
|
| Binance Futures
|
||||||
|
|
|
||||||
|
v
|
||||||
|
============
|
||||||
|
Databases
|
||||||
|
============
|
||||||
|
| TimescaleDB: cloud21
|
||||||
|
| TimescaleDB: cvttdata
|
||||||
|
v
|
||||||
|
================
|
||||||
|
Daily Archive
|
||||||
|
================
|
||||||
|
| created by crontabs:
|
||||||
|
| cvttdata:
|
||||||
|
| (1) /home/cvtt/prod/utils/archive_yesterday_md.sh cloud21
|
||||||
|
| (2) /home/cvtt/prod/utils/archive_yesterday_md.sh cvttdata
|
||||||
|
| stored in:
|
||||||
|
| cvttdata:/home/cvtt/prod/archive/md_archive/crypto/cloud21 (1)
|
||||||
|
| cvttdata:/home/cvtt/prod/archive/md_archive/crypto/cvttdata (2)
|
||||||
|
|
|
||||||
|
v
|
||||||
|
==========
|
||||||
|
Storage
|
||||||
|
==========
|
||||||
|
| created by crontabs:
|
||||||
|
| cvttdata:
|
||||||
|
| TBD
|
||||||
|
| stored in:
|
||||||
|
| homestore:/works/cvtt/md_archive/crypto/ (cvttdata and cloud21)
|
||||||
|
| cloud21:/opt/store/cvtt/md_archive/crypto/ (cvttdata and cloud21)
|
||||||
|
|
|
||||||
|
v
|
||||||
|
==========
|
||||||
|
Usage
|
||||||
|
==========
|
||||||
@@ -0,0 +1,46 @@
|
|||||||
|
-------------------------------------
|
||||||
|
E Q U I T Y M A R K E T D A T A
|
||||||
|
-------------------------------------
|
||||||
|
=====================
|
||||||
|
Exchanges (Sources)
|
||||||
|
=====================
|
||||||
|
| Alpaca
|
||||||
|
|
|
||||||
|
|
|
||||||
|
| TBD ============
|
||||||
|
| TBD Databases
|
||||||
|
| TBD ============
|
||||||
|
| TBD | TimescaleDB: cloud21
|
||||||
|
| TBD | TimescaleDB: cvttdata
|
||||||
|
v TBD v
|
||||||
|
================
|
||||||
|
Daily Archive
|
||||||
|
================
|
||||||
|
| created by crontab on cvttdata:
|
||||||
|
| /home/cvtt/prod/run/alpaca_md.sh
|
||||||
|
| stored in:
|
||||||
|
| cvttdata:/home/cvtt/prod/archive/md_archive/equities/alpaca_md (TBD)
|
||||||
|
|
|
||||||
|
v
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
==========
|
||||||
|
Storage
|
||||||
|
==========
|
||||||
|
| created by crontabs:
|
||||||
|
| cvttdata:
|
||||||
|
|
|
||||||
|
| stored in:
|
||||||
|
| homestore:/works/cvtt/md_archive/crypto/cvttdata
|
||||||
|
| homestore:/works/cvtt/md_archive/crypto/cloud21
|
||||||
|
| backed up in:
|
||||||
|
| cloud21:/opt/store/cvtt/md_archive/crypto/cvttdata
|
||||||
|
| cloud21:/opt/store/cvtt/md_archive/crypto/cloud21
|
||||||
|
v
|
||||||
|
==========
|
||||||
|
Usage
|
||||||
|
==========
|
||||||
+1
-1
@@ -1 +1 @@
|
|||||||
0.8.3
|
0.8.9
|
||||||
|
|||||||
@@ -48,7 +48,8 @@ export PYTHONPATH=/home/cvtt/prod
|
|||||||
export Python=/home/cvtt/.pyenv/python3.10-venv/bin/python3
|
export Python=/home/cvtt/.pyenv/python3.10-venv/bin/python3
|
||||||
export Config=http://cloud16.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 PyScript=/home/cvtt/prod/cvttpy/exchanges/alpaca/hist_md/hist_md_bars.py
|
||||||
export OutputDir=/home/cvtt/host_drive/alpaca_md # Local
|
|
||||||
|
export OutputDir=/home/cvtt/prod/archive/md_archive/equities/alpaca_md # Local
|
||||||
export LogDir=/home/cvtt/prod/logs/alpaca_md
|
export LogDir=/home/cvtt/prod/logs/alpaca_md
|
||||||
|
|
||||||
# ----- T E M P
|
# ----- T E M P
|
||||||
|
|||||||
@@ -4,14 +4,14 @@ Python=/home/cvtt/.pyenv/python3.10-venv/bin/python3.10
|
|||||||
RootDir=/home/cvtt/prod
|
RootDir=/home/cvtt/prod
|
||||||
export PYTHONPATH=${RootDir}
|
export PYTHONPATH=${RootDir}
|
||||||
|
|
||||||
host=$(hostname)
|
host=${1}
|
||||||
if [ "${host}" == "cvttdata" ]
|
if [ "${host}" == "cvttdata" ]
|
||||||
then
|
then
|
||||||
ArchiveRootDir=/home/cvtt/prod/archive/md_archive
|
ArchiveRootDir=/home/cvtt/prod/archive/md_archive/crypto/cvttdata
|
||||||
CredKey=TSDB_MD_CVTTDATA_RO
|
CredKey=TSDB_MD_CVTTDATA_RO
|
||||||
elif [ "${host}" == "cloud21.cryptovaltrading.com" ]
|
elif [ "${host}" == "cloud21" ]
|
||||||
then
|
then
|
||||||
ArchiveRootDir=/opt/store/cvtt/archive/md_archive
|
ArchiveRootDir=/home/cvtt/prod/archive/md_archive/crypto/cloud21
|
||||||
CredKey=TSDB_MD_CLD21_RO
|
CredKey=TSDB_MD_CLD21_RO
|
||||||
else
|
else
|
||||||
echo "Unknown host ${host}. ${0} Aborted."
|
echo "Unknown host ${host}. ${0} Aborted."
|
||||||
@@ -21,7 +21,7 @@ fi
|
|||||||
mkdir -p ${ArchiveRootDir}
|
mkdir -p ${ArchiveRootDir}
|
||||||
|
|
||||||
yesterday=$(date -d "yesterday" +%Y%m%d)
|
yesterday=$(date -d "yesterday" +%Y%m%d)
|
||||||
Schemas=${1}
|
Schemas=${2}
|
||||||
if [ "${Schemas}" == "" ]
|
if [ "${Schemas}" == "" ]
|
||||||
then
|
then
|
||||||
Schemas="coinbase,bnbspot,bnbfut"
|
Schemas="coinbase,bnbspot,bnbfut"
|
||||||
|
|||||||
@@ -0,0 +1,33 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
# Collect all "A" files
|
||||||
|
letter=${1}
|
||||||
|
|
||||||
|
if [ "${letter}" == "" ]; then
|
||||||
|
echo "Usage $0 <letter>"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# copy text data to local location
|
||||||
|
rsync -ahv /home/cvtt/host_drive/eqt_hist_md/txt/${letter} /home/cvtt/tmp/txt/
|
||||||
|
|
||||||
|
# create db files
|
||||||
|
PYTHONPATH=/home/cvtt/prod /home/cvtt/.pyenv/python3.10-venv/bin/python3 /home/cvtt/prod/cvttpy/trading/mkt_data/ad_hoc/eqt_md_to_db.py /home/cvtt/tmp/txt/${letter} /home/cvtt/tmp/db
|
||||||
|
|
||||||
|
if [ "$?" != "0" ] ; then
|
||||||
|
exit
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Move all files to host drive
|
||||||
|
# a) create file list
|
||||||
|
(cd /home/cvtt/tmp/db/ && find . -name '*db' -print | grep "/${letter}/") > /home/cvtt/tmp/tran_db/${letter}_files
|
||||||
|
|
||||||
|
echo ${letter} is done
|
||||||
|
exit
|
||||||
|
|
||||||
|
|
||||||
|
# b) rsync files to host drive
|
||||||
|
rsync -ahv --remove-source-files --files-from=/home/cvtt/tmp/tran_db/${letter}_files /home/cvtt/tmp/db/ cvtt@my-vm-host:/localdisk/cvtt/eqt_hist_md/db/
|
||||||
|
|
||||||
|
# Clean directories
|
||||||
|
( cd /home/cvtt/tmp/db && (for d in $(find . -name $letter -type d -print); do echo $d ; done) | grep -v /$letter/$letter | xargs rm -rf) && rm -rf /home/cvtt/tmp/txt/${letter}
|
||||||
Reference in New Issue
Block a user