# 通源推送文档V1.0

**Repository Path**: linknet/ws_document

## Basic Information

- **Project Name**: 通源推送文档V1.0
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-04-08
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

```
# python演示代码
# Be sure to pip install websocket-client
# Details: https://pypi.org/project/websocket-client/

import websocket

def on_message(ws, message):
    print(message)

def on_error(ws, error):
    print(error)

def on_close(ws):
    print("### closed ###")

def on_open(ws):
  # 订阅消息解释 
  # 交易所 HKEX:港交所 SSE:上交所 SZSE:深交所
  # 证券类型 1:股票 2:指数
  # T:交易数据 Q:行情数据
  # 股票代码 00001
  # 多条订阅英文,隔开
  # 详细请查询市场对照表
  ws.send('{"action":"SUBSCRIBE","symbols":"HKEX|1|T|00001,HKEX|1|Q|00001"}')
  # 取消订阅消息 
  ws.send('{"action":"DELSUBSCRIBE","symbols":"HKEX|1|T|00001,HKEX|1|Q|00001"}')
  # 心跳包 30s发送一次心跳包
  ws.send('{"action":"PING"}')

if __name__ == "__main__":
    # websocket.enableTrace(True)
    ws = websocket.WebSocketApp("ws://{host}/{vhost}?appId={appId}&appSecret={appSecret}",
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close)
    ws.on_open = on_open
    ws.run_forever()
```

##### date 数据解释 (**data数据英文 | 隔开**)

**市场SSE返回消息格式**

`
市场|证券类型|最新交易时间|证券代码|收盘价|开盘价|最高价|最低价|最新价|成交量|成交额|买量|平均买价|卖量|平均卖价|买一价|买一数|买一量|....
`

**市场SZSE返回消息格式**

`
市场|证券类型|最新交易时间|证券代码|交易状态|收盘价|开盘价|最新价|最高价|最低价|涨停价|跌停价|成交量|成交额|市盈率1|市盈率2|买量|平均买价|卖量|平均卖价|买一价|买一数|买一量|....
`

**市场HKEX返回消息格式**

`
市场|证券类型|最新交易时间|证券代码|证券名称|成交量|剩余量|持仓量|结算价|收盘价|开盘价|最高价|最低价|最新价|成交量|成交额|买一价|买一量|....
`