Get ohlc from kraken web sockets.
Project description
aio-kraken-ws
![PEP8](https://pypi-camo.freetls.fastly.net/6fb00dfb51e9ef50800acf286dab4c6c7b018f5b/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f636f64652532307374796c652d706570382d677265656e2e737667)
A module to collect ohlc candles from Kraken using WebSockets that is asyncio friendly! Looking for automated trading tools? Botcrypto may interest you.
Key features
- Subscribe to kraken data using a single WebSocket.
- Trigger a callback that is coroutine on each new closed candles from kraken.
- Easy subscription/unsubscription to datasets, i.e. [(PAIR, Unit Time)].
- Callback is regulary triggered at each end of the UT intervals, whatever is the number of data received by kraken.
Getting started
Install
pip install aio-kraken-ws
Usage
# check tests/learning/log_to_file.py for a complete example
async def callback(pair, interval, timestamp, o, h, l, c, v):
""" A coroutine handling new candles.
:param str pair:
:param int interval: time in minutes
:param int timestamp: candle open timestamp.
:param float o: open price
:param float h: high price
:param float l: low price
:param float c: close price
:param float v: volume
"""
with open("candles.txt", "a+") as file:
file.write(f"[{pair}:{interval}]({timestamp},{o},{h},{l},{c},{v})\n")
kraken_ws = await KrakenWs.create(callback)
# subscribe to some datasets
await kraken_ws.subscribe([("XBT/EUR", 1), ("ETH/EUR", 5)])
The callback
function is called for each dataset at the end of each dataset's unit time interval.
E.g. if subscription start at 4h42.05 to the dataset ("XBT/EUR", 1)
, then callback is triggered at 4h43.00, at 4h44.00, at 4h45.00, etc... For ("XBT/EUR", 60)
, it would be at 5h00.00, at 6h00.00, etc... It's possible to get at most 10ms delay between the exact UT interval ending and the actual datetime of the call.
If no new data were received from Kraken during an interval, the callback is triggered with the latest known close price and v=0, as it's described in the following example.
E.g.
await kraken_ws.subscribe([("XBT/EUR", 1)])
# time.time() = 120
await callback("XBT/EUR", 1, 60, 42.0, 57.0, 19.0, 24.0, 150.0)
# time.time() = 180
await callback("XBT/EUR", 1, 120, 19.0, 24.0, 8.0, 10.0, 13.0)
# time.time() = 240 : no data received in 60s, i.e. no activity
await callback("XBT/EUR", 1, 180, 10.0, 10.0, 10.0, 10.0, 0.0)
An exception raised by the callback
will be logged and it wont stop the streams.
Start tests
Clone the repo and install requirements
pip install -e .[test]
Run the suite tests
# unit tests - no call to kraken - fast
pytest --cov=aio_kraken_ws --cov-report= -v tests/unit
# integration tests - actual kraken subscription - slow
pytest --cov=aio_kraken_ws --cov-append -v -n 8 tests/integration
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for aio_kraken_ws-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e6b067f7b9f2ef4f17792fdb35dfedeb7149892cd5befeada8858a272f1e53df |
|
MD5 | f497819bd0ac2efa33447bf6266304f7 |
|
BLAKE2b-256 | 9bb04ee78bbb691778a25c946361702c5b2eea04e3e13f614fc3581af47c8a39 |