X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=qp%2Fprediction.py;fp=qp%2Fprediction.py;h=c861ca7c0243ec8bc9316985cb936aacca957acb;hb=a1cb1abac5f5979f507b6760f0862c38c3ba2347;hp=0000000000000000000000000000000000000000;hpb=cd32fb9b8f63431086809c542b6dab26c8ea09b1;p=ric-app%2Fqp.git

diff --git a/qp/prediction.py b/qp/prediction.py
new file mode 100644
index 0000000..c861ca7
--- /dev/null
+++ b/qp/prediction.py
@@ -0,0 +1,45 @@
+# ==================================================================================
+#  Copyright (c) 2020 HCL Technologies Limited.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+# ==================================================================================
+# import pandas as pd
+import os
+import joblib
+import pandas as pd
+from qptrain import PROCESS
+
+
+def forecast(data, cid, nobs=1):
+    """
+     forecast the time series using the saved model.
+    """
+    data = data[['pdcpBytesUl', 'pdcpBytesDl']]
+    ps = PROCESS(data.copy())
+    ps.make_stationary()
+
+    if not ps.valid():
+        df_f = data.tail(1)
+    elif os.path.isfile('qp/'+cid):
+        model = joblib.load('qp/'+cid)
+        pred = model.forecast(y=ps.data.values, steps=nobs)
+
+        if pred is not None:
+            df_f = pd.DataFrame(pred, columns=data.columns)
+            df_f.index = pd.date_range(start=data.index[-1], freq='10ms', periods=len(df_f))
+            df_f = df_f[data.columns].astype(int)
+            df_f = ps.invert_transformation(data, df_f)
+    else:
+        return None
+    df_f = df_f[data.columns].astype(int)
+    return df_f