Unable to receive mark price Kline data stream

[wanghaora]

I followed the official Binance documentation strictly:
Binance Documentation (Mark Price Kline Streams)

However, when I subscribe to @markprice@1s, I can receive data without any problem.
But when I subscribe to @markPriceKline_, there is no output at all.

Could you please clarify why this is happening? Is there a missing step or a bug in the SDK?

@markPriceKline_
https://developers.binance.com/docs/zh-CN/derivatives/coin-margined-futures/websocket-market-streams/Mark-Price-Kline-Candlestick-Streams

`import os
import json
import asyncio
import websockets
from dotenv import load_dotenv

dotenv_file = ".env.prod"
load_dotenv(dotenv_file)

API_KEY = os.getenv("BINANCE_API_KEY")
API_SECRET = os.getenv("BINANCE_API_SECRET")

async def mark_price_stream(symbol="bnbusdt", stream_type="markPriceKline_1m"):
"""
"""
url = f"wss://fstream.binance.com/ws/{symbol}@{stream_type}"
print(f"✅ 已连接到 {url}")

async with websockets.connect(url) as ws:
    while True:
        try:
            message = await asyncio.wait_for(ws.recv(), timeout=60)
            data = json.loads(message)
            print(f"[{symbol.upper()}] 收到消息类型: {stream_type}")

            # === 如果是K线流 ===
            if "k" in data:
                k = data["k"]
                print(
                    f"🕒 [{symbol.upper()}] 开:{k['o']} 高:{k['h']} 低:{k['l']} 收:{k['c']} 收线:{k['x']}"
                )
            # === 如果是标记价格1s流 ===
            elif "p" in data and "i" in data:
                print(f"💰 [{symbol.upper()}] 标记价: {data['p']} 时间: {data['E']}")
            else:
                print(f"[{symbol.upper()}] 收到其他消息: {data}")

        except asyncio.TimeoutError:
            print(f"[{symbol.upper()}] ⏳ 等待中... 暂无新数据")

async def main():
await asyncio.gather(
# 每秒标记价格流
# mark_price_stream("btcusdt", "markPrice@1s"),
# 每分钟标记价格K线流
mark_price_stream("ethusdt", "markPriceKline_1m"),
mark_price_stream("ethusdt", "markPriceKline_1h"),
mark_price_stream("bnbusdt", "markPriceKline_1s"),
mark_price_stream("bnbusdt", "markPriceKline_15m"),
mark_price_stream("bnbusdt", "markPriceKline_15m"),
# 你可以添加更多币种
# mark_price_stream("bnbusdt", "markPrice@1s"),
)

if name == "main":
asyncio.run(main())
`

[wanghaora]

uv add binance-sdk-derivatives-trading-usds-futures

import os
import json
import asyncio
import websockets
from dotenv import load_dotenv

dotenv_file = ".env.prod"
load_dotenv(dotenv_file)

API_KEY = os.getenv("BINANCE_API_KEY")
API_SECRET = os.getenv("BINANCE_API_SECRET")

async def mark_price_stream(symbol="bnbusdt", stream_type="markPriceKline_1m"):
"""
"""
url = f"wss://fstream.binance.com/ws/{symbol}@{stream_type}"
print(f"✅ 已连接到 {url}")

async with websockets.connect(url) as ws:
    while True:
        try:
            message = await asyncio.wait_for(ws.recv(), timeout=60)
            data = json.loads(message)
            print(f"[{symbol.upper()}] 收到消息类型: {stream_type}")

            # === 如果是K线流 ===
            if "k" in data:
                k = data["k"]
                print(
                    f"🕒 [{symbol.upper()}] 开:{k['o']} 高:{k['h']} 低:{k['l']} 收:{k['c']} 收线:{k['x']}"
                )
            # === 如果是标记价格1s流 ===
            elif "p" in data and "i" in data:
                print(f"💰 [{symbol.upper()}] 标记价: {data['p']} 时间: {data['E']}")
            else:
                print(f"[{symbol.upper()}] 收到其他消息: {data}")

        except asyncio.TimeoutError:
            print(f"[{symbol.upper()}] ⏳ 等待中... 暂无新数据")

async def main():
await asyncio.gather(
# 每秒标记价格流
# mark_price_stream("btcusdt", "markPrice@1s"),
# 每分钟标记价格K线流
mark_price_stream("ethusdt", "markPriceKline_1m"),
mark_price_stream("ethusdt", "markPriceKline_1h"),
mark_price_stream("bnbusdt", "markPriceKline_1s"),
mark_price_stream("bnbusdt", "markPriceKline_15m"),
mark_price_stream("bnbusdt", "markPriceKline_15m"),
# 你可以添加更多币种
# mark_price_stream("bnbusdt", "markPrice@1s"),
)

if name == "main":
asyncio.run(main())

[alplabin]

Hi @wanghaora, the stream @markPriceKline is used in derivatives trading COIN M and not in derivatives trading USDS M. Therefore, the base endpoint should be wss://dstream.binancefuture.com.
Please note that the bnbusdt symbol is not available in derivatives trading COIN M.

[wanghaora]

Hi @wanghaora, the stream @markPriceKline is used in derivatives trading COIN M and not in derivatives trading USDS M. Therefore, the base endpoint should be wss://dstream.binancefuture.com. Please note that the bnbusdt symbol is not available in derivatives trading COIN M.

