معرفی شرکت ها
aio-kraken-ws-0.3.9
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
Get ohlc from kraken web sockets.
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | aio-kraken-ws-0.3.9 |
| نام | aio-kraken-ws |
| نسخه کتابخانه | 0.3.9 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | Constantin De La Roche |
| ایمیل نویسنده | constantin@botcrypto.io |
| آدرس صفحه اصلی | https://gitlab.com/cdlr75/aio-kraken-ws |
| آدرس اینترنتی | https://pypi.org/project/aio-kraken-ws/ |
| مجوز | - |
aio-kraken-ws [](https://gitlab.com/botcrypto/aio-kraken-ws/commits/master)
[](https://gitlab.com/botcrypto/aio-kraken-ws/commits/master)
[](https://www.python.org/dev/peps/pep-0008/)
===
A module to collect ohlc candles from Kraken using WebSockets that is asyncio friendly! Looking for automated trading tools? [Botcrypto](https://botcrypto.io) 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 subscribe/unsubscribe to datasets, i.e. [(pair, Unit Time)] ex: [('XBT/EUR', 1)].
- Callback is regularly 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
```python
# 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
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.
```python
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)
```
### Error management
- An exception raised by the `callback` will be logged and it wont stop the streams
- If kraken send an error message, an `ERROR` log is emitted with the kraken payload
- If kraken send 'Subscription ohlc interval not supported', the related dataset is automatically unsubscribed
#### Warning
The `callback` should takes less than a minute to process. If the `callback` takes more than a minutes, a *warning* is emitted and you may lose market data.
Kraken WebSocket server manage **20 subscriptions maximum** per connection. Above 20 subscriptions, you may not receive all desired data.
**Hopfully, aio-kraken-ws manage this limitation for you!** A new websocket connection is open every 20 subscriptions.
Moreover, after 24h a subscriptions seem to expire and no more market data is receive. To ensure we do not lose the stream of market data, **aio-kraken-ws** automatically reconnect and re-subscribe to the datasets every 5 minutes.
## Tests
You can find a working example of KrakenWs in `tests/learning/log_to_file.py`.
### Run tests locally
Clone the repo and install requirements
```sh
pip install -e .[test]
```
Run the suite tests
```sh
# 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
```
## Changelog
See https://cdlr75.gitlab.io/aio-kraken-ws/CHANGELOG.html
نیازمندی
| مقدار | نام |
|---|---|
| ==8.0.2 | websockets |
| ==0.13.0 | asynctest |
| ==2.5.0 | pycodestyle |
| ==2.3.1 | pylint |
| ==5.1.2 | pytest |
| ==2.7.1 | pytest-cov |
| ==1.29.0 | pytest-xdist |
زبان مورد نیاز
| مقدار | نام |
|---|---|
| >=3 | Python |
نحوه نصب
نصب پکیج whl aio-kraken-ws-0.3.9:
pip install aio-kraken-ws-0.3.9.whl
نصب پکیج tar.gz aio-kraken-ws-0.3.9:
pip install aio-kraken-ws-0.3.9.tar.gz