i can't get real data live

[infopinecodex-hue]

hi here is my code

from project_x_py import TradingSuite
from project_x_py.event_bus import EventType
import asyncio

async def on_new_bar(event):
    bar = event.data
    print(f"🕒 New {bar['timeframe']} bar - High: {bar['high']} Low: {bar['low']} Close: {bar['close']}")

async def setup_realtime():
    suite = await TradingSuite.create("NQ", timeframes=["1min"])
    await suite.connect()

    # Await because in your SDK .on is async
    await suite.events.on(EventType.NEW_BAR, on_new_bar)

    print(f"Connected to {suite.instrument.name}, waiting for first complete bar...")
    await asyncio.Event().wait()  # keep alive indefinitely

await setup_realtime()

but it does not show any things when we have new candle

[TexasCoding]

Have you updated to the latest version 3.1.5? There was an issue in a previous the previous release

[TexasCoding]

candle

Try updating to version 3.1.5 .. this was a bug in the previous release. I will make more examples that make this setup clearer later this evening

[infopinecodex-hue]

no not working this is your example in main page
but i found this example
this working

[infopinecodex-hue]

but even this which i made for just 1min timeframe with help of github example gives same output , not updating price

here is my code

import asyncio
import logging
from datetime import datetime
from typing import Any

from project_x_py import (
    EventType,
    TradingSuite,
)

logging.disable(logging.CRITICAL)  # Disables ALL 
logger = logging.getLogger(__name__)

async def display_current_price(data_manager: Any) -> None:
    """Display current price for 1min timeframe."""
    try:
        # Get 1min data
        data = await data_manager.get_data("1min")
        if data is not None and not data.is_empty():
            latest_bar = data.tail(1)
            for row in latest_bar.iter_rows(named=True):
                timestamp = row["timestamp"]
                high = row["high"]
                volume = row["volume"]
                time_str = timestamp.strftime("%H:%M:%S")
                print(f"1min Bar: ${high:.2f} @ {time_str} (Vol: {volume:,})")
        else:
            print("1min: Initializing or no data available")
    except Exception as e:
        print(f"Error getting price: {e}")

async def new_bar_callback(event: Any) -> None:
    """Handle new 1min bar creation."""
    data = event.data if hasattr(event, "data") else event
    if data.get("timeframe") == "1min":
        bar = data.get("data", {})
        timestamp = datetime.now().strftime("%H:%M:%S")
        if bar and "high" in bar and "volume" in bar:
            print(
                f"[{timestamp}] New 1min Bar: ${bar['high']:.2f} (Vol: {bar['volume']:,})"
            )

async def main() -> bool:
    """Main async real-time data streaming for NQ 1min."""
    print("runiing...")
    try:
        # Create TradingSuite with only 1min timeframe
        suite = await TradingSuite.create(
            instrument="NQ",
            timeframes=["1min"],  # Only 1min timeframe
            initial_days=5,
        )
        print("=" * 60)
        print(f"{suite.instrument.name} 1-MINUTE REAL-TIME DATA STREAMING")
        print("=" * 60)

        print("✅ Trading suite created for NQ 1min")
        data_manager = suite.data

        # Register callback for new 1min bars
        await suite.on(EventType.NEW_BAR, new_bar_callback)

        print("\n🔔 Listening for NQ 1-minute price updates...")
        print("Press Ctrl+C to stop streaming")
        print("=" * 60)

        # Monitoring task
        async def monitor_price() -> None:
            """Monitor and display price periodically."""
            while True:
                await asyncio.sleep(30)  # Update every 30 seconds
                await display_current_price(data_manager)

        try:
            await monitor_price()
        except KeyboardInterrupt:
            print("\n🛑 Stopping real-time data stream...")

    except Exception as e:
        logger.error(f"❌ Error in real-time data streaming: {e}")
        raise
    finally:
        if "suite" in locals():
            print("\n🧹 Cleaning up connections...")
            await suite.disconnect()
            print("✅ Cleanup completed!")

    print("\n✅ NQ 1-minute streaming completed!")
    return True

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

