Skip to content

Emptyset110/SinaL2

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

17 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

SinaL2

从dHydra框架( https://github.com/Emptyset110/dHydra ) 中抽离出来的获取Sina Level2行情/逐笔的类

注意事项

  • 在新浪购买Level2数据时有声明,禁止恶意抓取,不保证在云服务器的可用性,数据可靠性与使用方式的最终解释权属于新浪。 dHydra不拥有任何解释权。
  • 由于这是直接从dHydra中去耦合抽离出来的逻辑,为了省事我并没有去掉安装时候的依赖包。(比如依赖了pandas这种大的安装包,个人认为装一下也没什么不好,虽然基本用不到)
  • 最后,还是建议采用dHydra框架,对于高频数据的处理做好了redis消息队列与多进程处理数据的解决方案
  • 采用Apache开源协议

使用方法

用pip安装

pip install SinaL2

或者

git clone https://github.com/Emptyset110/SinaL2.git
cd SinaL2

在运行当前目录新建文件sina.json来配置你的新浪帐号信息(需要在新浪购买Level2,普及版或标准版通用)

{
	"username":"",
	"password":""
}

使用范例

# -*- coding: utf-8 -*-
from SinaL2 import SinaL2
import threading
import time
import SinaL2.util as util


def on_recv_data(message):
    print(util.ws_parse(message=message, to_dict=True))
    # 这里用util.ws_parse来解析字符串了,并且转为一个包含dict的list输出

def start_sina_l2():
    sina_l2 = SinaL2(symbols=["sz000001","sh600221"], on_recv_data=on_recv_data, query=["quotation","transaction","orders"])
    sina_l2.start()

t = threading.Thread(target=start_sina_l2, daemon=True)
t.start()

while True:
    # 目的是让主线程不退出
    time.sleep(10)

详细参数说明还是参考( https://github.com/Emptyset110/dHydra )或者( http://doc.dhydra.org )

About

Level2 from dHydra

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Contributors 3

  •  
  •  
  •  

Languages