使用次数越多, backtrader 必须面对的想法和意外场景的混合就越多。对于每个新平台,一个挑战是要看看平台是否能够达到开发开始时设置的期望,灵活性和易用性是目标,Python被选为基石。
工单#76 提出了一个问题,即是否可以完成具有不同交易日历的同步市场。直接尝试这样做失败了,问题创建者想知道为什么不 backtrader 查看日期。
在给出任何答案之前,必须考虑以下几点:
- 未对齐的天数的指示器的行为
 
对后者的回答是:
- 该平台尽可能地 
date和time不可知论,不会查看字段的内容来评估这些概念 
考虑到股票市场价格是datetime 串行的事实,上述可以保持 true 达到一定的限度。对于多个数据,以下设计注意事项适用:
-  
添加到
cerebro的第 1个数据是datamaster -  
所有其他数据必须在时间上对齐/同步,它永远无法超越(就
datetime而言)datamaster 
将上面的3个项目符号放在一起,可以提供问题创建者所经历的组合。场景:
-  
历年:
2012 -  
数据0:
^GSPC(或朋友的标准普尔500指数) -  
数据1:
^GDAXI(或朋友的Dax指数) 
通过以下方式运行自订文稿以查看数据是如何同步的backtrader:
$ ./weekdaysaligner.py --online --data1 '^GSPC' --data0 '^GDAXI'
输出:
0001, True, data0, 2012-01-03T23:59:59, 2012-01-03T23:59:59, data1 0002, True, data0, 2012-01-04T23:59:59, 2012-01-04T23:59:59, data1 0003, True, data0, 2012-01-05T23:59:59, 2012-01-05T23:59:59, data1 0004, True, data0, 2012-01-06T23:59:59, 2012-01-06T23:59:59, data1 0005, True, data0, 2012-01-09T23:59:59, 2012-01-09T23:59:59, data1 0006, True, data0, 2012-01-10T23:59:59, 2012-01-10T23:59:59, data1 0007, True, data0, 2012-01-11T23:59:59, 2012-01-11T23:59:59, data1 0008, True, data0, 2012-01-12T23:59:59, 2012-01-12T23:59:59, data1 0009, True, data0, 2012-01-13T23:59:59, 2012-01-13T23:59:59, data1 0010, False, data0, 2012-01-17T23:59:59, 2012-01-16T23:59:59, data1 0011, False, data0, 2012-01-18T23:59:59, 2012-01-17T23:59:59, data1 ...
一旦2012-01-16 交易日历发散。这是 data0 datamaster (^GSPC),即使 data1 (^GDAXI)会有一个柱线来兑现 2012-01-16,这不是标准普尔500指数 的交易日 。
最好的是,backtrader 当下一个交易日 ^GSPC 进来时,可以对上述设计限制做些什么, 2012-01-17 交付下一个尚未处理的日期 ^GDAXI 是 2012-01-16.
同步问题随着每个发散日而累积。在它的末尾2012 如下所示:
... 0249, False, data0, 2012-12-28T23:59:59, 2012-12-19T23:59:59, data1 0250, False, data0, 2012-12-31T23:59:59, 2012-12-20T23:59:59, data1
原因应该很明显:欧洲人比美国人交易的天数更多。
在票证 #76https://github.com/mementum/backtrader/issues/76 中,海报显示了什么 zipline 。让我们来看看 2012-01-13 - 2012-01-17 难题:
0009 : True : 2012-01-13 : close 1289.09 - 2012-01-13 : close 6143.08 0010 : False : 2012-01-13 : close 1289.09 - 2012-01-16 : close 6220.01 0011 : True : 2012-01-17 : close 1293.67 - 2012-01-17 : close 6332.93
起泡的藤壶!2012-01-13 的数据只是简单地 拷贝, 而没有明显要求用户许可。恕我直言,这不应该是因为平台的最终用户无法撤消此自发添加。
注意
除了简要介绍zipline之外,作者不知道这是否是脚本开发人员配置的标准行为,以及是否可以撤消
一旦我们看到其他人,让我们再次backtrader尝试使用积累的智能:欧洲人比美国人更频繁地交易。让我们反转 和 ^GDAXI 的角色^GSPC,看看结果:
$ ./weekdaysaligner.py --online --data1 '^GSPC' --data0 '^GDAXI'
输出(跳到2012-01-13 直接):
... 0009, True, data0, 2012-01-13T23:59:59, 2012-01-13T23:59:59, data1 0010, False, data0, 2012-01-16T23:59:59, 2012-01-13T23:59:59, data1 0011, True, data0, 2012-01-17T23:59:59, 2012-01-17T23:59:59, data1 ...
再次起泡藤壶!backtrader还拷贝了 2012-01-13 (在本例^GSPC中 ) 的值data1作为 (现在 ^GDAXI) 交付的2012-01-16匹配data0项。
甚至更好:
- 在下一个日期实现同步: 
2012-01-17 
同样的重新同步很快就会再次出现:
... 0034, True, data0, 2012-02-17T23:59:59, 2012-02-17T23:59:59, data1 0035, False, data0, 2012-02-20T23:59:59, 2012-02-17T23:59:59, data1 0036, True, data0, 2012-02-21T23:59:59, 2012-02-21T23:59:59, data1 ...
其次是不太容易的重新同步:
... 0068, True, data0, 2012-04-05T23:59:59, 2012-04-05T23:59:59, data1 0069, False, data0, 2012-04-10T23:59:59, 2012-04-09T23:59:59, data1 ... 0129, False, data0, 2012-07-04T23:59:59, 2012-07-03T23:59:59, data1 0130, True, data0, 2012-07-05T23:59:59, 2012-07-05T23:59:59, data1 ...
这样的情节不断重复,直到 last 栏^GDAXI 交付:
... 0256, True, data0, 2012-12-31T23:59:59, 2012-12-31T23:59:59, data1 ...
此同步问题backtrader 的原因是不会拷贝数据。
-  
datamaster一旦交付了一个新的酒吧,另datas一个就会被要求交付 -  
如果没有柱线可以传递电流
datetimedatamaster(例如,因为它将被超越),那么下一个最佳数据就是,可以说,重新传递这是一个已经看到的酒吧
date 
正确同步
但并非所有的希望都消失了。backtrader 可以交付。让我们使用 筛检程序。 backtrader 这项技术允许在数据到达平台最深处之前对其进行操作,例如计算指针。
注意
delivering 是一个感知问题,因此交付的 backtrader 可能不是接收者所期望的 delivery
实际代码
from __future__ import (absolute_import, division, print_function,
                        unicode_literals)
