#update for realtime_stock

QARealtimeCollector/__init__.py

@@ -42,3 +42,7 @@ def resample(code, freq, model):
 def random(code, date, price, interval):
     r = QARTC_RandomTick(code, date, price, interval)
     r.start()
+
+
+def stock_collector():
+    QARTC_Stock().start()

QARealtimeCollector/collectors/stockcollector.py

@@ -69,7 +69,7 @@ def run(self):
 
 
 if __name__ == "__main__":
-    r = QARTC_Stock('yutiansut', '940809')
+    r = QARTC_Stock()
     r.subscribe('000001')
     r.subscribe('000002')
     r.start()

QARealtimeCollector/webserver.py

@@ -9,6 +9,7 @@
 from tornado.web import Application, RequestHandler, authenticated
 
 import QUANTAXIS as QA
+from QAPUBSUB.producer import publisher, publisher_routing
 from QARealtimeCollector.collectors import (QARTC_CtpBeeCollector,
                                             QARTC_CTPTickCollector,
                                             QARTC_RandomTick, QARTC_Stock,
@@ -47,7 +48,11 @@ def post(self):
                     self.handler[market_type][code].start()
                     self.write({'result': 'success'})
                 else:
-                    pass
+                    publisher_routing(exchange='QARealtime_Market', routing_key='stock').pub(json.dumps({
+                        'topic': 'subscribe',
+                        'code': code
+                    }), routing_key='stock')
+                    self.handler[market_type][code] = True
 
             else:
                 self.write({'result': 'already exist'})

setup.py

@@ -70,6 +70,7 @@ def read(fname):
             'QARC_Resample = QARealtimeCollector.__init__:resample',
             'QARC_Random = QARealtimeCollector.__init__:random',
             'QARC_CTP = QARealtimeCollector.__init__:start_ctp',
+            'QARC_Stock = QARealtimeCollector.__init__:stock_collector',
             'QARC_WEBSERVER = QARealtimeCollector.webserver:main'
         ]
     },