python - 滚动窗口 REVISITED - 添加窗口滚动数量作为参数 - 向前分析
问题描述
我一直在网上搜索可以创建滚动窗口的方法,以便我可以以通用的方式对时间序列执行称为前向分析的交叉验证技术。
但是,我还没有找到任何在 1)窗口大小(几乎所有方法都有这个;例如,pandas
滚动或有点不同的np.roll)和 2)窗口滚动量方面结合灵活性的解决方案,理解为如何我们想要滚动窗口的许多索引(即没有找到任何包含此内容的索引)。
在@coldspeed的帮助下,我一直在尝试优化并制作简洁的代码(我无法在此发表评论,因为我没有达到所需的声誉;希望尽快到达那里!),但我没有t 能够合并窗口滚动量。
我的想法:
我
np.roll
与下面的示例一起尝试过,但没有成功。我还尝试修改下面的代码乘以该
ith
值,但我无法将其放入我想维护的列表理解中。
3. 下面的示例适用于任何窗口大小,但是,它只会提前一步“滚动”窗口,我希望它可以推广到任何步骤。
那么,¿有没有办法让这两个参数在列表理解方法中可用?或者,¿是否有任何其他我没有找到的资源可以让这更容易?非常感谢所有帮助。我的示例代码如下:
In [1]: import numpy as np
In [2]: arr = np.random.random((10,3))
In [3]: arr
Out[3]: array([[0.38020065, 0.22656515, 0.25926935],
[0.13446667, 0.04386083, 0.47210474],
[0.4374763 , 0.20024762, 0.50494097],
[0.49770835, 0.16381492, 0.6410294 ],
[0.9711233 , 0.2004874 , 0.71186102],
[0.61729025, 0.72601898, 0.18970222],
[0.99308981, 0.80017134, 0.64955358],
[0.46632326, 0.37341677, 0.49950571],
[0.45753235, 0.55642914, 0.31972887],
[0.4371343 , 0.08905587, 0.74511753]])
In [4]: inSamplePercentage = 0.4
In [5]: outSamplePercentage = 0.3 * inSamplePercentage
In [6]: windowSizeTrain = round(inSamplePercentage * arr.shape[0])
In [7]: windowSizeTest = round(outSamplePercentage * arr.shape[0])
In [8]: windowTrPlusTs = windowSizeTrain + windowSizeTest
In [9]: sliceListX = [arr[i: i + windowTrPlusTs] for i in range(len(arr) - (windowTrPlusTs-1))]
给定 5 的窗口长度和 2 的窗口滚动数量,我可以指定如下内容:
Out [15]:
[array([[0.38020065, 0.22656515, 0.25926935],
[0.13446667, 0.04386083, 0.47210474],
[0.4374763 , 0.20024762, 0.50494097],
[0.49770835, 0.16381492, 0.6410294 ],
[0.9711233 , 0.2004874 , 0.71186102]]),
array([[0.4374763 , 0.20024762, 0.50494097],
[0.49770835, 0.16381492, 0.6410294 ],
[0.9711233 , 0.2004874 , 0.71186102],
[0.61729025, 0.72601898, 0.18970222],
[0.99308981, 0.80017134, 0.64955358]]),
array([[0.9711233 , 0.2004874 , 0.71186102],
[0.61729025, 0.72601898, 0.18970222],
[0.99308981, 0.80017134, 0.64955358],
[0.46632326, 0.37341677, 0.49950571],
[0.45753235, 0.55642914, 0.31972887]]),
array([[0.99308981, 0.80017134, 0.64955358],
[0.46632326, 0.37341677, 0.49950571],
[0.45753235, 0.55642914, 0.31972887],
[0.4371343 , 0.08905587, 0.74511753]])]
(这包含了最后一个数组,尽管它的长度小于 5)。
或者:
Out [16]:
[array([[0.38020065, 0.22656515, 0.25926935],
[0.13446667, 0.04386083, 0.47210474],
[0.4374763 , 0.20024762, 0.50494097],
[0.49770835, 0.16381492, 0.6410294 ],
[0.9711233 , 0.2004874 , 0.71186102]]),
array([[0.4374763 , 0.20024762, 0.50494097],
[0.49770835, 0.16381492, 0.6410294 ],
[0.9711233 , 0.2004874 , 0.71186102],
[0.61729025, 0.72601898, 0.18970222],
[0.99308981, 0.80017134, 0.64955358]]),
array([[0.9711233 , 0.2004874 , 0.71186102],
[0.61729025, 0.72601898, 0.18970222],
[0.99308981, 0.80017134, 0.64955358],
[0.46632326, 0.37341677, 0.49950571],
[0.45753235, 0.55642914, 0.31972887]])]
(只有长度 == 5 的数组 -> 但是,这可以从上面的一个简单的掩码派生而来)。
编辑:也忘了提到这一点——如果熊猫滚动对象支持iter方法,可以做一些事情。
解决方案
因此,给我两分钱(在@Ben.T 的帮助下),这里是创建前向分析基本工具的代码,以了解您的模型将如何以更通用的方式执行。
非锚定 WFA
def walkForwardAnal(myArr, windowSize, rollQty):
from numpy.lib.stride_tricks import as_strided
ArrRows, ArrCols = myArr.shape
ArrItems = myArr.itemsize
sliceQtyAndShape = (int((ArrRows - windowSize) / rollQty + 1), windowSize, ArrCols)
print('The final view shape is {}'.format(sliceQtyAndShape))
ArrStrides = (rollQty * ArrCols * ArrItems, ArrCols * ArrItems, ArrItems)
print('The final strides are {}'.format(ArrStrides))
sliceList = list(as_strided(myArr, shape=sliceQtyAndShape, strides=ArrStrides, writeable=False))
return sliceList
wSizeTr = 400
wSizeTe = 100
wSizeTot = wSizeTr + wSizeTe
rQty = 200
sliceListX = wf.walkForwardAnal(X, wSizeTot, rQty)
sliceListY = wf.walkForwardAnal(y, wSizeTot, rQty)
for sliceArrX, sliceArrY in zip(sliceListX, sliceListY):
## Consider having to make a .copy() of each array, so that we don't modify the original one.
# XArr = sliceArrX.copy() and hence, changing Xtrain, Xtest = XArr[...]
# YArr = sliceArrY.copy() and hence, changing Ytrain, Ytest = XArr[...]
Xtrain = sliceArrX[:-wSizeTe,:]
Xtest = sliceArrX[-wSizeTe:,:]
Ytrain = sliceArrY[:-wSizeTe,:]
Ytest = sliceArrY[-wSizeTe:,:]
锚定WFA
timeSeriesCrossVal = TimeSeriesSplit(n_splits=5)
for trainIndex, testIndex in timeSeriesCrossVal.split(X):
## Check if the training and testing quantities make sense. If not, increase or decrease the n_splits parameter.
Xtrain = X[trainIndex]
Xtest = X[testIndex]
Ytrain = y[trainIndex]
Ytest = y[testIndex]
然后,您可以创建以下内容(在两种方法中的任何一种中)并继续建模:
# Fit on training set only - The targets (y) are already encoded in dummy variables, so no need to standarize them.
scaler = StandardScaler()
scaler.fit(Xtrain)
# Apply transform to both the training set and the test set.
trainX = scaler.transform(Xtrain)
testX = scaler.transform(Xtest)
## PCA - Principal Component Analysis #### APPLY PCA TO THE STANDARIZED TRAINING SET! :::: Fit on training set only.
pca = PCA(.95)
pca.fit(trainX)
# Apply transform to both the training set and the test set.
trainX = pca.transform(trainX)
testX = pca.transform(testX)
## Predict and append predictions...
具有广义窗口滚动量的非锚定情况的一个衬垫:
sliceListX = [arr[i: i + wSizeTot] for i in range(0, arr.shape[0] - wSizeTot+1, rQty)]
推荐阅读
- ssas - 如何在 MDX 中进行递归求和?
- java - 驱动程序在 IntelliJ IDEA 中没有收到来自服务器的任何数据包
- graph - 我想在 Grafana 的图表上设置警报,但我无法设置
- laravel - Laravel Nova - 如何使用 Laravel 错误页面
- linux - Branching & Merging strategy - Linux kernel
- swift - 清除内存存储类型
- sql - 在 SSIS 中使用参数计算日期没有给出正确的结果
- c# - EF 查询可以为空吗?
- python - 我无法遍历完整的 l2 列表
- mysql - 为什么这个mysql触发器会出错?