import datetime
class WeekDaysFiller(object):
    '''Bar Filler to add missing calendar days to trading days'''
    # kickstart value for date comparisons
    lastdt = datetime.datetime.max.toordinal()
    def __init__(self, data, fillclose=False):
        self.fillclose = fillclose
        self.voidbar = [float('Nan')] * data.size()  # init a void bar
    def __call__(self, data):
        '''Empty bars (NaN) or with last close price are added for weekdays with no
        data
        Params:
          - data: the data source to filter/process
        Returns:
          - True (always): bars are removed (even if put back on the stack)
        '''
        dt = data.datetime.dt()  # current date in int format
        lastdt = self.lastdt + 1  # move the last seen data once forward
        while lastdt < dt:  # loop over gap bars
            if datetime.date.fromordinal(lastdt).isoweekday() < 6:  # Mon-Fri
                # Fill in date and add new bar to the stack
                if self.fillclose:
                    self.voidbar = [self.lastclose] * data.size()
                self.voidbar[-1] = float(lastdt) + data.sessionend
                data._add2stack(self.voidbar[:])
            lastdt += 1  # move lastdt forward
        self.lastdt = dt  # keep a record of the last seen date
        self.lastclose = data.close[0]
        data._save2stack(erase=True)  # dt bar to the stack and out of stream
        return True  # bars are on the stack (new and original)
