分享

Backtrader量化平台教程(一):backtrader的整体框架

 imelee 2018-03-07

  backtrader是一个量化策略的回测分析平台,功能还是很强大的。

1.安装backtrader

安装很简单,和别的lib安装一模一样,pip install backtrader。

2.从代码开始

  1. from __future__ import (absolute_import, division, print_function,  
  2.                         unicode_literals)  
  3.   
  4. import datetime  # For datetime objects  
  5. import os.path  # To manage paths  
  6. import sys  # To find out the script name (in argv[0])  
  7. import pandas as pd  
  8. from WindPy import w  
  9. # Import the backtrader platform  
  10. import backtrader as bt  
  11.   
  12.   
  13. # Create a Stratey  
  14. class TestStrategy(bt.Strategy):  
  15.   
  16.     def log(self, txt, dt=None):  
  17.         ''''' Logging function fot this strategy'''  
  18.         dt = dt or self.datas[0].datetime.date(0)  
  19.         print('%s, %s' % (dt.isoformat(), txt))  
  20.   
  21.     def __init__(self):  
  22.         # Keep a reference to the "close" line in the data[0] dataseries  
  23.         self.dataclose = self.datas[0].close  
  24.         # To keep track of pending orders  
  25.         self.order = None  
  26.   
  27.     def notify(self, order):  
  28.         if order.status in [order.Submitted, order.Accepted]:  
  29.             # Buy/Sell order submitted/accepted to/by broker - Nothing to do  
  30.             return  
  31.   
  32.         # Check if an order has been completed  
  33.         # Attention: broker could reject order if not enougth cash  
  34.         if order.status in [order.Completed, order.Canceled, order.Margin]:  
  35.             if order.isbuy():  
  36.                 self.log('BUY EXECUTED, %.2f' % order.executed.price)  
  37.             elif order.issell():  
  38.                 self.log('SELL EXECUTED, %.2f' % order.executed.price)  
  39.   
  40.             self.bar_executed = len(self)  
  41.   
  42.         # Write down: no pending order  
  43.         self.order = None  
  44.   
  45.     def next(self):  
  46.         # Simply log the closing price of the series from the reference  
  47.         self.log('Close, %.2f' % self.dataclose[0])  
  48.   
  49.         # Check if an order is pending ... if yes, we cannot send a 2nd one  
  50.         if self.order:  
  51.             return  
  52.   
  53.         # Check if we are in the market  
  54.         if not self.position:  
  55.   
  56.             # Not yet ... we MIGHT BUY if ...  
  57.             if self.dataclose[0] < self.dataclose[-1]:  
  58.                 # current close less than previous close  
  59.   
  60.                 if self.dataclose[-1] < self.dataclose[-2]:  
  61.                     # previous close less than the previous close  
  62.   
  63.                     # BUY, BUY, BUY!!! (with default parameters)  
  64.                     self.log('BUY CREATE, %.2f' % self.dataclose[0])  
  65.   
  66.                     # Keep track of the created order to avoid a 2nd order  
  67.                     self.order = self.buy()  
  68.   
  69.         else:  
  70.   
  71.             # Already in the market ... we might sell  
  72.             if len(self) >= (self.bar_executed + 5):  
  73.                 # SELL, SELL, SELL!!! (with all possible default parameters)  
  74.                 self.log('SELL CREATE, %.2f' % self.dataclose[0])  
  75.   
  76.                 # Keep track of the created order to avoid a 2nd order  
  77.                 self.order = self.sell()  
  78.   
  79.   
  80. if __name__ == '__main__':  
  81.     # Create a cerebro entity  
  82.     cerebro = bt.Cerebro()  
  83.   
  84.     # Add a strategy  
  85.     cerebro.addstrategy(TestStrategy)  
  86.   
  87.     # Create a Data Feed  
  88.     # 本地数据,笔者用Wind获取的东风汽车数据以csv形式存储在本地。  
  89.     # parase_dates = True是为了读取csv为dataframe的时候能够自动识别datetime格式的字符串,big作为index  
  90.     # 注意,这里最后的pandas要符合backtrader的要求的格式  
  91.     dataframe = pd.read_csv('dfqc.csv', index_col=0, parse_dates=True)  
  92.     dataframe['openinterest'] = 0  
  93.     data = bt.feeds.PandasData(dataname=dataframe,  
  94.                         fromdate = datetime.datetime(2015, 1, 1),  
  95.                         todate = datetime.datetime(2016, 12, 31)  
  96.                         )  
  97.     # Add the Data Feed to Cerebro  
  98.     cerebro.adddata(data)  
  99.   
  100.     # Set our desired cash start  
  101.     cerebro.broker.setcash(100000.0)  
  102.   
  103.     # Print out the starting conditions  
  104.     print('Starting Portfolio Value: %.2f' % cerebro.broker.getvalue())  
  105.   
  106.     # Run over everything  
  107.     cerebro.run()  
  108.   
  109.     # Print out the final result  
  110.     print('Final Portfolio Value: %.2f' % cerebro.broker.getvalue())  
  111.     # Plot the result  
  112.     cerebro.plot()  
