TASE 以色列股市 API 接口详解：获取股票数据、行情与量化对接

      import requests

# 配置你的 API 密钥
API_TOKEN = "your_token_here"
headers = {
    "accept": "application/json",
    "token": API_TOKEN
}

# 定义请求参数
# 实际使用时请参考 iTick 官方产品列表获取正确的 code
region = "IL"
code = "TEVA"

url = f"https://api.itick.org/stock/quote?region={region}&code={code}"

try:
    response = requests.get(url, headers=headers)
    if response.status_code == 200:
        data = response.json().get('data', {})
        print(f"股票: {code}.{region}")
        print(f"最新价: {data.get('ld')}")          # latest price
        print(f"涨跌幅: {data.get('chp')}%")        # change percent
        print(f"开盘价: {data.get('o')}")           # open price
        print(f"最高价: {data.get('h')}")           # high price
        print(f"最低价: {data.get('l')}")           # low price
        print(f"成交量: {data.get('v')}")           # volume
    else:
        print(f"请求失败，状态码: {response.status_code}, 错误: {response.text}")
except Exception as e:
    print(f"网络异常: {e}")

    

      import requests
import pandas as pd

API_TOKEN = "your_token_here"
headers = {
    "accept": "application/json",
    "token": API_TOKEN
}

# 获取以色列股票的日线数据
region = "IL"
code = "TEVA"  # 示例代码
kType = "8"    # 8 代表日线
limit = "100"  # 获取最近100根

url = f"https://api.itick.org/stock/kline?region={region}&code={code}&kType={kType}&limit={limit}"

response = requests.get(url, headers=headers)

if response.status_code == 200:
    kline_data = response.json().get('data', [])
    if kline_data:
        # 将数据转换为 pandas DataFrame，便于分析
        df = pd.DataFrame(kline_data)
        # 通常返回的字段包括：t(时间), o(开), h(高), l(低), c(收), v(量)
        df = df.rename(columns={'t': 'timestamp', 'o': 'open', 'h': 'high', 'l': 'low', 'c': 'close', 'v': 'volume'})
        df['timestamp'] = pd.to_datetime(df['timestamp'], unit='s')  # 转换时间戳
        print(df[['timestamp', 'open', 'high', 'low', 'close', 'volume']].head())
    else:
        print("未获取到数据")
else:
    print("请求失败")

    

      import websocket
import json
import threading

WS_URL = "wss://api.itick.org/stock"  # 股票行情WebSocket地址
API_TOKEN = "your_token_here"

def on_open(ws):
    """连接建立后，发送订阅消息"""
    print("连接已打开，正在订阅TASE股票...")

    # 订阅消息：订阅以色列市场的TEVA股票的报价(quote)和成交(tick)
    subscribe_msg = {
        "ac": "subscribe",
        "params": "TEVA$IL",  # 格式：代码$市场
        "types": "quote,tick"   # 订阅数据类型：报价和逐笔成交
    }
    ws.send(json.dumps(subscribe_msg))

def on_message(ws, message):
    """处理收到的实时数据"""
    data = json.loads(message)
    # 这里可以添加你的策略逻辑
    print(f"实时数据: {data}")

def on_error(ws, error):
    print(f"错误: {error}")

def on_close(ws, close_status_code, close_msg):
    print("连接已关闭")

if __name__ == "__main__":
    # 在header中传递token
    ws = websocket.WebSocketApp(WS_URL,
                                header={"token": API_TOKEN},
                                on_open=on_open,
                                on_message=on_message,
                                on_error=on_error,
                                on_close=on_close)

    # 在后台线程中运行WebSocket客户端，避免阻塞主线程
    wst = threading.Thread(target=ws.run_forever)
    wst.start()

    # 这里可以继续执行其他任务
    try:
        while True:
            # 主线程保持运行
            pass
    except KeyboardInterrupt:
        ws.close()

    

      # 假设我们已经通过 REST API 获取了 TASE 股票的日线数据并存在 df 中
# df 包含 'close' 列

import talib

# 计算短期和长期移动平均线
df['MA_Short'] = talib.SMA(df['close'], timeperiod=20)
df['MA_Long'] = talib.SMA(df['close'], timeperiod=60)

# 获取最新两条数据判断金叉/死叉
if df['MA_Short'].iloc[-2] <= df['MA_Long'].iloc[-2] and df['MA_Short'].iloc[-1] > df['MA_Long'].iloc[-1]:
    print("金叉信号出现！考虑买入 TASE 股票")
    signal = "BUY"
elif df['MA_Short'].iloc[-2] >= df['MA_Long'].iloc[-2] and df['MA_Short'].iloc[-1] < df['MA_Long'].iloc[-1]:
    print("死叉信号出现！考虑卖出 TASE 股票")
    signal = "SELL"
else:
    signal = "HOLD"
    print("无明确信号，继续持有或观望")

# 此处可将信号接入你的交易系统