WebSocket을 사용한 실시간 금융 데이터 스트리밍
4518 단어 datasciencepythontutorial
WebSocket은 차트 애플리케이션, 포트폴리오 관리 및 알고리즘 거래 시스템과 같이 정확한 실시간 데이터에 의존하는 앱의 중요한 부분일 수 있습니다.
준비
서비스Twelve Data를 사용하게 됩니다. WebSocketsusage에 적합하도록 API 키를 업그레이드했는지 확인하십시오.
Python 사용자의 경우 라이브러리
pip install twelvedata
- GitHub 를 설치하십시오.파이썬
먼저 새 데이터를 수신할 때 사용할 함수를 정의합니다.
def on_event(e):
print(e)
이 기능은 논리에 따라 가격 업데이트, 레코드 업데이트, 변경 사항 표시 등의 연속 작업을 수행해야 합니다.
Remember that all data received is in
json
format or to be more precise adict
object.
메인 블록은
TDClient
객체를 초기화하고 서버에 연속 연결을 수행해야 합니다.from twelvedata import TDClient
td = TDClient('your_api_key')
ws = td.websocket(symbols=['BTC/USD', 'AAPL', 'EUR/USD'], on_event=on_event)
ws.connect()
ws.keep_alive()
WebSocket은 다음 메서드를 지원합니다.
subscribe
- 포함할 새 심볼.unsubscribe
- 구독에서 이전 기호를 제거합니다.reset
- 모든 기호를 구독 취소합니다.connect
- 서버와의 새 연결을 엽니다.disconnect
- 서버와의 기존 연결을 닫습니다.keep_alive
- 무한 루프를 실행하여 모든 데이터를 수신합니다.응답
이에 대한 응답으로 기본 메타 정보, 틱 가격 및 일일 거래량이 포함된 개체를 받게 됩니다. 예:
{'event': 'price', 'symbol': 'BTC/USD', 'currency_base': 'Bitcoin', 'currency_quote': 'US Dollar', 'exchange': 'Binance', 'type': 'Digital Currency', 'timestamp': 1600595462, 'price': 10964.8, 'day_volume': 38279}
Do not forget about market open hours, for instance over the weekends only crypto markets are opened.
평균 대기 시간은 약 ~150ms이므로 데이터를 안정적으로 사용하고 모든 용도에 적용할 수 있습니다. 또한 단일 형식을 사용하면 다양한 유형의 자산에서 데이터를 유연하게 스트리밍할 수 있습니다.
이제 애플리케이션에 쉽게 사용할 수 있습니다. 차트.
Reference
이 문제에 관하여(WebSocket을 사용한 실시간 금융 데이터 스트리밍), 우리는 이곳에서 더 많은 자료를 발견하고 링크를 클릭하여 보았다 https://dev.to/midassss/real-time-financial-data-streaming-using-websockets-4phb텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
우수한 개발자 콘텐츠 발견에 전념 (Collection and Share based on the CC Protocol.)