Getting Started

Node.js tardis-dev provides convenient access to tick-level historical and real-time cryptocurrency market data both in exchange-native and normalized formats. It relies on async iteration (for await ...of), which makes it straightforward to consume replayed data, real-time streams and locally computed derived data in the same style.

Installation

Requires Node.js v12+ installed.

npm install tardis-dev --save

Historical Replay

Exchange-native

const { replay } = require('tardis-dev')

const messages = replay({
  exchange: 'bitmex',
  filters: [
    { channel: 'trade', symbols: ['XBTUSD'] },
    { channel: 'orderBookL2', symbols: ['XBTUSD'] }
  ],
  from: '2019-05-01',
  to: '2019-05-02'
})

for await (const message of messages) {
  console.log(message)
}

Normalized

Full replay reference lives on Replaying Historical Data.

Real-Time Streaming

Exchange-native

const { stream } = require('tardis-dev')

const messages = stream({
  exchange: 'bitmex',
  filters: [
    { channel: 'trade', symbols: ['XBTUSD'] },
    { channel: 'orderBookL2', symbols: ['XBTUSD'] }
  ]
})

for await (const message of messages) {
  console.log(message)
}

Normalized

Full streaming reference lives on Streaming Real-Time Data.

Key Capabilities

• historical tick-level market data replay backed by Tardis.dev HTTP API

• consolidated real-time data streaming API connecting directly to exchanges' public WebSocket APIs

• support for both exchange-native and normalized market data formats

• transparent historical local data caching (cached data is stored on disk in compressed GZIP format and decompressed on demand when reading the data)

• combining multiple exchanges feeds into single one via combine

• computing derived data locally via compute

• full limit order book reconstruction via OrderBook

• built-in TypeScript support

• Open Source

GitHub - tardis-dev/tardis-node: Convenient access to tick-level real-time and historical cryptocurrency market data via Node.jsGitHub

Tardis-dev GitHub repository

Debugging and logging

tardis-dev lib uses debug package for verbose logging and debugging purposes that can be enabled via DEBUG environment variable set to tardis-dev*.

Usage with TypeScript

Simply change from require

const { replay, stream } = require('tardis-dev')

to ES Modules import

import { replay, stream } from 'tardis-dev'

to enjoy first class TypeScript typings.

Reference pages

• Replaying Historical Data

• Streaming Real-Time Data

• Normalization and Local Processing

Historical market data helpers

init(options)

This function doesn't affect real-time streaming functionality in any way, it's useful only for historical data replay.

When working with market data via replay and replayNormalized, by default only the first day of each month of historical data is available for replay, and locally cached historical data is stored in the default location on disk (OS temp dir).

Init function allows providing an apiKey received via email after ordering historical market data access via Tardis.dev website, as well as a custom cacheDir. apiKey can also be provided directly via options of replay and replayNormalized functions - that overrides anything that was provided via init.

const { init } = require('tardis-dev')

init({
  apiKey: 'YOUR API KEY',
  cacheDir: 'CUSTOM CACHE DIR PATH'
})

init options

name	type	default	description
apiKey	string (optional)	undefined	API key for Tardis.dev HTTP API - if not provided only first day of each month of historical data is accessible
cacheDir	string	<os.tmpdir>/.tardis-cache	path to local dir that will be used as cache location - if not provided default temp dir for given OS will be used

getExchangeDetails(exchange)

Given exchange id provides exchange details (available symbols, availability dates, available channels, pricing info etc) provided by exchanges/:exchange API endpoint.

const { getExchangeDetails } = require('tardis-dev')

const bitmexExchangeDetails = await getExchangeDetails('bitmex')

type of response returned by awaiting on getExchangeDetails

{
  id: string
  name: string
  enabled: boolean
  filterable: boolean
  availableSince: string
  availableSymbols: {
    id: string
    type: 'spot' | 'future' | 'perpetual' | 'option'
    availableSince: string
    availableTo?: string
  }[]
  availableChannels: string[]
  incidentReports: {
    from: string
    to: string
    status: string
    details: string
  }
}

getApiKeyAccessInfo(apiKey?)

Given apiKey provided as optional parameter or provided in init function provides information about what historical data is available for it - exchanges, date ranges, symbols.

const { getApiKeyAccessInfo } = require('tardis-dev')

const details = await getApiKeyAccessInfo('YOUR_API_KEY')

type of response returned by awaiting on getApiKeyAccessInfo()

{
  exchange: string
  from: string
  to: string
  symbols: string[]
}[]

clearCache()

Clears local data cache dir.

const { clearCache } = require('tardis-dev')

await clearCache()