使用Kafka Streams来分析加密交换的实时交易活动
在伦敦的2019年Kafka峰会,Ludvig Sandman,SVP产品工程和Bruce Zulu那销售工程领先对于Panopticon Streaming Analytics提出了一篇论文:
像Coinbase,Binance和Kraken等加密货币交换使投资者能够购买,销售和贸易加密货币,包括比特币,LiteCoin,Ethereum等等。根据交易所,可以使用菲亚特货币(法律政府温柔如美国或欧元)或其他加密货币进行交易。大多数交流还允许投资者用另一个人购买一种类型的加密货币(例如,用Ethereum购买比特币。)鉴于加密货币估值的高速和高挥发性,监测和分析交易活动以及交易算法的表现是令人生畏的。Kafka Streams提供了完美的基础设施,以支持市场和参与者行为的可见性,具有非常高的时间准确度,这在交易此类挥发性仪器时至关重要。
特别是,加密货币交易员需要几种方法来可视化交易活动并重建并在全面的深度上查看他们的订单书籍。他们需要工具可以制作大量复杂的实时计算,包括:
- 最佳出价和优惠
- 出价累计规模和优惠
- 蔓延到中位数
- 价格活动之间的德国
- 时间加权平均值
- 消息费率(新,取消,交易,替换)
- 累积贸易流量
所有计算必须在整个交易日实时完成多对菲亚特货币和加密货币。交易者必须能够对每个订单的所有方面进行执行。新工具利用Kafka Stream的力量使得交易者自己能够在屏幕上构建定向图,而无需写入任何代码。定向图控制数据流,计算和加密货币交易数据的统计分析,并可以将其输出到深度监测和分析实时数据以及存储在内存时间序列数据库中的历史交易数据。本文介绍了构建和部署Kafka Streams以支持加密货币交易的实用方法。
这里观看他们的演示文稿的视频:https://www.confluent.io/kafka-summit-lon19/using-kafka-streams-analyze-trading-crypto-exchanges.