Hi 游客

更多精彩,请登录!

比特池塘 区块链技术 正文

利用LSTM框架实时预测比特币价格

Cherry95
1145 0 0

! U0 ?9 n5 Z5 p$ S0 T: v比特币的价格数据是基于时间序列的,因此比特币的价格预测大多采用LSTM模型来实现。
% v2 c+ O8 |& O' T- {" X长期短期记忆(LSTM)是一种特别适用于时间序列数据(或具有时间 / 空间 / 结构顺序的数据,例如电影、句子等)的深度学习模型,是预测加密货币的价格走向的理想模型。
- x) R" W  P1 K本文主要写了通过LSTM进行数据拟合,从而预测比特币的未来价格。% \5 }2 ^8 N, O0 n4 P2 f
import需要使用的库
. a; L7 z3 }! i8 H9 z7 aimport pandas as pd' R- @; [  i! i. R' l; t# j  l
import numpy as np
. W7 n. |; I8 ^/ ?  ~1 \from sklearn.preprocessing import MinMaxScaler, LabelEncoder% b9 _$ K' O& M6 J, m+ D6 z$ R
from keras.models import Sequential9 @3 @- R2 \% e5 v0 S& P/ R
from keras.layers import LSTM, Dense, Dropout! N+ g  j+ p; X
from matplotlib import pyplot as plt  g1 L& N1 _+ a
%matplotlib inline
8 m0 U' K, ]& Y; F数据分析; W: R+ q* q# _9 R3 m- c4 e' Q
数据加载; J( ]& X5 F6 R! s) C, {: G1 T; O
读取BTC的日交易数据
% K6 N# t1 E) I6 C! |( Pdata = pd.read_csv(filepath_or_buffer="btc_data_day")
! d3 s+ ]7 H9 g. A& q查看数据可得,现在的数据一共有1380条,数据由Date、Open、High、Low、Close、Volume(BTC)、Volume(Currency)、Weighted Price这几列组成。其中除去Date列以外,其余的数据列都是float64数据类型。* e" i! ^6 _, u5 p' i& c/ h
data.info()  t; K) X# l; Z" ~
查看下前10行的数据
1 m8 b% W3 E& N5 {1 ~- Sdata.head(10)+ O$ N% w  x; k9 J; f

' u" G4 f  F) z; a, L数据可视化
8 l  E. ]; {! e* G+ W* `' y3 M使用matplotlib将Weighted Price绘制出来,看下数据的分布跟走势。在图中我们发现了有一段数据0的部分,我们需要确认下数据是否有异常。; t! {: n" S) n; j! A* m% L
plt.plot(data['Weighted Price'], label='Price')5 `$ O! v/ e! k* P. U9 J' m$ b
plt.ylabel('Price')8 Y$ ~( |3 P8 r5 Y! p' J( j
plt.legend()! d7 s1 F& A7 [# b  }
plt.show()
0 f+ R# o" b) X* O1 u5 r$ H
. J7 R2 w6 `0 Y8 C& V异常数据处理9 m2 F, ?2 X. c1 h5 e6 h) V
先查看下数据是否含有nan的数据,可以看到我们的数据中没有nan的数据
3 Z; M- s: l6 x& n5 ddata.isnull().sum()
1 y9 T: \" g3 ^7 ~, N. \1 S" tDate                 0) o& x9 x" W2 N5 u# N
Open                 0
* ~$ V; Q5 `, l+ F6 qHigh                 0, W/ l! v! d/ O7 O+ _7 W( M
Low                  0
/ j" Z8 d. O' I, b9 zClose                0
* M/ Y" n" U: z- K3 m# g- ?/ v" lVolume (BTC)         0
) l3 P: G7 M& q3 o" HVolume (Currency)    0
* |- ]7 e% ]. a, K, F) D6 X# _Weighted Price       0, f7 e+ }- \$ s/ _8 a4 I; K
dtype: int648 K0 z) c* A* H
再查看下0数据,可以看到我们的数据中含有0值,我们需要对0值做下处理8 ]; `! n2 y! E/ p" b
(data == 0).astype(int).any()
8 \0 k' T$ s2 u. A+ G  gDate                 False
2 W" B( P; _  vOpen                  True
8 Z' y; Y6 f; R4 QHigh                  True5 s, r# r2 y7 y
Low                   True
/ i' u& }  d6 S1 I7 NClose                 True
$ s- l  N- _4 u% `7 Y9 [Volume (BTC)          True( l4 h0 R3 ]$ A7 ]  k$ ]. u2 `
Volume (Currency)     True
9 ?3 H7 G# u6 I9 E! I6 V8 CWeighted Price        True" l$ P' Z" k% P  p7 m4 }8 E8 j
dtype: bool/ K  @4 x  V+ r9 o& t
data['Weighted Price'].replace(0, np.nan, inplace=True)
$ U6 o$ g9 ]; t' e( p& W  {data['Weighted Price'].fillna(method='ffill', inplace=True)
' u0 t/ v& R  [% @+ y" h& Zdata['Open'].replace(0, np.nan, inplace=True)
  W0 A& I! X2 i: U- R+ g) S/ k" Adata['Open'].fillna(method='ffill', inplace=True)
: `" `! Y* o1 N2 udata['High'].replace(0, np.nan, inplace=True)% \; q  w3 n8 D
data['High'].fillna(method='ffill', inplace=True); Q/ T2 R; e2 B1 s
data['Low'].replace(0, np.nan, inplace=True)+ k+ w/ Q5 x. O( A% ?; l
data['Low'].fillna(method='ffill', inplace=True)- C' r, V! ~2 D* `
data['Close'].replace(0, np.nan, inplace=True)( |- V  [: ?2 K; T. s
data['Close'].fillna(method='ffill', inplace=True)
) l" g' D4 h% m' E3 P* F2 ?' F2 Ldata['Volume (BTC)'].replace(0, np.nan, inplace=True)/ C/ _: G2 J, E4 \( x) Y6 O$ A
data['Volume (BTC)'].fillna(method='ffill', inplace=True)# k* C" M8 d  d! [1 {
data['Volume (Currency)'].replace(0, np.nan, inplace=True)+ b( \+ \3 A+ v7 c9 U1 d
data['Volume (Currency)'].fillna(method='ffill', inplace=True)
) J) w, F6 }* g4 D: s- }7 a(data == 0).astype(int).any()9 z$ ?0 i. A/ l, y
Date                 False0 d) H$ [% G( k5 ~
Open                 False" O6 x- S: ?9 W
High                 False
1 X* M- D9 y  W' s+ t' kLow                  False
. t. z; |: V+ x/ q5 X6 R0 o, ?2 eClose                False- _, r; P% x4 X3 P
Volume (BTC)         False
( u- Q+ h( ]! g, s: aVolume (Currency)    False/ ^7 k  M/ R. y" ]' [5 m0 ?7 H
Weighted Price       False
% K( M$ Z: Y1 V1 k& ldtype: bool/ l4 D% Q) S1 z) G" X
再看下数据的分布跟走势,这个时候曲线已经非常的连续& Q  ~1 K, _8 ^, j$ `. B; @
plt.plot(data['Weighted Price'], label='Price')" A3 K' i7 z; D) Q* r% C
plt.ylabel('Price')
6 B4 o5 U+ }* e. \/ T  {0 Wplt.legend()7 n* S- z: R1 q& R
plt.show(), ?8 g2 R0 M- I2 d. q  ^

9 w+ h2 H  b4 o1 z) K: j8 D! w训练数据集和测试数据集划分4 D. d' w8 q% {
将数据归一化到0-1' {1 N! H/ C! o$ H& \
data_set = data.drop('Date', axis=1).values
/ ]4 R9 I9 g6 V! K4 z( edata_set = data_set.astype('float32')1 @  M3 A% h& T( q+ x: z
mms = MinMaxScaler(feature_range=(0, 1))
, z, q  f4 w9 S2 hdata_set = mms.fit_transform(data_set)
1 L0 [" |% U! r以2:8划分测试数据集跟训练数据集2 c( Z1 O/ ]" N1 @: v
ratio = 0.8
4 y- T) M( |& b: otrain_size = int(len(data_set) * ratio)3 L( X( k/ B, v* T# R
test_size = len(data_set) - train_size% D4 U: q8 A" d% `4 m- E9 x) }
train, test = data_set[0:train_size,:], data_set[train_size:len(data_set),:]; @' s4 g9 j& p8 ?0 Z' ?
创建训练数据集跟测试数据集,以1天作为窗口期来创建我们的训练数据集跟测试数据集。! H, F2 o  m" B3 r4 {1 Q' u
def create_dataset(data):
( W; o) \# o7 V    window = 1. E, H; @7 ~& o5 y
    label_index = 6
