alpaca/test.py at main · mobtownlabs/alpaca · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
from alpaca.trading.client import TradingClient
from alpaca.trading.enums import OrderSide, TimeInForce
from alpaca.trading.requests import LimitOrderRequest, MarketOrderRequest
from alpaca.trading.stream import TradingStream
import config


client = TradingClient(config.API_KEY, config.SECRET_KEY, paper=True)


account = dict(client.get_account())

#for k,v in account.items():
#    print(f"{k:30}: {v}")


order_details = LimitOrderRequest(
    symbol = "BTC/USD",
    qty = 0.00009975,
    side = OrderSide.SELL,
    limit_price = 43110.00,
    time_in_force = "gtc"
)

order = client.submit_order(order_details)

trades = TradingStream(config.API_KEY, config.SECRET_KEY, paper=True)

async def trade_status(data):
    print(data)

trades.subscribe_trade_updates(trade_status)
trades.run()

assets = [asset for asset in client.get_all_positions()]
positions = [(asset.symbol, asset.qty, asset.current_price) for asset in assets]

for position in positions:
    print(f"{position[0]:9}{position[1]:>4}{float(position[1]) * float(position[2]):>15.2f}")

client.close_all_positions(cancel_orders=True)

trades.close()