{"id":41844,"date":"2025-02-05T10:45:08","date_gmt":"2025-02-05T10:45:08","guid":{"rendered":"https:\/\/mycryptomania.com\/?p=41844"},"modified":"2025-02-05T10:45:08","modified_gmt":"2025-02-05T10:45:08","slug":"crypto-trading-bot-in-alpaca","status":"publish","type":"post","link":"https:\/\/mycryptomania.com\/?p=41844","title":{"rendered":"Crypto Trading Bot in Alpaca"},"content":{"rendered":"

The goal of this story is to create the simplest paper trading bot in Alpaca<\/em> which will use WebSocket 1-minute bars. The strategy\u00a0is<\/p>\n

Buy 0.1 BTC at Market if RSI_14 < 30 and HAVE_NO_POSITIONSell 0.1 BTC at Market if RSI_14 > 70 and HAVE_POSITION<\/p>\n

YouTube Video<\/h3>\n

https:\/\/medium.com\/media\/61d42518884e876d57f7a501b30f2eaf\/href<\/a><\/p>\n

Installations<\/h3>\n

Install alpaca-py<\/em>!pip install aplaca-py<\/p>\n

2. Install pandas_ta<\/em><\/p>\n

!pip install pandas_ta<\/p>\n

API Keys +\u00a0Secrets<\/h3>\n

from google.colab import userdata
ALPACA_API_KEY=userdata.get(‘ALPACA_API_KEY’)
ALPACA_API_SECRET=userdata.get(‘ALPACA_API_SECRET’)<\/p>\n

Nest Asyncio<\/h3>\n

Allow nested use of asyncio <\/em>within Jupyter notebooks<\/em>, Google Colab<\/em>, or other environments that already have an event loop\u00a0running.Written by the legend Ewald De Wit\u00a0RIPimport nest_asyncio <\/p>\n

nest_asyncio.apply()<\/p>\n

Initialize Paper Trading\u00a0Client<\/h3>\n

from alpaca.trading.client import TradingClient
trading_client = TradingClient(ALPACA_API_KEY, ALPACA_API_SECRET, paper=True)<\/p>\n

Crypto Data Stream for Websocket Data<\/h3>\n

Initialize CryptoDataStream<\/em><\/strong><\/p>\n

Used to manage real-time Crypto Websocket data.from alpaca.data.live import CryptoDataStream<\/p>\n

crypto_data_stream = CryptoDataStream(ALPACA_API_KEY, ALPACA_API_SECRET)<\/p>\n

Define Event Handler when New Bar\u00a0Arrives<\/strong><\/p>\n

This is where we put our trading\u00a0logicAnalogous to callback <\/em>in ib_insync<\/em>from alpaca.trading.requests import MarketOrderRequest
from alpaca.trading.enums import OrderSide, TimeInForce
from pandas_ta.momentum import rsi
bars = []
has_position = False
async def on_new_bar(bar):
global bars
global has_position<\/p>\n

bars.append(bar)<\/p>\n

if len(bars)<15:
print(“Not Enough Data”)<\/p>\n

else:
rsi_value = rsi(util.df(bars[-15:]).close).iloc[-1]
print(f”Current RSI is {rsi_value}”)<\/p>\n

if has_position and rsi_value>=70:
print(“RSI is overbought, sell BTC”)
trading_client.submit_order(
order_data=MarketOrderRequest(
symbol=”BTC\/USD”,
qty=.1,
side=OrderSide.SELL,
time_in_force=TimeInForce.GTC
)
)
has_position = False
elif not has_position and rsi_value<=30:
print(“RSI is oversold, buy BTC”)
trading_client.submit_order(
order_data=MarketOrderRequest(
symbol=”BTC\/USD”,
qty=.1,
side=OrderSide.BUY,
time_in_force=TimeInForce.GTC
)
)
has_position = TrueNote we used the following helper function util.df <\/em>to convert a list of bars into a Pandas DataFrame<\/em>import pandas as pd
class util:
@staticmethod
def df(json_like):
if isinstance(json_like, list):
json_like = [element.__dict__ for element in json_like]
return pd.DataFrame(json_like)
else:
json_like = json_like.__dict__
return pd.DataFrame(json_like.values(), index=json_like.keys())<\/p>\n

Subscribe to Websocket 1-minute Bars and attach Event\u00a0Handler<\/strong><\/p>\n

crypto_data_stream.subscribe_bars(on_new_bar, “BTC\/USD”)<\/p>\n

Run the Algo (BLOCKING)<\/strong><\/p>\n

crypto_data_stream.run()<\/p>\n

Run the Algo (NON BLOCKING)<\/strong><\/p>\n

import asyncio
asyncio.create_task(crypto_data_stream._run_forever())If you are using Jupyter\/Colab<\/em> and still want it to be Interactive this is\u00a0useful<\/p>\n

Sample Output:<\/strong><\/p>\n

Crypto Trading Bot in Alpaca<\/a> was originally published in Coinmonks<\/a> on Medium, where people are continuing the conversation by highlighting and responding to this story.<\/p>","protected":false},"excerpt":{"rendered":"

The goal of this story is to create the simplest paper trading bot in Alpaca which will use WebSocket 1-minute bars. The strategy\u00a0is Buy 0.1 BTC at Market if RSI_14 < 30 and HAVE_NO_POSITIONSell 0.1 BTC at Market if RSI_14 > 70 and HAVE_POSITION YouTube Video https:\/\/medium.com\/media\/61d42518884e876d57f7a501b30f2eaf\/href Installations Install alpaca-py!pip install aplaca-py 2. Install pandas_ta […]<\/p>\n","protected":false},"author":0,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2],"tags":[],"class_list":["post-41844","post","type-post","status-publish","format-standard","hentry","category-interesting"],"_links":{"self":[{"href":"https:\/\/mycryptomania.com\/index.php?rest_route=\/wp\/v2\/posts\/41844"}],"collection":[{"href":"https:\/\/mycryptomania.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/mycryptomania.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"replies":[{"embeddable":true,"href":"https:\/\/mycryptomania.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=41844"}],"version-history":[{"count":0,"href":"https:\/\/mycryptomania.com\/index.php?rest_route=\/wp\/v2\/posts\/41844\/revisions"}],"wp:attachment":[{"href":"https:\/\/mycryptomania.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=41844"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/mycryptomania.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=41844"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/mycryptomania.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=41844"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}