from trade29.sc.bridge import SCBridge

# create the bridge object
bridge = SCBridge()

# subscribe to time and sales data
bridge.time_and_sales_request('xx')

# get access to the response queue
messages = bridge.get_response_queue()

# go into a while loop, wait for messages and print them out

while True:
    msg = messages.get()
    print(msg.df)

 

from trade29.sc.bridge import SCBridge

bridge = SCBridge()

bridge.market_depth_request('xx', update_frequency=5000, include_pulling_stacking=True, include_mbo=True)

messages = bridge.get_response_queue()

while True:
    msg = messages.get()
    print(msg.df)

# placing a market order every 30 seconds

from trade29.sc.bridge import SCBridge
import time

bridge = SCBridge()

while True:

    print('placing order')
    bridge.submit_order('xx', is_buy=1, order_type=0, attach_orders_sc_trade_window=1)

    time.sleep(30)

from trade29.sc.bridge import SCBridge

bridge = SCBridge()

request_id = bridge.graph_data_request(key='xx', base_data='1;4')

messages = bridge.get_response_queue()

while True:
    
    msg = messages.get()
    print(msg.df)