测试文稿已经具备了使用它的功能:
$ ./weekdaysaligner.py --online --data0 '^GSPC' --data1 '^GDAXI' --filler
将--filler 添加到 WeekDaysFiller 和 data0 data1中。输出:
0001, True, data0, 2012-01-03T23:59:59, 2012-01-03T23:59:59, data1 ... 0009, True, data0, 2012-01-13T23:59:59, 2012-01-13T23:59:59, data1 0010, True, data0, 2012-01-16T23:59:59, 2012-01-16T23:59:59, data1 0011, True, data0, 2012-01-17T23:59:59, 2012-01-17T23:59:59, data1 ...
第1个 难题 - 2012-01-13 2012-01-17 已经消失了。并且整个集合是同步的:
... 0256, True, data0, 2012-12-25T23:59:59, 2012-12-25T23:59:59, data1 0257, True, data0, 2012-12-26T23:59:59, 2012-12-26T23:59:59, data1 0258, True, data0, 2012-12-27T23:59:59, 2012-12-27T23:59:59, data1 0259, True, data0, 2012-12-28T23:59:59, 2012-12-28T23:59:59, data1 0260, True, data0, 2012-12-31T23:59:59, 2012-12-31T23:59:59, data1
值得注意的事情:
-  
正如我们
^GSPClines250(指数交易250日)2012data0 -  
data0256我们有^GDAXIlines(指数交易256日)2012 -  
随着到位,
WeekDaysFiller两个数据的长度已扩展到260添加
52*2(周末和周末中的几天),我们最终会得到364.在一年中正常365日子之前的剩余日子肯定是星期六或星期日。 
筛选器填充NaN 给定数据未进行交易的天数的值。让我们把它画出来:
$ ./weekdaysaligner.py --online --data0 '^GSPC' --data1 '^GDAXI' --filler --plot
充满的日子是显而易见的:
-  
柱线之间的间隙就在那里
 -  
对于 volume 图来说,差距更加明显
 
第2个图将尝试回答顶部的问题:指针会发生什么?请记住,新柱线的值已指定为 NaN (这就是为什么它们不显示):
$ ./weekdaysaligner.py --online --data0 '^GSPC' --data1 '^GDAXI' --filler --plot --sma 10
重新起泡藤壶!简单移动平均线打破了时空连续体,在没有连续性解的情况下跳过了一些柱。这当然是用Not a Number(又名NaN)填充的效果:数学运算不再有意义。
如果使用lastNaN看到的收盘价:
$ ./weekdaysaligner.py --online --data0 '^GSPC' --data1 '^GDAXI' --filler --plot --sma 10 --fillclose
在整个260天内,使用常规SMA,该情节看起来要好得多。
结论
将两种工具与不同的交易日历同步是一个决策和妥协的问题。backtrader 需要时间一致的数据来处理多个数据,不同的交易日历无济于事。
使用这里描述的WeekDaysFiller 可以缓解这种情况,但它绝不是普遍的灵丹妙药,因为用哪些值来填补是一个长期和长期考虑的问题。
脚本代码和用法
可作为以下来源backtrader的样品:
$ ./weekdaysaligner.py --help
usage: weekdaysaligner.py [-h] [--online] --data0 DATA0 [--data1 DATA1]
                          [--sma SMA] [--fillclose] [--filler] [--filler0]
                          [--filler1] [--fromdate FROMDATE] [--todate TODATE]
                          [--plot]