[TexasCoding]

but even this which i made for just 1min timeframe with help of github example gives same output , not updating price

here is my code

import asyncio

import logging

from datetime import datetime

from typing import Any



from project_x_py import (

    EventType,

    TradingSuite,

)



logging.disable(logging.CRITICAL)  # Disables ALL 

logger = logging.getLogger(__name__)



async def display_current_price(data_manager: Any) -> None:

    """Display current price for 1min timeframe."""

    try:

        # Get 1min data

        data = await data_manager.get_data("1min")

        if data is not None and not data.is_empty():

            latest_bar = data.tail(1)

            for row in latest_bar.iter_rows(named=True):

                timestamp = row["timestamp"]

                high = row["high"]

                volume = row["volume"]

                time_str = timestamp.strftime("%H:%M:%S")

                print(f"1min Bar: ${high:.2f} @ {time_str} (Vol: {volume:,})")

        else:

            print("1min: Initializing or no data available")

    except Exception as e:

        print(f"Error getting price: {e}")



async def new_bar_callback(event: Any) -> None:

    """Handle new 1min bar creation."""

    data = event.data if hasattr(event, "data") else event

    if data.get("timeframe") == "1min":

        bar = data.get("data", {})

        timestamp = datetime.now().strftime("%H:%M:%S")

        if bar and "high" in bar and "volume" in bar:

            print(

                f"[{timestamp}] New 1min Bar: ${bar['high']:.2f} (Vol: {bar['volume']:,})"

            )



async def main() -> bool:

    """Main async real-time data streaming for NQ 1min."""

    print("runiing...")

    try:

        # Create TradingSuite with only 1min timeframe

        suite = await TradingSuite.create(

            instrument="NQ",

            timeframes=["1min"],  # Only 1min timeframe

            initial_days=5,

        )

        print("=" * 60)

        print(f"{suite.instrument.name} 1-MINUTE REAL-TIME DATA STREAMING")

        print("=" * 60)



        print("✅ Trading suite created for NQ 1min")

        data_manager = suite.data



        # Register callback for new 1min bars

        await suite.on(EventType.NEW_BAR, new_bar_callback)



        print("\n🔔 Listening for NQ 1-minute price updates...")

        print("Press Ctrl+C to stop streaming")

        print("=" * 60)



        # Monitoring task

        async def monitor_price() -> None:

            """Monitor and display price periodically."""

            while True:

                await asyncio.sleep(30)  # Update every 30 seconds

                await display_current_price(data_manager)



        try:

            await monitor_price()

        except KeyboardInterrupt:

            print("\n🛑 Stopping real-time data stream...")



    except Exception as e:

        logger.error(f"❌ Error in real-time data streaming: {e}")

        raise

    finally:

        if "suite" in locals():

            print("\n🧹 Cleaning up connections...")

            await suite.disconnect()

            print("✅ Cleanup completed!")



    print("\n✅ NQ 1-minute streaming completed!")

    return True



if __name__ == "__main__":

    asyncio.run(main())

That looks like it would work. I had this issue last night and fixed it. But I did not push the example code. Currently I am at work and can not access exactly what the issues was. It was something simple though. When I get home I will make sure to update documentation on how to use this.

Unfortunately I do not have a lot of time to live test this package, so I hope you and others continue to use it to help work out any bugs. Thanks

[infopinecodex-hue]

Thanks a lot for creating this package and for taking the time to help! I really appreciate your effort, especially since you’re doing this in your limited free time. I’ll keep using it and share any bugs or feedback I find

[TexasCoding]

Sorry for the delay in addressing the fix for this issue.
You were trying to access the data from the event.data. This is not the full data, just the newest bar data. You need to use suite.data (data manager) to access the actual bar data.

But in doing this I discovered a bug in the event handler. When calling suite.data within a handler a deadlock was creating causing the method to freeze. This has been fixed and a v3.1.6 has been pushed.

I created a couple of simple examples showing ways to use events and getting bar data:
01_events_with_on.py

00_events_with_wait_for.py

[infopinecodex-hue]

