xing-tick-crawler
설치
pip install xing-tick-crawler
사용예시
1. config.py 파일 생성 및 설정
config = {
"id" : "my_id" , # xing api 아이디
"password" : "my_password" , # xing api 패스워드
"cert_password" : "my_cert_password" , # 공동인증서 비밀번호
}
RES_FOLDER_PATH = "C:/eBEST/xingAPI/Res" # xing_tick_crawler Res 파일 폴더 위치
TICKER_DATA_FOLDER_PATH = "." # tick 데이터 저장할 위치
2. main.py 생성 및 실행
"""
크롤러 1 구독옵션 (기본값 All True)
- STOCK_VI_ON_OFF
- KOSPI_ORDER_BOOK
- KOSPI_AFTER_MARKET_ORDER_BOOK
- KOSPI_AFTER_MARKET_TICK
- KOSPI_BROKER_INFO
- STOCK_FUTURES_ORDER_BOOK
- STOCK_FUTURES_TICK
크롤러 2 구독옵션 (기본값 All True)
- KOSDAQ_ORDER_BOOK
- KOSDAQ_AFTER_MARKET_ORDER_BOOK
- KOSDAQ_AFTER_MARKET_TICK
- KOSDAQ_BROKER_INFO
"""
from xing_tick_crawler .crawler import crawler_1 , crawler_2 , crawl_kospi_tick , crawl_kosdaq_tick
from datetime import datetime
from multiprocessing import Process , get_context
from multiprocessing .queues import Queue
if __name__ == "__main__" :
crawler_1_subs_option = {
# 주식 VI 정보 off
'STOCK_VI_ON_OFF' : False ,
}
crawler_2_subs_option = {
}
queue = Queue (ctx = get_context ())
p1 = Process (target = crawl_kospi_tick , args = (queue ,))
p2 = Process (target = crawl_kosdaq_tick , args = (queue ,))
p3 = Process (target = crawler_1 , args = (queue ,), kwargs = crawler_1_subs_option )
p4 = Process (target = crawler_2 , args = (queue ,), kwargs = crawler_2_subs_option )
p1 .start ()
p2 .start ()
p3 .start ()
p4 .start ()
while True :
tick = queue .get ()
waiting_tasks = queue .qsize ()
tick_type , tick_data = tick
print (f"\r { datetime .now ()} waiting tasks : { '%6d' % waiting_tasks } " , end = '' )
print (tick_type , tick_data )
구현 Real 목록
주식시장
선물옵션시장