指定替代日期时间格式“异常：无效的日期时间。一定比上一个大”

Question

我正在尝试读取每15分钟有一个新数据输入的csv。据我所知，我之所以返回这个异常是因为日期并不是每行都改变，但时间确实改变了。但是，feed没有及时读取，我不知道如何修复它。这是我的密码：

from pyalgotrade.feed import csvfeed

feed = csvfeed.Feed("Date","%d/%m/%Y")
feed.addValuesFromCSV("eurusd-15m-july-small.csv")
for dateTime, value in feed:
    print (dateTime, value)

我的csv看起来像这样：

Date,Time,Open,High,Low,Close,Volume
07/08/2018,17:30:00,1.15994,1.15994,1.15961,1.15982,414
07/08/2018,17:45:00,1.15982,1.16001,1.15964,1.15996,485

以下是完整错误：

(datetime.datetime(2018, 8, 7, 0, 0), {'High': 1.15994, 'Volume': 414.0, 
'Low': 1.15961, 'Time': '17:30:00', 'Close': 1.15982, 'Open': 1.15994})
---------------------------------------------------------------------------
Exception                                 Traceback (most recent call last)
<ipython-input-12-0cbdbe588a05> in <module>()
      3 feed = csvfeed.Feed("Date","%d/%m/%Y")
      4 feed.addValuesFromCSV("eurusd-15m-july-small.csv")
----> 5 for dateTime, value in feed:
      6     print (dateTime, value)

/Users/Phil/anaconda2/lib/python2.7/site- 
packages/pyalgotrade/feed/__init__.pyc in feed_iterator(feed)
     29     try:
     30         while not feed.eof():
---> 31             yield feed.getNextValuesAndUpdateDS()
     32     finally:
     33         feed.stop()

/Users/Phil/anaconda2/lib/python2.7/site- 
packages/pyalgotrade/feed/__init__.pyc in getNextValuesAndUpdateDS(self)
     88                     ds = self.createDataSeries(key, self.__maxLen)
     89                     self.__ds[key] = ds
---> 90                 ds.appendWithDateTime(dateTime, value)
     91         return (dateTime, values)
     92 

/Users/Phil/anaconda2/lib/python2.7/site- 
packages/pyalgotrade/dataseries/__init__.pyc in appendWithDateTime(self, 
dateTime, value)
    134 
    135         if dateTime is not None and len(self.__dateTimes) != 0 and 
self.__dateTimes[-1] >= dateTime:
--> 136             raise Exception("Invalid datetime. It must be bigger than 
that last one")
    137 
    138         assert(len(self.__values) == len(self.__dateTimes))

Exception: Invalid datetime. It must be bigger than that last one

提前谢谢！你知道吗

Answer 1

问题是datetime在两个独立的列中，所以@daniel提到必须自定义解析。试试这个：

import datetime

from pyalgotrade.feed import csvfeed


# Row parser that extracts the datetime combining 2 columns
class RowParser(csvfeed.RowParser):
    def parseRow(self, csvRowDict):
        dateTimeCombined = "%s %s" % (csvRowDict["Date"], csvRowDict["Time"])
        dateTime = datetime.datetime.strptime(dateTimeCombined, "%d/%m/%Y %H:%M:%S")

        # Convert the values
        values = {}
        for key, value in csvRowDict.items():
            if key not in ["Date", "Time"]:
                values[key] = csvfeed.float_or_string(key, value)
        return (dateTime, values)

    def getFieldNames(self):
        return None

    def getDelimiter(self):
        return ","


feed = csvfeed.BaseFeed(RowParser())
feed.addValuesFromCSV("eurusd-15m-july-small.csv")
for dateTime, value in feed:
    print (dateTime, value)