Storage engine for cryptocurrency data
Project description
A storage engine for cryptocurrency market data. You supply the exchanges, data type (trade, book, etc), and trading pairs you’re interested in and Cryptostore does the rest!
Stores data to:
Parquet
Arctic
Google Cloud Storage
Amazon S3
Requirements
Cryptostore currently requires either Kafka or Redis to be installed. The extra dependencies for your backend of choice must be installed as well (eg pip install cryptostore[redis]). Redis requires Redis Streams, which is supported in versions > 5.0.
Running Cryptostore
Once installed with pip, an executable is placed on the path, so you can simply run cryptostore to start the collector. It requires a config.yaml file. If its not in the current working directory, you can specify the path to the config with the --config option.
An example config, with documentation inline is provided in the root of the repository. The config file is monitored by cryptostore, so you can change the options in the file and it will apply them without the need to reload the service (this is experimental. If you encounter issues with it, please raise an issue).
Running with other consumers
Cryptostore can operate with other consumers of the exchange data (eg. a trading engine consuming updates).
For Redis
Disable the message removal in the Redis settings in config.yaml. The other consumer will need to be responsible for message removal (if so desired), and it must ensure messages are not removed before cryptostore has had a chance to process them.
For Kafka
You need only supply a different consumer group id for the other consumers to ensure all consumers receive all messages. Kafka’s configuration controls the removal of committed messages in a topic (typically by time or size).
Planned features
☐ Missing data detection and correction (for exchanges that support historical data, typically only trade data)
☐ Storing data to InfluxDB
☐ Storing data to MongoDB
☐ Subscribing to Book Deltas
☐ Support for enabling computation and storage of diverse metrics in parallel with data collection (eg. configurable OHLCV)
☐ Support for forwarding data to another service/sink (eg. to a trading engine).
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 Distributions
Built Distribution
File details
Details for the file cryptostore-0.0.6-py3-none-any.whl
.
File metadata
- Download URL: cryptostore-0.0.6-py3-none-any.whl
- Upload date:
- Size: 17.2 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.13.0 pkginfo/1.5.0.1 requests/2.21.0 setuptools/41.0.1 requests-toolbelt/0.9.1 tqdm/4.32.1 CPython/3.7.3
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | b2f0ec6760cbc0130bb708deb763312ea6a432f1201b7d6e23bb5e0eb00280f3 |
|
MD5 | 42368c87870e2b717b2cd6e02ca195f4 |
|
BLAKE2b-256 | 5ac73928ae735ede41408d0180ece1f59d06dd28832e20ca16f0a6b58c44f530 |