投研基本模块图

回测引擎数据搬运(sub)

C2

q1

n

cron : schedule tasksub: subscriptpub: publish

回测引擎(sub)

type: directdurable=Truename: luobo.touyan

指标计算(用户公式)

q1: durable=True

q3

q4

定时任务(pub)

stock.reprocess

q4: durable=True

q2: durable=True

P

task.regression

指标计算引擎(sub/pub)

MQ

stock_reprocess

C3

q2

q0

stock_spider

C4

预处理引擎

transfer.indicator

指标(pub[q2])

DB

mongodb

数据爬取(pub/sub)

预处理引擎(sub)

回测引擎

q0: durable=True

指标搬运(回测用)

数据爬取模块

WebServer

C0

type:directexchange: luobo.touyanq0:routing_key:stock.spiderq1: routing_key:stock.reprocessq2:routing_key:calc.indicatorq3:routing_key:transfer.indicatorq4:routing_key:task.regression

calc.indicator

X

transfer_indicator

C1

calc_indicator

公式引擎

task_regression

回测(pub[q4])

q0: message: b'{ \"all\

1

stock.spider

q3: durable=True