I can’t get the tick data at the upd function. Any idea? Thx.
user01@centos67 ~/torq
$ find | grep -vP ‘#|log|~’ | grep -iP ‘rtsub|accesslist|process.csv’ | xargs head -1000
==> ./code/processes/rtsub.q <==
\d .rtsub
\d .
.servers.CONNECTIONS:`tickerplant;
.servers.startup;
upd:{show x;show y};
tickerplanttypes:`tickerplant;
.sub.getsubscriptionhandles[tickerplanttypes;();()!()];
.sub.subscribe[;;0b;0b] each .sub.getsubscriptionhandles[tickerplanttypes;();()!()];
==> ./config/passwords/accesslist.txt <==
discovery:pass
feed:pass
gateway:pass
hdb:pass
housekeeping:pass
kill:pass
monitor:pass
rdb:pass
reporter:pass
sort:pass
tickerplant:pass
wdb:pass
chainedtp:pass
rtsub:pass
admin:admin
==> ./config/passwords/rtsub.txt <==
rtsub:pass
==> ./config/nontorqprocess.csv <==
host,port,proctype,procname
==> ./config/process.csv <==
host,port,proctype,procname
localhost,{KDBBASEPORT}+1,discovery,discovery1
localhost,{KDBBASEPORT},tickerplant,tickerplant1
localhost,{KDBBASEPORT}+2,rdb,rdb1
localhost,{KDBBASEPORT}+3,hdb,hdb1
localhost,{KDBBASEPORT}+4,hdb,hdb2
localhost,{KDBBASEPORT}+5,wdb,wdb1
localhost,{KDBBASEPORT}+6,sort,sort1
localhost,{KDBBASEPORT}+7,gateway,gateway1
localhost,{KDBBASEPORT}+8,kill,killtick
localhost,{KDBBASEPORT}+9,monitor,monitor1
localhost,{KDBBASEPORT}+10,tickerlogreplay,tpreplay1
localhost,{KDBBASEPORT}+11,housekeeping,housekeeping1
localhost,{KDBBASEPORT}+12,reporter,reporter1
localhost,{KDBBASEPORT}+13,compression,compression1
localhost,{KDBBASEPORT}+14,feed,feed1
localhost,{KDBBASEPORT}+15,chainedtp,chainedtp1
localhost,{KDBBASEPORT}+16,rtsub,rtsub1
user01@centos67 ~/torq
$ head -v -n1000 start_torq_demo.sh
==> start_torq_demo.sh <==
# Load the environment
. ./setenv.sh
# sets the base port for a default TorQ installation
export KDBHDB=${TORQHOME}/hdb/database
export KDBBASEPORT=6000
export KDBSTACKID=“-stackid ${KDBBASEPORT}”
export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:$KDBLIB/l32
##### EMAILS #####
# this is where the emails will be sent to
# export DEMOEMAILRECEIVER=user@torq.co.uk
# also set the email server configuration in config/settings/default.q
##### END EMAILS #####
# launch the discovery service
echo ‘Starting discovery proc…’
q torq.q -load code/processes/discovery.q ${KDBSTACKID} -proctype discovery -procname discovery1 -U config/passwords/accesslist.txt -localtime </dev/null >$KDBLOG/torqdiscovery.txt 2>&1 &
# launch the tickerplant, rdb, hdb
echo ‘Starting tp…’
q code/processes/tickerplant.q database ${TORQHOME}/hdb ${KDBSTACKID} -proctype tickerplant -procname tickerplant1 -U config/passwords/accesslist.txt -localtime </dev/null >$KDBLOG/torqtp.txt 2>&1 &
echo ‘Starting rdb…’
q torq.q -load code/processes/rdb.q ${KDBSTACKID} -proctype rdb -procname rdb1 -U config/passwords/accesslist.txt -localtime -g 1 -T 30 </dev/null >$KDBLOG/torqrdb.txt 2>&1 &
echo ‘Starting ctp…’
q torq.q -load code/processes/chainedtp.q ${KDBSTACKID} -proctype chainedtp -procname chainedtp1 -U config/passwords/accesslist.txt -localtime </dev/null >$KDBLOG/torqchainedtp.txt 2>&1 &
echo ‘Starting hdb1…’
q torq.q -load ${KDBHDB} ${KDBSTACKID} -proctype hdb -procname hdb1 -U config/passwords/accesslist.txt -localtime -g 1 -T 60 -w 4000 </dev/null >$KDBLOG/torqhdb1.txt 2>&1 &
echo ‘Starting hdb2…’
q torq.q -load ${KDBHDB} ${KDBSTACKID} -proctype hdb -procname hdb2 -U config/passwords/accesslist.txt -localtime -g 1 -T 60 -w 4000 </dev/null >$KDBLOG/torqhdb2.txt 2>&1 &
# launch the gateway
echo ‘Starting gw…’
q torq.q -load code/processes/gateway.q ${KDBSTACKID} -proctype gateway -procname gateway1 -U config/passwords/accesslist.txt -localtime -g 1 -w 4000 </dev/null >$KDBLOG/torqgw.txt 2>&1 &
# launch the monitor
echo ‘Starting monitor…’
q torq.q -load code/processes/monitor.q ${KDBSTACKID} -proctype monitor -procname monitor1 -localtime </dev/null >$KDBLOG/torqmonitor.txt 2>&1 &
# launch the reporter
echo ‘Starting reporter…’
q torq.q -load code/processes/reporter.q ${KDBSTACKID} -proctype reporter -procname reporter1 -U config/passwords/accesslist.txt -localtime </dev/null >$KDBLOG/torqreporter.txt 2>&1 &
# launch housekeeping
echo ‘Starting housekeeping proc…’
q torq.q -load code/processes/housekeeping.q ${KDBSTACKID} -proctype housekeeping -procname housekeeping1 -U config/passwords/accesslist.txt -localtime </dev/null >$KDBLOG/torqhousekeeping.txt 2>&1 &
# launch sort processes
echo ‘Starting sorting proc…’
q torq.q -load code/processes/wdb.q ${KDBSTACKID} -proctype sort -procname sort1 -U config/passwords/accesslist.txt -localtime -g 1 </dev/null >$KDBLOG/torqsort.txt 2>&1 & # sort process
# launch wdb
echo ‘Starting wdb…’
q torq.q -load code/processes/wdb.q ${KDBSTACKID} -proctype wdb -procname wdb1 -U config/passwords/accesslist.txt -localtime -g 1 </dev/null >$KDBLOG/torqwdb.txt 2>&1 & # pdb process
# launch compress
echo ‘Starting compression proc…’
q torq.q -load code/processes/compression.q ${KDBSTACKID} -proctype compression -procname compression1 -localtime </dev/null >$KDBLOG/torqcompress1.txt 2>&1 & # compression process
# launch feed
echo ‘Starting feed…’
q torq.q -load code/tick/feed.q ${KDBSTACKID} -proctype feed -procname feed1 -localtime </dev/null >$KDBLOG/torqfeed.txt 2>&1 &
# rtsub
echo ‘Starting rtsub…’
q torq.q -load code/processes/rtsub.q ${KDBSTACKID} -proctype rtsub -procname rtsub1 -U config/passwords/accesslist.txt -localtime -g 1 -T 30 </dev/null >$KDBLOG/torqrtsub.txt 2>&1 &
user01@centos67 ~/torq
$ tail logs/*rtsub1.log
==> logs/err_rtsub1.log <==
==> logs/out_rtsub1.log <==
# #
################################################################################
2015.08.17D11:38:34.659732000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|attempting to connect to discovery services
2015.08.17D11:38:34.659768000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|attempting to open handle to :centos67.yanyan.com:6001
2015.08.17D11:38:34.670402000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|connection to :centos67.yanyan.com:6001 successful
2015.08.17D11:38:34.672815000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|registering with discovery services
2015.08.17D11:38:34.672858000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|requesting processes from discovery service
2015.08.17D11:38:34.672915000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|querying discovery services for processes of types tickerplant
2015.08.17D11:41:03.940222000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|attempting to open handle to :centos67.yanyan.com:6000
2015.08.17D11:41:03.940536000|centos67.yanyan.com|rtsub|rtsub1|INF|conn|connection to :centos67.yanyan.com:6000 successful
==> logs/usage_rtsub1.log <==
2015.08.17D11:56:33.396779000|373|0N|ps|rtsub|rtsub1|"b"|-1062709672i|user01|0i|“.hb.publishheartbeat”|2645632 67108864 67108864 0 0|0N|“”
2015.08.17D11:56:33.397087000|373|114|ps|rtsub|rtsub1|"c"|-1062709672i|user01|0i|“.hb.publishheartbeat”|2645792 67108864 67108864 0 0|10|“”
2015.08.17D11:56:36.597051000|374|0N|ps|rtsub|rtsub1|"b"|-1062709672i|user01|0i|“.hb.checkheartbeat”|2645888 67108864 67108864 0 0|0N|“”
2015.08.17D11:56:36.597708000|374|204|ps|rtsub|rtsub1|"c"|-1062709672i|user01|0i|“.hb.checkheartbeat”|2646048 67108864 67108864 0 0|10|“”
2015.08.17D11:56:36.598934000|375|0N|ps|rtsub|rtsub1|"b"|-1062709672i|user01|0i|“.sub.checksubscriptions”|2646144 67108864 67108864 0 0|0N|“”
2015.08.17D11:56:36.599440000|375|351|ps|rtsub|rtsub1|"c"|-1062709672i|user01|0i|“.sub.checksubscriptions”|2646304 67108864 67108864 0 0|10|“”
2015.08.17D11:56:46.596283000|376|0N|ps|rtsub|rtsub1|"b"|-1062709672i|user01|0i|“.sub.checksubscriptions”|2646400 67108864 67108864 0 0|0N|“”
2015.08.17D11:56:46.596497000|376|35|ps|rtsub|rtsub1|"c"|-1062709672i|user01|0i|“.sub.checksubscriptions”|2646560 67108864 67108864 0 0|10|“”
2015.08.17D11:56:46.797315000|377|0N|ps|rtsub|rtsub1|"b"|-1062709672i|user01|0i|“.hb.checkheartbeat”|2646656 67108864 67108864 0 0|0N|“”
2015.08.17D11:56:46.797558000|377|66|ps|rtsub|rtsub1|"c"|-1062709672i|user01|0i|“.hb.checkheartbeat”|2646816 67108864 67108864 0 0|10|“”