thanks it works perfectly but there is another issue when i change symbol from MNQ to NQ or ES it does not update data

import asyncio
import signal

from project_x_py import TradingSuite
from project_x_py.event_bus import EventType

async def on_new_bar(suite: TradingSuite):
    current_price = await suite.data.get_current_price()
    last_bars = await suite.data.get_data(timeframe="1min", bars=5)
    print(f"\nCurrent price: {current_price}")
    print("=" * 80)

    if last_bars is not None and not last_bars.is_empty():
        print("Last 5 bars (oldest to newest):")
        print("-" * 80)

        # Get the last 5 bars and iterate through them
        for row in last_bars.tail(5).iter_rows(named=True):
            timestamp = row["timestamp"]
            open_price = row["open"]
            high = row["high"]
            low = row["low"]
            close = row["close"]
            volume = row["volume"]

            print(
                f"Time: {timestamp} | O: ${open_price:,.2f} | H: ${high:,.2f} | L: ${low:,.2f} | C: ${close:,.2f} | Vol: {volume:,}"
            )
    else:
        print("No bar data available yet")


async def main():
    suite = await TradingSuite.create(
        instrument="NQ",
        timeframes=["1min"],
    )

    await suite.connect()

    # Set up signal handler for clean exit
    shutdown_event = asyncio.Event()

    def signal_handler(signum, frame):
        print("\n\nReceived interrupt signal. Shutting down gracefully...")
        shutdown_event.set()

    signal.signal(signal.SIGINT, signal_handler)
    signal.signal(signal.SIGTERM, signal_handler)

    print(f"Monitoring {suite.instrument.name} 1min. Press CTRL+C to exit.\n")

    try:
        while not shutdown_event.is_set():
            try:
                # Wait for new bar with timeout to check shutdown event
                new_bar = await asyncio.wait_for(
                    suite.wait_for(EventType.NEW_BAR), timeout=1.0
                )
                if new_bar:
                    await on_new_bar(suite)
            except TimeoutError:
                # Timeout is expected, just check shutdown_event again
                pass
    finally:
        print("Disconnecting from real-time feeds...")
        await suite.disconnect()
        print("Clean shutdown complete.")


await main() 

i used await main() because i use deepnote that is not a problem i tested on local with asyncio.run(main()) no difrent

[TexasCoding]

Thanks for helping find these issues. This had never been an issue before, so I had just been testing with MNQ. But I created a bug that went unnoticed. The issue should be fixed now in v3.1.8

These examples should be working with micros and minis now:
01_events_with_on.py

00_events_with_wait_for.py

[infopinecodex-hue]

hi seems there is another issue i comparing price with Tradingview but it's not same (i tested for Nq and MNQ and my symbol in tradingview is NQU2025! , MNQ2025!)

# variables
Timeframe = "5min"
Symbol = "NQ"
import asyncio
import signal

from project_x_py import TradingSuite
from project_x_py.event_bus import EventType


async def on_new_bar(suite: TradingSuite):
    current_price = await suite.data.get_current_price()
    last_bars = await suite.data.get_data(timeframe=Timeframe, bars=2)
    print(f"\nCurrent price: {current_price}")
    print("=" * 80)

    if last_bars is not None and not last_bars.is_empty():
        print("Last 2 bars (oldest to newest):")
        print("-" * 80)

        # Get the last 2 bars and iterate through them
        for row in last_bars.tail(2).iter_rows(named=True):
            timestamp = row["timestamp"]
            open_price = row["open"]
            high = row["high"]
            low = row["low"]
            close = row["close"]
            volume = row["volume"]

            print(
                f"Time: {timestamp} | O: ${open_price:,.2f} | H: ${high:,.2f} | L: ${low:,.2f} | C: ${close:,.2f} | Vol: {volume:,}"
            )
    else:
        print("No bar data available yet")


