pywatts/pywatts/kcross.py

59 lines
2.1 KiB
Python

import random
def split(data, k):
"""Returns (X_train, y_train, X_eval, y_eval)"""
# Training features as list of dictionaries (each dict is for ONE test run)
X_train = []
# Training labels as list of dictionaries (each dict is for ONE test run)
y_train = []
# Evaluation features as list of dictionaries (each i-th dict includes all features except X_train[i])
X_eval = []
# Evaluation labels as list of dictionaries (each i-th dict includes all labels except X_train[i])
y_eval = []
data_list = data['dc'].tolist()
# Each sample has 337 elements
samples = [data_list[i:i+337] for i in range(0, len(data_list) - 337, 30)]
# Randomly shuffle samples
random.shuffle(samples)
bucketsize = int(len(samples) / k)
# K steps
for i in range(k):
eval_samples = []
train_samples = []
for j in range(k):
if j == i:
eval_samples.extend(samples[j*bucketsize:(j+1)*bucketsize])
else:
train_samples.extend(samples[j*bucketsize:(j+1)*bucketsize])
# Create new dictionaries in the eval lists
X_eval.append({'dc': [x for s in eval_samples for c, x in enumerate(s, 1) if c % 337 != 0]})
y_eval.append({'dc': [x for s in eval_samples for c, x in enumerate(s, 1) if c % 337 == 0]})
X_train.append({'dc': [x for s in train_samples for c, x in enumerate(s, 1) if c % 337 != 0]})
y_train.append({'dc': [x for s in train_samples for c, x in enumerate(s, 1) if c % 337 == 0]})
return X_train, y_train, X_eval, y_eval
def train(nn, X_train, y_train, X_eval, y_eval, steps=100):
"""Trains the Network nn using k-cross-validation"""
evaluation = []
for count, train_data in enumerate(X_train):
for i in range(steps):
nn.train(train_data, y_train[count], batch_size=1000, steps=30) #batch_size=int(len(train_data['dc'])/336), steps=1)
evaluation.append(nn.evaluate(X_eval[count], y_eval[count]))
print("Training %s: %s/%s" % (count, (i+1), steps))
return evaluation