阿根廷股市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()