Python SDK

pip install rivermarkets

from rivermarkets import RiverMarkets

client = RiverMarkets(api_key="your_api_key")

# Search markets
results = client.markets.search_markets(q="bitcoin")
for market in results.results:
    print(f"{market.river_id}: {market.title}")

from rivermarkets import AsyncRiverMarkets

client = AsyncRiverMarkets(api_key="your_api_key")
results = await client.markets.search_markets(q="bitcoin")

order = client.orders.create_order(
    subaccount_id="your_subaccount_id",
    river_id=4552150,
    order_type="LIMIT",
    time_in_force="GTC",
    buy_flag=True,
    price=0.50,
    qty=10,
)
print(f"Order placed: {order.river_order_id}")

orders = client.orders.list_orders(status="RESTING")
for order in orders.orders:
    print(f"{order.river_order_id}: {order.status}")

client.orders.cancel_order(order_id="your_order_id")

positions = client.positions.get_positions()

fills = client.fills.get_fills(subaccount_id="your_subaccount_id")

orderbook = client.orderbooks.get_orderbook(river_id=4552150)

prices = client.prices.get_prices(river_id=4552150, type="candlestick", interval="1d")

# List subaccounts
subaccounts = client.subaccounts.list_subaccounts()

# Create a subaccount
subaccount = client.subaccounts.create_subaccount(name="My Strategy")

from rivermarkets import BadRequestError, NotFoundError

try:
    order = client.orders.get_order(order_id="invalid")
except NotFoundError:
    print("Order not found")
except BadRequestError as e:
    print(f"Bad request: {e.body}")

client = RiverMarkets(
    api_key="your_api_key",
    base_url="https://api.rivermarkets.com",  # default
    timeout=30.0,                              # seconds, default 60
)