Futures Websockets

class kraken.futures.KrakenFuturesWSClient(key: str = '', secret: str = '', url: str = '', callback: Any | None = None, sandbox: bool = False)

Bases: KrakenBaseFuturesAPI

Class to access public and (optional) private/authenticated websocket connection.

So far there are no trade endpoints that can be accessed using the Futures Kraken API. If this has changed and not implemented yet, please open an issue: https://github.com/btschwertfeger/python-kraken-sdk/issues

• https://docs.futures.kraken.com/#websocket-api

Parameters:

• key (str, optional) – The Kraken Futures API key to access private endpoints

• secret (str, optional) – The Kraken Futures Secret key to access private endpoints

• url (str, optional) – Set a custom URL (default: futures.kraken.com/ws/v1)

• sandbox (bool, optional) – Use the Kraken Futures demo environment (URL will switch to demo-futures.kraken.com/ws/v1, default: False)

Futures Websocket: Create the websocket client

import asyncio
from kraken.futures import KrakenFuturesWSClient

async def main() -> None:

    # Create a custom bot
    class Bot(KrakenFuturesWSClient):
        async def on_message(self, event: dict) -> None:
            print(event)

    bot = Bot()     # unauthenticated
    auth_bot = Bot( # authenticated
        key="api-key",
        secret="secret-key"
    )

    # now you can subscribe to channels using
    await bot.subscribe(
        feed='ticker',
        products=["XBTUSD", "DOT/EUR"]
    )
    # the messages can be used within the `on_message` callback method

    while True:
        await asyncio.sleep(6)

if __name__ == "__main__":
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        loop.close()


        from kraken.futures import KrakenFuturesWSClient

Futures Websocket: Create the websocket client as context manager

import asyncio
from kraken.futures import KrakenFuturesWSClient

async def on_message(msg):
    print(msg)

async def main() -> None:
    async with KrakenFuturesWSClient(callback=on_message) as session:
        await session.subscribe(feed="ticker", products=["PF_XBTUSD"])

    while True:
        await asyncio.sleep(6)

if __name__ == "__main__":
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        pass
    finally:
        loop.close()

get_active_subscriptions() → List[dict]

Returns the list of active subscriptions.

Returns:

List of active subscriptions including the feed names, products and additional information.

Return type:

List[dict]

Initialize your client as described in kraken.futures.KrakenFuturesWSClient to run the following example:

Futures Websocket: Get the active subscriptions

>>> from kraken.futures import KrakenFuturesWSClient
...
>>> KrakenFuturesWSClient.get_active_subscriptions()
[
    {
        "event": "subscribe",
        "feed": "ticker,
        "product_ids": ["PI_XBTUSD"]
    }, {
        "event": "subscribe",
        "feed": "open_orders,
    }, ...
]

static get_available_private_subscription_feeds() → List[str]

Return all available private feeds that can be un-/subscribed to/from using the Kraken Futures API

Returns:

List of available private feeds

Return type:

List[str]

Futures Websocket: Get the available private subscription feeds

>>> from kraken.futures import KrakenFuturesWSClient
>>> KrakenFuturesWSClient.get_available_private_subscription_feeds()
[
    "fills", "open_positions", "open_orders",
    "open_orders_verbose", "balances",
    "deposits_withdrawals", "account_balances_and_margins",
    "account_log", "notifications_auth"
]

static get_available_public_subscription_feeds() → List[str]

Return all available public feeds that can be un-/subscribed using the Kraken Futures API.

Returns:

List of available public feeds

Return type:

List[str]

Futures Websocket: Get the available public subscription feeds

>>> from kraken.futures import KrakenFuturesWSClient
>>> KrakenFuturesWSClient.get_available_private_subscription_feeds()
[
    "trade", "book", "ticker",
    "ticker_lite", "heartbeat"
]

property is_auth: bool

Checks if key and secret are set.

Returns:

True if the credentials are set, else False

Return type:

bool

Futures Websocket: Check if the credentials are set

>>> from kraken.futures import KrakenFuturesWSClient
>>> KrakenFuturesWSClient().is_auth()
False

async on_message(msg: dict) → None

Method that serves as the default callback function Calls the defined callback function (if defined) or overload this function.

This is the default method which just logs the messages. In production you want to overload this with your custom methods, as shown in the Example of kraken.futures.KrakenFuturesWSClient.

Parameters:

msg (dict) – The message that was send by Kraken via the websocket connection.

Return type:

NOne

async subscribe(feed: str, products: List[str] | None = None) → None

Subscribe to a Futures websocket channel/feed. For some feeds authentication is required.

• https://docs.futures.kraken.com/#websocket-api-websocket-api-introduction-subscriptions

Parameters:

• feed (str) – The websocket feed/channel to subscribe to

• products (List[str], optional) – The products/futures contracts to subscribe to

Raises:

ValueError – If the parameters don’t match the requirements set by the Kraken API

Initialize your client as described in kraken.futures.KrakenFuturesWSClient to run the following example:

Futures Websocket: Subscribe to a feed

>>> await bot.subscribe(feed='ticker', products=["XBTUSD", "DOT/EUR"])

Success or failures are sent over the websocket connection and can be received via the default kraken.futures.KrakenFuturesWSClient.on_message() or a custom callback function.

async unsubscribe(feed: str, products: List[str] | None = None) → None

Subscribe to a Futures websocket channel/feed. For some feeds authentication is required.

• https://docs.futures.kraken.com/#websocket-api-websocket-api-introduction-subscriptions

Parameters:

• feed (str) – The websocket feed/channel to unsubscribe from

• products (List[str], optional) – The products/futures contracts to unsubscribe from

Raises:

ValueError – If the parameters don’t match the requirements set by the Kraken API

Initialize your client as described in kraken.futures.KrakenFuturesWSClient to run the following example:

Futures Websocket: Unsubscribe from a feed

>>> await bot.unsubscribe(feed='ticker', products=["XBTUSD", "DOT/EUR"])

Success or failures are sent over the websocket connection and can be received via the default kraken.futures.KrakenFuturesWSClient.on_message`() or a custom callback function.