pipinstallib\_async

pipinstallpoetry-U

poetryinstall

poetryinstall--with=docs,dev

poetryinstall--with=docspoetryrunsphinx-build-bhtmldocshtml

poetryrunmypyib\_async

poetrybuild

poetryinstallpoetryconfigpypi-token.pypiyour-api-tokenpoetrypublish--build

# Make sure TWS/Gateway is running and API is enabled# Check that ports match (7497 for TWS, 4001 for Gateway)ib.connect('127.0.0.1',7497,clientId=1)# TWSib.connect('127.0.0.1',4001,clientId=1)# Gateway

# Each connection needs a unique client IDib.connect('127.0.0.1',7497,clientId=1)# Use different numbers for multiple connections

# For free delayed data (no subscription required)ib.reqMarketDataType(3)# Delayedib.reqMarketDataType(4)# Delayed frozen# For real-time data (requires subscription)ib.reqMarketDataType(1)# Real-time

from ib\_async import\*ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Your code hereib.disconnect()

from ib\_async import\*util.startLoop()# Required for notebooksib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Your code here - no need to call ib.run()

import asynciofrom ib\_async import\*asyncdef main():ib=IB()awaitib.connectAsync('127.0.0.1',7497,clientId=1)# Your async code hereib.disconnect()asyncio.run(main())

from ib\_async import\*# Connect to TWS or IB Gatewayib=IB()ib.connect('127.0.0.1',7497,clientId=1)print("Connected")# Disconnect when doneib.disconnect()

from ib\_async import\*ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Get account summaryaccount=ib.managedAccounts()[0]summary=ib.accountSummary(account)foriteminsummary:print(f"{item.tag}: {item.value}")ib.disconnect()

from ib\_async import\*# util.startLoop() # uncomment this line when in a notebookib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Request historical datacontract=Forex('EURUSD')bars=ib.reqHistoricalData(contract,endDateTime='',durationStr='30 D',barSizeSetting='1 hour',whatToShow='MIDPOINT',useRTH=True)# Convert to pandas dataframe (pandas needs to be installed):df=util.df(bars)print(df.head())ib.disconnect()

from ib\_async import\*import timeib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Subscribe to live market datacontract=Stock('AAPL','SMART','USD')ticker=ib.reqMktData(contract,'',False,False)# Print live quotes for 30 secondsforiinrange(30):ib.sleep(1)# Wait 1 secondifticker.last:print(f"AAPL: ${ticker.last} (bid: ${ticker.bid}, ask: ${ticker.ask})")ib.disconnect()

from ib\_async import\*ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Create a contract and ordercontract=Stock('AAPL','SMART','USD')order=MarketOrder('BUY',100)# Place the ordertrade=ib.placeOrder(contract,order)print(f"Order placed: {trade}")# Monitor order statuswhilenottrade.isDone():ib.sleep(1)print(f"Order status: {trade.orderStatus.status}")ib.disconnect()

from ib\_async import\*ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Get current positionspositions=ib.positions()print("Current Positions:")forposinpositions:print(f"{pos.contract.symbol}: {pos.position} @ {pos.avgCost}")# Get open ordersorders=ib.openTrades()print(f"\nOpen Orders: {len(orders)}")fortradeinorders:print(f"{trade.contract.symbol}: {trade.order.action} {trade.order.totalQuantity}")ib.disconnect()

from ib\_async import\*def onPnL(pnl):print(f"P&L Update: Unrealized: ${pnl.unrealizedPnL:.2f}, Realized: ${pnl.realizedPnL:.2f}")ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Subscribe to P&L updatesaccount=ib.managedAccounts()[0]pnl=ib.reqPnL(account)pnl.updateEvent+=onPnL# Keep running to receive updatestry:ib.run()# Run until interruptedexceptKeyboardInterrupt:ib.disconnect()

from ib\_async import\*ib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Create a bracket order (entry + stop loss + take profit)contract=Stock('TSLA','SMART','USD')# Parent orderparent=LimitOrder('BUY',100,250.00)parent.orderId=ib.client.getReqId()parent.transmit=False# Stop lossstopLoss=StopOrder('SELL',100,240.00)stopLoss.orderId=ib.client.getReqId()stopLoss.parentId=parent.orderIdstopLoss.transmit=False# Take profittakeProfit=LimitOrder('SELL',100,260.00)takeProfit.orderId=ib.client.getReqId()takeProfit.parentId=parent.orderIdtakeProfit.transmit=True# Place bracket ordertrades=[]trades.append(ib.placeOrder(contract,parent))trades.append(ib.placeOrder(contract,stopLoss))trades.append(ib.placeOrder(contract,takeProfit))print(f"Bracket order placed: {len(trades)} orders")ib.disconnect()

from ib\_async import\*import pandas as pdib=IB()ib.connect('127.0.0.1',7497,clientId=1)# Get multiple timeframescontract=Stock('SPY','SMART','USD')# Daily bars for 1 yeardaily\_bars=ib.reqHistoricalData(contract,endDateTime='',durationStr='1 Y',barSizeSetting='1 day',whatToShow='TRADES',useRTH=True)# 5-minute bars for last 5 daysintraday\_bars=ib.reqHistoricalData(contract,endDateTime='',durationStr='5 D',barSizeSetting='5 mins',whatToShow='TRADES',useRTH=True)# Convert to DataFramesdaily\_df=util.df(daily\_bars)intraday\_df=util.df(intraday\_bars)print(f"Daily bars: {len(daily\_df)} rows")print(f"Intraday bars: {len(intraday\_df)} rows")# Calculate simple moving averagedaily\_df['SMA\_20']=daily\_df['close'].rolling(20).mean()print(daily\_df[['date','close','SMA\_20']].tail())ib.disconnect()

# Synchronous (blocks until complete)bars=ib.reqHistoricalData(contract,...)# Asynchronous (yields to event loop)bars=awaitib.reqHistoricalDataAsync(contract,...)

# Subscribe to eventsdef onOrderUpdate(trade):print(f"Order update: {trade.orderStatus.status}")ib.orderStatusEvent+=onOrderUpdate# Or with asyncasyncdef onTicker(ticker):print(f"Price update: {ticker.last}")ticker.updateEvent+=onTicker

try:ib.connect('127.0.0.1',7497,clientId=1)exceptConnectionRefusedError:print("TWS/Gateway not running or API not enabled")exceptExceptionase:print(f"Connection error: {e}")

poetry install --with=dev
poetry run pytest

poetry run mypy ib_async

poetry run ruff format
poetry run ruff check --fix

git clone https://github.com/ib-api-reloaded/ib_async.gitcd ib_async

poetry install --with=dev,docs

poetry run pytest
poetry run mypy ib_async