CFD即所謂的差價合約，是投資者在不擁有實際資產的情況下，交易金融市場的一種方式。最近筆者研究這一塊比較多，但查遍整個中文互聯網卻很少找到關于CFD實時行情的查詢教程。因此有了這篇文章。以下我將通過一個簡單的Python代碼示例，逐步教你如何查詢CFD指數的實時行情。

行情接口信息

首先，確保你有一個有效的API接口，我們這里用Infoway API作為演示，該接口能夠返回所需的CFD指數實時數據。請求地址如下：

https://data.infoway.io/common/batch_trade/HK50%2CCN50%2CEUSTX50%2CJPN225%2CUS30%2CUS500

這個接口支持批量查詢，所以我們一次性查多個市場的。這個URL包含了多個CFD指數的數據：HK50, CN50, EUSTX50, JPN225, US30, 和 US500。這些指數代表了不同的市場，涵蓋了香港、中國、歐洲、日本和美國等多個區域。

請求示例

現在，我們已經準備好發送HTTP請求來獲取實時行情數據。以下是完整的Python代碼示例：

import requestsurl = "https://data.infoway.io/common/batch_trade/HK50%2CCN50%2CEUSTX50%2CJPN225%2CUS30%2CUS500"# 申請API KEY: www.infoway.io
headers = {"accept": "application/json",  # 告訴服務器返回的數據格式為JSON"apiKey": "YOUR_API_KEY"  # 你的API Key
}# 發送GET請求
response = requests.get(url, headers=headers)# 打印響應內容
print(response.text)

解析API響應

當你發送請求后，API會返回一個包含行情數據的響應。以下是一個示例響應：

{"ret": 200,"msg": "success","traceId": "9708dde2-67af-4be6-ad08-c2bc51a44aa3","data": [{"s": "EUSTX50","t": 1752762978999,"p": "5362.84","v": "1.0","vw": "5362.840","td": 0},{"s": "US500","t": 1752762980117,"p": "6277.8","v": "1.0","vw": "6277.80","td": 0},{"s": "CN50","t": 1752762978999,"p": "13730.68","v": "1.0","vw": "13730.680","td": 0},{"s": "US30","t": 1752762978661,"p": "44303.5","v": "2.0","vw": "88607.00","td": 0},{"s": "HK50","t": 1752762980117,"p": "24530.0","v": "1.0","vw": "24530.00","td": 0},{"s": "JPN225","t": 1752762976348,"p": "39894.0","v": "1.0","vw": "39894.00","td": 0}]
}

從響應中，我們可以提取出不同CFD指數的實時數據。每個指數都包含以下信息：

• s: 指數代碼（如EUSTX50表示歐洲指數）
• t: 時間戳
• p: 當前價格
• v: 成交量
• vw: 加權平均價格
• td: 代表交易方向，0為默認值，1為Buy，2為SELL

打印和處理數據

如果你希望進一步處理或格式化數據，可以使用以下代碼來提取和打印每個CFD指數的價格信息：

# 獲取返回的JSON數據
data = response.json()['data']# 遍歷并打印每個CFD指數的代碼和當前價格
for index in data:print(f"指數: {index['s']}, 當前價格: {index['p']}")

運行此代碼，你將會看到類似如下的輸出：

指數: EUSTX50, 當前價格: 5362.84
指數: US500, 當前價格: 6277.8
指數: CN50, 當前價格: 13730.68
指數: US30, 當前價格: 44303.5
指數: HK50, 當前價格: 24530.0
指數: JPN225, 當前價格: 39894.0

WebSocket訂閱CFD指數

如果你的交易策略對數據的延遲有更高的要求，可以改用WebSocket訂閱的方式來獲取數據。我們只需要與服務器建立好連接，就能源源不斷地從服務器獲取數據推送，代碼如下：

import asyncio
import json
import websockets#WebSocket訂閱連接
WS_URL = "wss://data.infoway.io/ws?business=common&apikey=YOUR_API_KEY"#申請API KEY: www.infoway.ioasync def connect_and_receive():async with websockets.connect(WS_URL) as websocket:# 發送初始消息，訂閱多個CFD指數init_message = {"code": 10000,"trace": "01213e9d-90a0-426e-a380-ebed633cba7a","data": {"codes": ["HK50", "CN50", "EUSTX50", "JPN225", "US30", "US500"]}}await websocket.send(json.dumps(init_message))# 設置ping任務async def send_ping():while True:await asyncio.sleep(30)ping_message = {"code": 10010,"trace": "01213e9d-90a0-426e-a380-ebed633cba7a"}await websocket.send(json.dumps(ping_message))# 啟動ping任務協程ping_task = asyncio.create_task(send_ping())try:# 持續接收消息while True:message = await websocket.recv()print(f"Message received: {message}")except websockets.exceptions.ConnectionClosedOK:print("Connection closed normally")finally:# 取消ping任務ping_task.cancel()# 運行主函數
asyncio.run(connect_and_receive())