async def main():
    suite = await TradingSuite.create(
        instrument=Symbol,
        timeframes=[Timeframe],
    )

    await suite.connect()

    # Set up signal handler for clean exit
    shutdown_event = asyncio.Event()

    def signal_handler(signum, frame):
        print("\n\nReceived interrupt signal. Shutting down gracefully...")
        shutdown_event.set()

    signal.signal(signal.SIGINT, signal_handler)
    signal.signal(signal.SIGTERM, signal_handler)

    print(f"Monitoring {suite.instrument.name} {Timeframe}. Press CTRL+C to exit.\n")

    try:
        while not shutdown_event.is_set():
            try:
                # Wait for new bar with timeout to check shutdown event
                new_bar = await asyncio.wait_for(
                    suite.wait_for(EventType.NEW_BAR), timeout=1.0
                )
                if new_bar:
                    await on_new_bar(suite)
            except TimeoutError:
                # Timeout is expected, just check shutdown_event again
                pass
    finally:
        print("Disconnecting from real-time feeds...")
        await suite.disconnect()
        print("Clean shutdown complete.")


await main()

[TexasCoding]

TradingView is using continuous contracts. But Project X currently does not have this as an option at least that I can see. They just have the current contracts. This is why the symbol names are different and why there are differences in prices as well. Now if there is a big difference there may be a problem. But when using TopStepx charts the prices are accurate, or at least have been.

I will do some investigating this evening. But futures data is strange and varies from platform to platform. And micro to mini

[TexasCoding]

hi seems there is another issue i comparing price with Tradingview but it's not same (i tested for Nq and MNQ and my symbol in tradingview is NQU2025! , MNQ2025!)

# variables
Timeframe = "5min"
Symbol = "NQ"
import asyncio
import signal

from project_x_py import TradingSuite
from project_x_py.event_bus import EventType


async def on_new_bar(suite: TradingSuite):
    current_price = await suite.data.get_current_price()
    last_bars = await suite.data.get_data(timeframe=Timeframe, bars=2)
    print(f"\nCurrent price: {current_price}")
    print("=" * 80)

    if last_bars is not None and not last_bars.is_empty():
        print("Last 2 bars (oldest to newest):")
        print("-" * 80)

        # Get the last 2 bars and iterate through them
        for row in last_bars.tail(2).iter_rows(named=True):
            timestamp = row["timestamp"]
            open_price = row["open"]
            high = row["high"]
            low = row["low"]
            close = row["close"]
            volume = row["volume"]

            print(
                f"Time: {timestamp} | O: ${open_price:,.2f} | H: ${high:,.2f} | L: ${low:,.2f} | C: ${close:,.2f} | Vol: {volume:,}"
            )
    else:
        print("No bar data available yet")


async def main():
    suite = await TradingSuite.create(
        instrument=Symbol,
        timeframes=[Timeframe],
    )

    await suite.connect()

    # Set up signal handler for clean exit
    shutdown_event = asyncio.Event()

    def signal_handler(signum, frame):
        print("\n\nReceived interrupt signal. Shutting down gracefully...")
        shutdown_event.set()

    signal.signal(signal.SIGINT, signal_handler)
    signal.signal(signal.SIGTERM, signal_handler)

    print(f"Monitoring {suite.instrument.name} {Timeframe}. Press CTRL+C to exit.\n")

    try:
        while not shutdown_event.is_set():
            try:
                # Wait for new bar with timeout to check shutdown event
                new_bar = await asyncio.wait_for(
                    suite.wait_for(EventType.NEW_BAR), timeout=1.0
                )
                if new_bar:
                    await on_new_bar(suite)
            except TimeoutError:
                # Timeout is expected, just check shutdown_event again
                pass
    finally:
        print("Disconnecting from real-time feeds...")
        await suite.disconnect()
        print("Clean shutdown complete.")


await main()

Actually there was some issues with the prices in data. The prices were not aligned with the tick value, which was the main issue.
Although I did discover that the historical data volumes the project x provides are much lower than tradingview and topstepx charts. It seems that the volume data they provide is not the full exchange volume from CME, rather is maybe just trade volumes from there service.

But the prices should be much more accurate now. At least as accurate as I can get them.
Thanks again for finding a issue that I had missed.

Version 3.1.9 should address this issue