Sample for aligning with trade
optional arguments:
  -h, --help            show this help message and exit
  --online              Fetch data online from Yahoo (default: False)
  --data0 DATA0         Data 0 to be read in (default: None)
  --data1 DATA1         Data 1 to be read in (default: None)
  --sma SMA             Add a sma to the datas (default: 0)
  --fillclose           Fill with Close price instead of NaN (default: False)
  --filler              Add Filler to Datas 0 and 1 (default: False)
  --filler0             Add Filler to Data 0 (default: False)
  --filler1             Add Filler to Data 1 (default: False)
  --fromdate FROMDATE, -f FROMDATE
                        Starting date in YYYY-MM-DD format (default:
                        2012-01-01)
  --todate TODATE, -t TODATE
                        Ending date in YYYY-MM-DD format (default: 2012-12-31)
  --plot                Do plot (default: False)
代码:
from __future__ import (absolute_import, division, print_function,
                        unicode_literals)
import argparse
import datetime
import backtrader as bt
import backtrader.feeds as btfeeds
import backtrader.indicators as btind
import backtrader.utils.flushfile
# from wkdaysfiller import WeekDaysFiller
from weekdaysfiller import WeekDaysFiller
class St(bt.Strategy):
    params = (('sma', 0),)
    def __init__(self):
        if self.p.sma:
            btind.SMA(self.data0, period=self.p.sma)
            btind.SMA(self.data1, period=self.p.sma)
    def next(self):
        dtequal = (self.data0.datetime.datetime() ==
                   self.data1.datetime.datetime())
        txt = ''
        txt += '%04d, %5s' % (len(self), str(dtequal))
        txt += ', data0, %s' % self.data0.datetime.datetime().isoformat()
        txt += ', %s, data1' % self.data1.datetime.datetime().isoformat()
        print(txt)
def runstrat():
    args = parse_args()
    fromdate = datetime.datetime.strptime(args.fromdate, '%Y-%m-%d')
    todate = datetime.datetime.strptime(args.todate, '%Y-%m-%d')
    cerebro = bt.Cerebro(stdstats=False)
    DataFeed = btfeeds.YahooFinanceCSVData
    if args.online:
        DataFeed = btfeeds.YahooFinanceData
    data0 = DataFeed(dataname=args.data0, fromdate=fromdate, todate=todate)
    if args.data1:
        data1 = DataFeed(dataname=args.data1, fromdate=fromdate, todate=todate)
    else:
        data1 = data0.clone()
    if args.filler or args.filler0:
        data0.addfilter(WeekDaysFiller, fillclose=args.fillclose)
    if args.filler or args.filler1:
        data1.addfilter(WeekDaysFiller, fillclose=args.fillclose)
    cerebro.adddata(data0)
    cerebro.adddata(data1)
    cerebro.addstrategy(St, sma=args.sma)
    cerebro.run(runonce=True, preload=True)
    if args.plot:
        cerebro.plot(style='bar')
def parse_args():
    parser = argparse.ArgumentParser(
        formatter_class=argparse.ArgumentDefaultsHelpFormatter,
        description='Sample for aligning with trade ')
    parser.add_argument('--online', required=False, action='store_true',
                        help='Fetch data online from Yahoo')
    parser.add_argument('--data0', required=True, help='Data 0 to be read in')
    parser.add_argument('--data1', required=False, help='Data 1 to be read in')
    parser.add_argument('--sma', required=False, default=0, type=int,
                        help='Add a sma to the datas')
    parser.add_argument('--fillclose', required=False, action='store_true',
                        help='Fill with Close price instead of NaN')
    parser.add_argument('--filler', required=False, action='store_true',
                        help='Add Filler to Datas 0 and 1')
    parser.add_argument('--filler0', required=False, action='store_true',
                        help='Add Filler to Data 0')
    parser.add_argument('--filler1', required=False, action='store_true',
                        help='Add Filler to Data 1')
    parser.add_argument('--fromdate', '-f', default='2012-01-01',
                        help='Starting date in YYYY-MM-DD format')
    parser.add_argument('--todate', '-t', default='2012-12-31',
                        help='Ending date in YYYY-MM-DD format')
    parser.add_argument('--plot', required=False, action='store_true',
                        help='Do plot')
    return parser.parse_args()
if __name__ == '__main__':
    runstrat()