README: update live/backtest websocket usage

This commit is contained in:
Jacob Plaster
2018-11-16 14:38:05 +00:00
parent 31ecf5cd97
commit f48ba44c79

View File

@@ -1 +1,82 @@
# bitfinex-api-py
# Official Python `bfxapi`
This repo contains an official python library that is used to connect to the both the Bitfinex api and the Honey Frameworks data-server. The library communicates with these servers using both websocket connection and a REST interface.
## `bfxapi.LiveWebsocket`
The websocket exposes a collection of events that are triggered when certain data is received. Here is a full list of available events:
- `all`: listen for all messages coming through
- `connected:` called when a connection is made
- `authenticated`: called when the websocket passes authentication
- `message` (string): new incoming message from the websocket
- `notification` (array): incoming account notification
- `error` (string): error from the websocket
- `order_closed` (string): when an order confirmation is recieved
- `wallet_snapshot` (string): Initial wallet balances (Fired once)
- `order_snapshot` (string): Initial open orders (Fired once)
- `positions_snapshot` (string): Initial open positions (Fired once)
- `wallet_update` (string): changes to the balance of wallets
- `seed_candle` (candleArray): initial past candle to prime strategy
- `seed_trade` (tradeArray): initial past trade to prime strategy
- `funding_offer_snapshot`: opening funding offer balances
- `funding_loan_snapshot`:opening funding loan balances
- `funding_credit_snapshot`: opening funding credit balances
- `balance_update` when the state of a balance is changed
- `new_trade`: a new trade on the market has been executed
- `new_candle`: a new candle has been produced
For example. If you wanted to subscribe to all of the trades on the `tBTCUSD` market, then you can simply listen to the `new_trade` event. For Example:
```
ws = LiveBfxWebsocket(
logLevel='INFO'
)
@ws.on('new_trade')
def log_trade(trade):
print ("New trade: {}".format(trade))
@ws.on('connected')
def start():
ws.subscribe('trades', 'tBTCUSD')
ws.run()
```
NOTE: Instead of using the python decorators, you can also listen to events via function call:
```
ws.on('new_trade', log_trade)
```
## `bfxapi.DataServerWebsocket`
The data-server websocket is used for retrieving large amounts of historical data from a `bfx-hf-data-server` instance. The library then takes all of the incoming historical data from the server and pushes it down the `new_trade` and `new_candle` events. For information on how to start a data-server instance please visit the repo at: https://github.com/bitfinexcom/bfx-hf-data-server
A list of events available:
- `connected`: connection is made
- `new_trade`: a historical trade item is received
- `new_candle`: a historical candle item is received
- `done`: backtest has finished running
An example of a script that loads all of the historical trades for symbol `tBTCUSD` over the last 2 days:
```
ws = DataServerWebsocket(
symbol='tBTCUSD',
host='ws://localhost:8899'
)
@ws.on('new_trade')
def trade(trade):
print ("Backtest trade: {}".format(trade))
@ws.on('done')
def finish():
print ("Backtest complete!")
now = int(round(time.time() * 1000))
then = now - (1000 * 60 * 60 * 24 * 2) # 2 days ago
ws.run(then, now)
```