上面这段代码,大家安装完backtrader之后可以复制过去运行一样,一般来说,运行通过就说明环境没有问题。接下来我们就分析一下这个不赚钱的策略。

我们想想,量化回测,首先得有数据。

在backtrader里面,DataFeed就是这样一个数据的概念。

  1. dataframe = pd.read_csv('dfqc.csv', index_col=0, parse_dates=True)  
  2. dataframe['openinterest'] = 0  
  3. data = bt.feeds.PandasData(dataname=dataframe,  
  4.                         fromdate = datetime.datetime(2015, 1, 1),  
  5.                         todate = datetime.datetime(2016, 12, 31)  
  6.                         )  

这一段代码从本地csv文件获得某一个股票的交易数据,包括open,close,high,low,volume。大家注意到,这里我们的存储形式的pandas。backtrader是支持pandas这样的一种数据格式的,无形中方便了很多

关于该数据文件,大家可以去笔者的百度云下载。

链接:https://pan.baidu.com/s/1slnULbv 密码:wi3k

后面的很多教程案例,都会用到这一数据。

backtrader对每种数据的来源都有一定的标准,要不然咱们相信,不订立标准,框架怎么会知道每一列数据都是干嘛的呢。backtrader对于pandas的标准就是这些列的名字得是open,close,high,low,volume,openinterest。我们这里没有用到openinterest,所以把它设置为零就可以了,这里提示一下,backtrader要求pandas下的DataFeed,pandas的DataFrame的index是时间。

数据的问题解决了,那么数据要交给回测平台。这里整个回测功能的实现都是依赖于cercbro这个类实现的。这个单词的意思,在西班牙语里就是大脑。

我们创造一个大脑,

  1. # Create a cerebro entity  
  2.     cerebro = bt.Cerebro()  
然后把之前的数据喂给大脑:

  1. # Add the Data Feed to Cerebro  
  2.     cerebro.adddata(data)  
基础建设基本就完成了。

接下来就是技术性的较量,策略啦。

  1. class TestStrategy(bt.Strategy):  
每一个策略都是一个类,是一个继承bt.Strategy类的父类。具体里面的细节,下次再说。

假设我们写好了一个策略,换句话说,就是构造好了一个Strategy类,那么我们就应该把它喂给大脑。

  1. # Add a strategy  
  2.     cerebro.addstrategy(TestStrategy)  
好了,都齐全了。但是别忘了,我们还应该制定初始资金。

  1. # Set our desired cash start  
  2.     cerebro.broker.setcash(100000.0)  

cerebro里面的broker成员就是管这事的。我们给了他100000元。
到这里,该有的都有了,我们run就可以了。cerebro.run()方法就是把上述东西跑起来。
跑完之后,我们想看一下效果,人嘛,可视化的最好,所以:
  1. # Plot the result  
  2.    cerebro.plot()  
就能把结果跑出来。

3.我的结果


很显然,亏钱了,但是不要紧,程序对了,万里长征第一步对了。
俗话说的好,万事开头难,中间也难,结尾更难。

4.总结

最后总结一下,一个策略,你需要的是数据,而且要让回测平台认识,所以是满足一定规则整理的数据。然后就是回测的“脑子”。这些基础设施有了,写好你的策略。策略其实就是一个类,重写类里的方法就实现了一个个策略。接下来,run就可以了。so easy!




    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多