[区块链]Level-2市场数据究竟有哪些优势？（附代码）

说起Level-2行情接口数据，想必很多投资者都被开户的证券公司或者使用市场软件的客服骚扰过，因为他们经常向你推销各种基于Level-2市场数据的增值产品，包括一系列的界面、分析结果、指标公式等。这种看似聪明的东西对我们有用吗？值得我们每年花费去买吗？

Level-2市场数据是沪深交易所推出的收费市场数据服务。它可以提供在沪深交易所上市的证券产品的实时交易数据。数据传输速度比Level-1市场数据(即我们现在使用的5个市场数据)快3秒以上，还包括十档行情快照、委托队列、逐笔成交、逐笔委托总买卖等统计信息。客观来说，Level-2市场数据的出现确实比Level-1数据有了明显的提升，这体现在它的内容和速度上。

以下就是十档行情快照、委托队列、逐笔成交、逐笔委托

# 推送逐笔成交行情数据

def tick_record_stream():

????StreamResult = Stub.NewTickRecordStream(entity_pb2.Void())

????# 用For循环就可以不断消费数据

????for Result in StreamResult:

????????print(Result)

# 推送逐笔委托行情数据

def order_record_stream():

????StreamResult = Stub.NewOrderRecordStream(entity_pb2.Void())

????# 用For循环就可以不断消费数据

????for Result in StreamResult:

????????print(Result)

# 推送委托队列行情数据

def order_queue_record_stream():

????StreamResult = Stub.NewOrderQueueRecordStream(entity_pb2.Void())

????# 用For循环就可以不断消费数据

????for Result in StreamResult:

????????print(Result)

# 推送股票十档行情行情数据

def stock_quote_record_stream():

????StreamResult = Stub.NewStockQuoteRecordStream(entity_pb2.Void())

????# 用For循环就可以不断消费数据

????for Result in StreamResult:

????????print(Result)

if __name__ == '__main__':

????# 可以使用多线程并发接收推送数据

????ThreadOne = threading.Thread(target=tick_record_stream)

????ThreadTwo = threading.Thread(target=order_record_stream)

????ThreadThree = threading.Thread(target=order_queue_record_stream)

????ThreadFour = threading.Thread(target=stock_quote_record_stream)

????# 多进程并发接收推送数据

????# ProcessOne = Process(target=tick_record_stream)

????# ProcessTwo = Process(target=order_record_stream)

????# ProcessThree = Process(target=order_queue_record_stream)

????# ProcessFour = Process(target=stock_quote_record_stream)

????# 这设置为随主线程退出子线程,避免产生孤儿或僵尸线程

????ThreadOne.daemon = True

????ThreadTwo.daemon = True

????ThreadThree.daemon = True

????ThreadFour.daemon = True

????# ProcessOne.daemon = True

????# ProcessTwo.daemon = True

????# ProcessThree.daemon = True

????# ProcessFour.daemon = True

????# 有一点值得注意一下,假如订阅的股票相对活跃,推送的数据就不会有休眠的状态出现,因为Python的GIL锁,所以用多线程接收推送效率不显著,这个时候可以考虑用多进程来接收推送

????ThreadOne.start()

????ThreadTwo.start()

????ThreadThree.start()

????ThreadFour.start()

????# ProcessOne.start()

????# ProcessTwo.start()

????# ProcessThree.start()

????# ProcessFour.start()

????ThreadOne.join()

????ThreadTwo.join()

????ThreadThree.join()

????ThreadFour.join()

????# ProcessOne.join()

????# ProcessTwo.join()

????# ProcessThree.join()

????# ProcessFour.join()