diff --git a/pyFTS/hyperparam/Evolutionary.py b/pyFTS/hyperparam/Evolutionary.py index 4ac030f..71ec842 100644 --- a/pyFTS/hyperparam/Evolutionary.py +++ b/pyFTS/hyperparam/Evolutionary.py @@ -17,7 +17,7 @@ from pyFTS.distributed import dispy as dUtil __measures = ['f1', 'f2', 'rmse', 'size'] -# + def genotype(mf, npart, partitioner, order, alpha, lags, f1, f2): ''' Create the individual genotype diff --git a/pyFTS/models/multivariate/mvfts.py b/pyFTS/models/multivariate/mvfts.py index fdacfc0..20a3084 100644 --- a/pyFTS/models/multivariate/mvfts.py +++ b/pyFTS/models/multivariate/mvfts.py @@ -32,6 +32,7 @@ class MVFTS(fts.FTS): self.is_multivariate = True self.shortname = "MVFTS" self.name = "Multivariate FTS" + self.uod_clip = False def append_variable(self, var): """ diff --git a/pyFTS/tests/general.py b/pyFTS/tests/general.py index 894b83e..22e221d 100644 --- a/pyFTS/tests/general.py +++ b/pyFTS/tests/general.py @@ -52,6 +52,21 @@ datasets['TAIEX'] = TAIEX.get_data()[:5000] datasets['NASDAQ'] = NASDAQ.get_data()[:5000] datasets['SP500'] = SP500.get_data()[10000:15000] +#''' +for dataset_name, dataset in datasets.items(): + bchmk.sliding_window_benchmarks2(dataset, 1000, train=0.8, inc=0.2, + methods=[pwfts.ProbabilisticWeightedFTS], + benchmark_models=False, + transformations=[None], + orders=[1, 2, 3], + partitions=np.arange(10, 100, 5), + progress=False, type='point', + distributed=True, nodes=['192.168.254.113'], + file="experiments.db", dataset=dataset_name, + tag="gridsearch") + +''' + competitor_methods = [] competitor_methods.extend([arima.ARIMA]*3) competitor_methods.extend([quantreg.QuantileRegression]*2) @@ -89,9 +104,9 @@ for dataset_name, dataset in datasets.items(): partitions=[35], steps_ahead=[10], progress=False, type='point', - distributed=False, nodes=['192.168.0.110', '192.168.0.107','192.168.0.106'], - file="tmp.db", dataset=dataset_name, + distributed=True, nodes=['192.168.0.110', '192.168.0.107','192.168.0.106'], + file="experiments.db", dataset=dataset_name, tag="experiments") -#''' \ No newline at end of file +''' diff --git a/pyFTS/tests/multivariate.py b/pyFTS/tests/multivariate.py index bf253cb..784285f 100644 --- a/pyFTS/tests/multivariate.py +++ b/pyFTS/tests/multivariate.py @@ -21,6 +21,55 @@ from pyFTS.common import Membership import os + +dataset = pd.read_csv('https://query.data.world/s/2bgegjggydd3venttp3zlosh3wpjqj', sep=';') + +dataset['data'] = pd.to_datetime(dataset["data"], format='%Y-%m-%d %H:%M:%S') + +train_uv = dataset['glo_avg'].values[:24505] +test_uv = dataset['glo_avg'].values[24505:] + +train_mv = dataset.iloc[:24505] +test_mv = dataset.iloc[24505:] + +from pyFTS.models.multivariate import common, variable, mvfts +from pyFTS.models.seasonal import partitioner as seasonal +from pyFTS.models.seasonal.common import DateTime + +from itertools import product + +levels = ['VL', 'L', 'M', 'H', 'VH'] +sublevels = [str(k) for k in np.arange(0, 7)] +names = [] +for combination in product(*[levels, sublevels]): + names.append(combination[0] + combination[1]) + +sp = {'seasonality': DateTime.day_of_year , 'names': ['Jan','Feb','Mar','Apr','May', + 'Jun','Jul', 'Aug','Sep','Oct', + 'Nov','Dec']} + +vmonth = variable.Variable("Month", data_label="data", partitioner=seasonal.TimeGridPartitioner, npart=12, + data=train_mv, partitioner_specific=sp) + + +sp = {'seasonality': DateTime.minute_of_day, 'names': [str(k)+'hs' for k in range(0,24)]} + +vhour = variable.Variable("Hour", data_label="data", partitioner=seasonal.TimeGridPartitioner, npart=24, + data=train_mv, partitioner_specific=sp) + +vavg = variable.Variable("Radiation", data_label="glo_avg", alias='rad', + partitioner=Grid.GridPartitioner, npart=35, partitioner_specific={'names': names}, + data=train_mv) +fs = grid.GridCluster(explanatory_variables=[vmonth, vhour, vavg], target_variable=vavg) +model = cmvfts.ClusteredMVFTS(explanatory_variables=[vmonth, vhour, vavg], target_variable=vavg, partitioner=fs, + order=2, knn=1) + +model.fit(train_mv) +forecasts = model.predict(test_mv.iloc[:100]) + +print(forecasts) + + ''' from pyFTS.data import lorentz df = lorentz.get_dataframe(iterations=5000) @@ -76,7 +125,7 @@ for horizon in [1, 25, 50, 75, 100]: final = pd.DataFrame(rows, columns=columns) final.to_csv('gmvfts_lorentz1.csv',sep=';',index=False) -''' + import pandas as pd df = pd.read_csv('https://query.data.world/s/ftb7bzgobr6bsg6bsuxuqowja6ew4r') @@ -146,4 +195,5 @@ for horizon in [1, 25, 50, 75, 100]: columns.append('h{}'.format(horizon)) final = pd.DataFrame(rows, columns=columns) -final.to_csv('gmvfts_gefcom12.csv', sep=';', index=False) \ No newline at end of file +final.to_csv('gmvfts_gefcom12.csv', sep=';', index=False) +'''