! x2 d+ t4 x- K% j' ^    x, y = [], []
# `4 X4 Q5 u( Q) W    for i in range(len(data) - window):" Q4 }2 ]* o. ?' B
        x.append(data[i:(i + window), :])
1 k/ h8 F  w0 G. o        y.append(data[i + window, label_index])
7 x" P# T: F  n! M. @% `    return np.array(x), np.array(y), f; f9 C# J) p, a( U7 h- G
train_x, train_y = create_dataset(train)- ^. f8 S* ~* D8 V- G3 Q; M+ [
test_x, test_y = create_dataset(test)
% L- z  w9 P( w7 i! r定义模型并训练" R; C+ b' {. q5 o
这次我们使用一个简单的模型,这个模型结构如下1. LSTM2. Dense。& _+ G) H/ J; O4 d# y8 l) H3 }# O
这里需要对LSTM的inputh shape做下说明, Input Shape的输入维度为(batch_size, time steps, features)。其中,time steps值的是数据输入的时候的时间窗口间隔,这里我们使用1天作为时间窗口,并且我们的数据都是日数据,因此这里我们的time steps为1。
6 }4 U, z) T. v  C$ S; m5 N* }. F长短期记忆(Long short-term memory, LSTM)是一种特殊的RNN,主要是为了解决长序列训练过程中的梯度消失和梯度爆炸问题,这里先简单介绍下LSTM。
3 h/ f% T* `) R2 N$ S$ [4 A! y4 K$ J
8 I+ P9 c; m" C, V1 m1 z; p7 N从LSTM的网络结构示意图中,可以看到LSTM其实是一个小型的模型,他包含了3个sigmoid激活函数,2个tanh激活函数,3个乘法,1个加法。4 K5 Q) c. C: }5 r- _# _# {& d5 _
细胞状态" a! ~+ I- p2 U
细胞状态是LSTM的核心,他是上图中最上面的那根黑线, 在这根黑线下面是一些门,我们在后面介绍。细胞状态会根据每个门的结果,来得到更新。下面我们介绍下这些门,你就会理解细胞状态的流程。2 R4 z  W. L: ^/ g5 F$ t
LSTM网络能通过一种被称为门的结构对细胞状态进行删除或者添加信息。门能够有选择性的决定让哪些信息通过。门的结构是一个sigmoid层和一个点乘操作的组合。因为sigmoid层的输出是0-1的值,0表示都不能通过,1表示都能通过。一个LSTM里面包含三个门来控制细胞状态。下面我们来一一介绍下这些门。: n9 \! y( i' A9 t6 V* E! I. ~: N
遗忘门
; a% P. p' O  }( \LSTM的第一步就是决定细胞状态需要丢弃哪些信息。这部分操作是通过一个称为忘记门的sigmoid单元来处理的。我们来看下动画示意图,
& s) q6 X; a2 |
5 o+ Q# M2 R$ n( e7 l  X我们可以看到,遗忘门通过查看$h_{l-1}$和$x_{t}$信息来输出一个0-1之间的向量,该向量里面的0-1值表示细胞状态$C_{t-1}$中的哪些信息保留或丢弃多少。0表示不保留,1表示都保留。
7 ]) o! B0 Y4 x3 _8 Q9 R. D" S数学表达式: $f_{t}=\sigma\left(W_{f} \cdot\left[h_{t-1}, x_{t}\right]+b_{f}\right)$* c( }7 R$ K6 L$ \
输入门$ J+ T1 S( E% y* s% _8 O
下一步是决定给细胞状态添加哪些新的信息,这个步骤是通过输入门开完成的。我们先来看下动画示意图,8 q* X8 u* k) o0 A) D7 e, O& L
8 |* i1 n, ]. s9 ~; `8 o' x) X
我们看到了$h_{l-1}$和$x_{t}$的信息又被放入了一个遗忘门(sigmoid)跟输入门(tanh)中。因为遗忘门的输出结果是0-1的值,因此,如果遗忘门输出的是0的话,输入门后的结果$C_{i}$将不会被添加到当前的细胞状态中,如果是1,会全部的被添加到细胞状态中,因此这里的遗忘门的作用是将输入门的结果选择性的添加到细胞状态中。" E8 l; T& d$ I. P, X# T- Q
数学公式为: $C_{t}=f_{t} * C_{t-1}+i_{t} * \tilde{C}_{t}$
0 i+ u$ O" s& J- C8 w输出门
7 _% N! D6 `- k# Z更新完细胞状态后需要根据$h_{l-1}$和$x_{t}$输入的和来判断输出细胞的哪些状态特征,这里需要将输入经过一个称为输出门的sigmoid层得到判断条件,然后将细胞状态经过tanh层得到一个-1~1之间值的向量,该向量与输出门得到的判断条件相乘就得到了最终该RNN单元的输出, 动画示意图如下
/ X7 M! m1 l* _* F2 o/ q' y
1 h3 Z0 {& h* p- Vdef create_model():7 I6 Z! |4 k, C- L+ R4 H' t1 C/ v
    model = Sequential()$ d' O3 p9 o- {. M+ M
    model.add(LSTM(50, input_shape=(train_x.shape[1], train_x.shape[2])))
5 Z( S* l+ m! w: _) E( w    model.add(Dense(1))* l8 X( A' Y, L; D
    model.compile(loss='mae', optimizer='adam')% q- e5 m9 o6 K3 V7 ]
    model.summary()
+ G4 L* i+ u/ _6 K: ^$ k% }3 w    return model
, E  s# [1 `% K1 U# _model = create_model()
6 y: j: O! n9 G+ N, O. ?" r
6 w6 u8 I4 U1 X/ B, L9 {. jhistory = model.fit(train_x, train_y, epochs=80, batch_size=64, validation_data=(test_x, test_y), verbose=1, shuffle=False)
  K2 N1 b! T# c3 G8 d7 tplt.plot(history.history['loss'], label='train'), }8 H+ B9 A: h, I# W0 o
plt.plot(history.history['val_loss'], label='test'), O, L. N" k; a
plt.legend()
3 P7 H# p( Q) W  Eplt.show()
8 E5 G3 e4 U3 \" ?, w% o; y. y% A0 R; g2 m- W# z: x/ Z
train_x, train_y = create_dataset(train)# f7 ^2 {( w; E4 A8 G
test_x, test_y = create_dataset(test)& u% M% q7 ^$ n5 T1 o, u* C
预测
1 o3 G5 m7 L. w* D9 h$ ^' rpredict = model.predict(test_x)5 p$ M; Q+ K9 |! Y
plt.plot(predict, label='predict')
: A6 w4 X! R7 I* H2 Uplt.plot(test_y, label='ground true')
9 n/ r% N0 t4 A0 C6 }plt.legend()5 P$ h8 l3 R7 k' c. r; k* h
plt.show()
% E# z* r1 _* T; R2 V9 `/ W8 _
- l6 K2 \% m  Q. E+ v当前利用机器学习预测比特币长期价格走势还是非常困难的,本文只能作为学习案例使用。该案例之后会上线与矩池云的Demo镜像之中,感兴趣的用户可以直接体验。
BitMere.com 比特池塘系信息发布平台,比特池塘仅提供信息存储空间服务。
声明:该文观点仅代表作者本人,本文不代表比特池塘立场,且不构成建议,请谨慎对待。
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

成为第一个吐槽的人

Cherry95 小学生
  • 粉丝

    0

  • 关注

    0

  • 主题

    2