阿根廷股市API（BCBA）實時行情解析與歷史數據獲取指南

      import requests
import datetime

# ---------- 配置你的API Token ----------
API_TOKEN = "你的iTick_API_Token"  # 替換為真實Token
BASE_URL = "https://api.itick.org"

# ---------- 阿根廷BCBA實時行情請求 ----------
def get_bcba_quote(symbol, region="AR"): 
    headers = {
        "accept": "application/json",
        "token": API_TOKEN
    }
    url = f"{BASE_URL}/stock/quote?region={region}&code={symbol}"
    
    try:
        response = requests.get(url, headers=headers, timeout=3)
        response.raise_for_status()
        result = response.json()
        
        if result.get("code") == 0:  # 業務狀態碼0表示成功
            data = result["data"]
            return data
        else:
            print(f"API錯誤: {result.get('msg')}")
            return None
    except Exception as e:
        print(f"請求異常: {str(e)}")
        return None

# ---------- 調用示例：阿根廷YPF ----------
quote = get_bcba_quote("YPFD")  # YPF在BCBA的代碼為YPFD
if quote:
    print("="*50)
    print("🇦🇷 阿根廷BCBA實時行情")
    print("="*50)
    print(f"股票代碼 : {quote.get('s')}")
    print(f"最新價  : {quote.get('ld')} ARS")
    print(f"漲跌    : {quote.get('ch')} ({quote.get('chp')}%)")
    print(f"成交量  : {quote.get('v')}")
    
    # 時間戳轉換（毫秒）
    ts = quote.get('t') / 1000
    dt = datetime.datetime.fromtimestamp(ts)
    print(f"數據時間: {dt.strftime('%Y-%m-%d %H:%M:%S')}")

    

      import requests
import pandas as pd

def get_bcba_kline(symbol, region="AR", ktype="8", limit=30):
    """
    kType參數說明（iTick標準）：
    "1": 1分鐘, "2": 5分鐘, "3": 15分鐘, "4": 30分鐘,
    "5": 60分鐘, "8": 日線, "9": 週線, "10": 月線
    """
    headers = {
        "accept": "application/json",
        "token": API_TOKEN
    }
    url = f"{BASE_URL}/stock/kline?region={region}&code={symbol}&kType={ktype}&limit={limit}"
    
    response = requests.get(url, headers=headers)
    result = response.json()
    
    if result.get("code") == 0:
        kline_list = result.get("data", [])
        return kline_list
    else:
        print(f"獲取K線失敗: {result.get('msg')}")
        return []

# ---------- 獲取數據並轉為DataFrame ----------
kdata = get_bcba_kline("GGAL", ktype="8", limit=30)

if kdata:
    df = pd.DataFrame(kdata)
    # 轉換時間戳
    df['datetime'] = pd.to_datetime(df['t'], unit='ms')
    # 選擇並重命名字段
    df = df[['datetime', 'o', 'h', 'l', 'c', 'v']]
    df.columns = ['日期時間', '開盤', '最高', '最低', '收盤', '成交量']
    
    print(f"\n✅ 獲取到 {len(df)} 條阿根廷GGAL日K線數據")
    print(df.head(10).to_string(index=False))
    
    # 保存至CSV（供回測使用）
    df.to_csv('GGAL_BCBA_daily.csv', index=False, encoding='utf-8-sig')
    print("📁 數據已保存至 GGAL_BCBA_daily.csv")

    

      import websocket
import json
import threading
import time

# ---------- WebSocket配置 ----------
WS_URL = "wss://api.itick.org/stock"  # 股票市場WebSocket入口
API_TOKEN = "你的iTick_API_Token"

def on_message(ws, message):
    """接收推送數據"""
    data = json.loads(message)
    if data.get("data"):
        market_data = data["data"]
        data_type = market_data.get("type")  # quote/tick/depth
        symbol = market_data.get("s")
        
        if data_type == "quote":
            print(f"[{time.strftime('%H:%M:%S')}] {symbol} 最新價: {market_data.get('ld')} 漲跌: {market_data.get('chp')}%")

def on_open(ws):
    """連接成功後的訂閱操作"""
    print("✅ WebSocket 連接成功，正在訂閱阿根廷股票...")
    subscribe_msg = {
        "ac": "subscribe",
        "params": "YPFD$AR,GGAL$AR,MELI$AR",  # 阿根廷三巨頭
        "types": "quote"  # 僅訂閱報價
    }
    ws.send(json.dumps(subscribe_msg))
    print("📡 訂閱請求已發送")

def send_ping(ws):
    """心跳維持（每30秒）"""
    while True:
        time.sleep(30)
        ping_msg = {"ac": "ping", "params": str(int(time.time() * 1000))}
        ws.send(json.dumps(ping_msg))

# ---------- 啟動WebSocket ----------
def start_websocket():
    ws = websocket.WebSocketApp(
        WS_URL,
        header={"token": API_TOKEN},
        on_open=on_open,
        on_message=on_message
    )
    
    # 心跳線程
    ping_thread = threading.Thread(target=send_ping, args=(ws,))
    ping_thread.daemon = True
    ping_thread.start()
    
    # 阻塞運行
    ws.run_forever()

if __name__ == "__main__":
    start_websocket()