I’ve modified the code, but there’s still no output. Could you please help me by providing an example?
I just want to get the mark price Kline data for use in TradingView alerts. The data shown on TradingView is the mark price of the coin-margined contracts. Is there a WebSocket Kline data stream available for that?

`import os
import json
import asyncio
import websockets
from dotenv import load_dotenv

dotenv_file = ".env.prod"
load_dotenv(dotenv_file)

API_KEY = os.getenv("BINANCE_API_KEY")
API_SECRET = os.getenv("BINANCE_API_SECRET")

def get_stream_url(symbol, stream_type):
"""
Automatically select the correct WebSocket server based on the symbol:
- USDT-margined: fstream
- COIN-margined: dstream
"""
symbol_lower = symbol.lower()
if "usdt" in symbol_lower:
base = "wss://fstream.binance.com"
elif "usd" in symbol_lower:
base = "wss://dstream.binancefuture.com"
else:
raise ValueError(f"Unrecognized contract type: {symbol}")
return f"{base}/ws/{symbol_lower}@{stream_type}"

async def mark_price_stream(symbol="btcusdt", stream_type="markPriceKline_1m"):
"""
Subscribe to a single mark price or Kline (candlestick) stream
"""
url = get_stream_url(symbol, stream_type)
print(f"✅ Connecting to {symbol.upper()} stream: {url}")

while True:
    try:
        async with websockets.connect(url) as ws:
            print(f"🔗 Connected to {symbol.upper()} @ {stream_type}")
            while True:
                message = await asyncio.wait_for(ws.recv(), timeout=60)
                data = json.loads(message)

                # === Mark Price Kline Stream ===
                if "k" in data:
                    k = data["k"]
                    print(
                        f"📊 [{symbol.upper()}] "
                        f"Open:{k['o']} High:{k['h']} Low:{k['l']} Close:{k['c']} Closed:{k['x']}"
                    )
                # === Mark Price Stream ===
                elif "p" in data and "E" in data:
                    print(f"💰 [{symbol.upper()}] Mark Price: {data['p']} Time: {data['E']}")
                else:
                    print(f"[{symbol.upper()}] Received other message: {data}")

    except asyncio.TimeoutError:
        print(f"⏳ [{symbol.upper()}] Timeout waiting for data, reconnecting...")
    except Exception as e:
        print(f"⚠️ [{symbol.upper()}] Error: {e}, reconnecting in 5 seconds...")
        await asyncio.sleep(5)

async def main():
await asyncio.gather(
# --- USDT-Margined Futures ---
# mark_price_stream("btcusdt", "markPrice@1s"),
mark_price_stream("btcusdt", "markPriceKline_15m"),

    # --- COIN-Margined Futures ---
    mark_price_stream("btcusd_200626", "markPriceKline_1m"),
    mark_price_stream("btcusd_perpetual", "markPriceKline_1m"),
)

if name == "main":
asyncio.run(main())
`

[alplabin]

Hi @wanghaora, sorry, here is the right base url: wss://dstream.binance.com.

Additionally, markPriceKline is not supported for USDT-Margined Futures, and the symbols btcusd_200626 and btcusd_perpetual are not available in COIN-Margined Futures.

Your code should look like this:

import os
import json
import asyncio
import websockets

def get_stream_url(symbol, stream_type):
    """
    Automatically select the correct WebSocket server based on the symbol:
    - USDT-margined: fstream
    - COIN-margined: dstream
    """
    symbol_lower = symbol.lower()
    if "usdt" in symbol_lower:
        base = "wss://fstream.binance.com"
    elif "usd" in symbol_lower:
        base = "wss://dstream.binance.com"
    else:
        raise ValueError(f"Unrecognized contract type: {symbol}")
    return f"{base}/ws/{symbol_lower}@{stream_type}"

async def mark_price_stream(symbol="btcusdt", stream_type="markPriceKline_1m"):
    """
    Subscribe to a single mark price or Kline (candlestick) stream
    """
    url = get_stream_url(symbol, stream_type)
    print(f"✅ Connecting to {symbol.upper()} stream: {url}")

    while True:
        try:
            async with websockets.connect(url) as ws:
                print(f"🔗 Connected to {symbol.upper()} @ {stream_type}")
                while True:
                    message = await asyncio.wait_for(ws.recv(), timeout=60)
                    data = json.loads(message)

                    # === Mark Price Kline Stream ===
                    if "k" in data:
                        k = data["k"]
                        print(
                            f"📊 [{symbol.upper()}] "
                            f"Open:{k['o']} High:{k['h']} Low:{k['l']} Close:{k['c']} Closed:{k['x']}"
                        )
                    # === Mark Price Stream ===
                    elif "p" in data and "E" in data:
                        print(f"💰 [{symbol.upper()}] Mark Price: {data['p']} Time: {data['E']}")
                    else:
                        print(f"[{symbol.upper()}] Received other message: {data}")

        except asyncio.TimeoutError:
            print(f"⏳ [{symbol.upper()}] Timeout waiting for data, reconnecting...")
        except Exception as e:
            print(f"⚠️ [{symbol.upper()}] Error: {e}, reconnecting in 5 seconds...")
            await asyncio.sleep(5)

async def main():
    await asyncio.gather(
        # --- USDT-Margined Futures ---
        mark_price_stream("btcusdt", "markPrice@1s"),

        # --- COIN-Margined Futures ---
        mark_price_stream("btcusd_251226", "markPriceKline_1m"),
        mark_price_stream("btcusd_perp", "markPriceKline_1m"),
    )

if __name__ == "__main__":
    asyncio.run(main())