better_algo_v0.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {
    "datalore": {
     "hide_input_from_viewers": false,
     "hide_output_from_viewers": false,
     "node_id": "BJnL4Na9Ad7oRIjKy0nh2q",
     "type": "CODE"
    }
   },
   "outputs": [],
   "source": [
    "# aspects: inhouse generation and purchased \n",
    "\n",
    "# inputs:\n",
    "# inhouse generation = Wi(t)\n",
    "# price of electricity = Ci(t)\n",
    "# the total incoming load = L(t)\n",
    "# the QoS parameter = q\n",
    "\n",
    "# outpus:\n",
    "# the allocated workload to each datacenter\n",
    "# green workload, Ygi\n",
    "# brown workload, Ybi\n",
    "# total workload, Y\n",
    "\n",
    "\n",
    "# Algorithm:\n",
    "# i)    assume we have n datacenter\n",
    "# ii)   assume we are optimizing for each datacenter at once, and time slot are divided in hours\n",
    "# iii)  assume we have N division in the timeslot\n",
    "# iv)   for each time slot we will calculate the Y\n",
    "\n",
    "# Idea:\n",
    "# i)    we will consider Wi(t) to be a constant or zero\n",
    "# ii)   we will consider the price to be the announced per unit price of energy( electricity )\n",
    "# iii)  incoming load can be the load of peek hour\n",
    "# iv)   QoS parameter neglected\n",
    "\n",
    "\n",
    "# Brown Energy Treatment and Termination Algorithm\n",
    "# columns: 'time', 'total_incoming_green_energy', 'total_incoming_brown_energy',\n",
    "    #    'total_incoming_load', 'total_actual_load', 'green_energy_price',\n",
    "    #    'brown_energy_price'\n",
    "class Better(object):\n",
    "    def __init__(self, dataframe):\n",
    "        # the replicated dataset\n",
    "        self.df = dataframe.copy()\n",
    "\n",
    "        # the columns in ndarray\n",
    "        self.time = self.df['time'].values\n",
    "        self.total_incoming_green_energy = self.df['total_incoming_green_energy'].values\n",
    "        self.total_incoming_brown_energy = self.df['total_incoming_brown_energy'].values\n",
    "        self.total_incoming_load = self.df['total_incoming_load'].values\n",
    "        self.total_actual_load = self.df['total_actual_load'].values\n",
    "        self.green_energy_price = self.df['green_energy_price'].values\n",
    "        self.brown_energy_price = self.df['brown_energy_price'].values\n",
    "\n",
    "        #iterators\n",
    "        self.time_it = iter(self.time)\n",
    "        self.total_incoming_green_energy_it = iter(self.total_incoming_green_energy)\n",
    "        self.total_incoming_brown_energy_it = iter(self.total_incoming_brown_energy)\n",
    "        self.total_incoming_load_it = iter(self.total_incoming_load)\n",
    "        self.total_actual_load_it = iter(self.total_actual_load)\n",
    "        self.green_energy_price_it = iter(self.green_energy_price)\n",
    "        self.brown_energy_price_it = iter(self.brown_energy_price)\n",
    "        \n",
    "        # params\n",
    "        self.batch_size = 24\n",
    "\n",
    "    def lenth(self):\n",
    "        return len(self.df)\n",
    "    \n",
    "    def __len__(self):\n",
    "        return len(self.df)\n",
    "    \n",
    "    def days(self):\n",
    "        return len(self.df)/self.batch_size\n",
    "    \n",
    "    def load_batch(self, batch_size, it):\n",
    "        buffer = []\n",
    "        for _ in range(batch_size):\n",
    "            buffer.append(next(it))\n",
    "        return buffer\n",
    "\n",
    "    def evalute(self, days=None):\n",
    "        if not days:\n",
    "            days = self.days()\n",
    "        \n",
    "        for i in range(days):\n",
    "            print(f'################################:::DAY-{i+1}:::################################')\n",
    "            # green workload, Ygi\n",
    "            Ygi = self.load_batch(batch_size=self.batch_size, it=self.total_incoming_green_energy_it)\n",
    "            # brown workload, Ybi\n",
    "            Ybi = self.load_batch(batch_size=self.batch_size, it=self.total_incoming_brown_energy_it)\n",
    "            # actual load, L\n",
    "            L = self.load_batch(batch_size=self.batch_size, it=self.total_actual_load_it)\n",
    "\n",
    "            # per day savings\n",
    "            SAVE = 0\n",
    "            SAVE_G = 0\n",
    "            SAVE_B = 0\n",
    "            # total workload, Y (per day)\n",
    "            Y = 0\n",
    "            # for test\n",
    "            L_cum = 0\n",
    "            # per time slot\n",
    "            for i, (Lgi, Lbi, Li) in enumerate(zip(Ygi, Ybi, L)):\n",
    "                L_cum += Li\n",
    "                # per hour savings\n",
    "                save = 0\n",
    "                save_g = 0\n",
    "                save_b = 0\n",
    "                # per hour workload\n",
    "                yi = 0\n",
    "                if Lgi<Li:\n",
    "                    if Lbi>Li:\n",
    "                        yi += Li\n",
    "                        save_b += Lbi-Li\n",
    "                    else:\n",
    "                        yi += Lbi\n",
    "                else:\n",
    "                    if Lgi > Li:\n",
    "                        yi += Li\n",
    "                        save_g += Lgi-Li\n",
    "                    else:\n",
    "                        yi += Lgi\n",
    "                save = save_g + save_b\n",
    "                SAVE_G += save_g\n",
    "                SAVE_B += save_b\n",
    "                Y += yi\n",
    "                print(f'Hour {i+1}: Green Energy Saved: {save_g:.2f}, Brown Energy Saved:{save_b:.2f}')\n",
    "            SAVE += SAVE_G + SAVE_B\n",
    "            print('')\n",
    "            print(f'Total Day workload: {Y:.2f} , Total Energy Saved: {SAVE:.2f}')\n",
    "            print('')\n",
    "            print(f'Total Green Energy Saved: {SAVE_G:.2f} , Total Brown Energy Saved: {SAVE_B:.2f}')\n",
    "            print('')\n",
    "            if L_cum == Y:\n",
    "                print('Verdict: Fully Utilized!!!')\n",
    "            else:\n",
    "                print(f'Verdict: Deficiency!!!\\n\\t{L_cum-Y:.2f} energy deficit!')\n",
    "            \n",
    "            print('################################:::DAY-END:::################################')\n",
    "                \n",
    "                \n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {
    "datalore": {
     "hide_input_from_viewers": false,
     "hide_output_from_viewers": false,
     "node_id": "yYLFMqxPK0o6wJX89uPvT1",
     "type": "CODE"
    }
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "################################:::DAY-1:::################################\n",
      "Hour 1: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 2: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 3: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 4: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 5: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 6: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 7: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 8: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 9: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 10: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 11: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 12: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 13: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 14: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 15: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 16: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 17: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 18: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 19: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 20: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 21: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 22: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 23: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 24: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "\n",
      "Total Day workload: 150.08 , Total Energy Saved: 0.00\n",
      "\n",
      "Total Green Energy Saved: 0.00 , Total Brown Energy Saved: 0.00\n",
      "\n",
      "Verdict: Deficiency!!!\n",
      "\t250.05 energy deficit!\n",
      "################################:::DAY-END:::################################\n",
      "################################:::DAY-2:::################################\n",
      "Hour 1: Green Energy Saved: 0.24, Brown Energy Saved:0.00\n",
      "Hour 2: Green Energy Saved: 1.28, Brown Energy Saved:0.00\n",
      "Hour 3: Green Energy Saved: 2.25, Brown Energy Saved:0.00\n",
      "Hour 4: Green Energy Saved: 2.80, Brown Energy Saved:0.00\n",
      "Hour 5: Green Energy Saved: 2.79, Brown Energy Saved:0.00\n",
      "Hour 6: Green Energy Saved: 2.69, Brown Energy Saved:0.00\n",
      "Hour 7: Green Energy Saved: 2.66, Brown Energy Saved:0.00\n",
      "Hour 8: Green Energy Saved: 2.01, Brown Energy Saved:0.00\n",
      "Hour 9: Green Energy Saved: 1.30, Brown Energy Saved:0.00\n",
      "Hour 10: Green Energy Saved: 0.14, Brown Energy Saved:0.00\n",
      "Hour 11: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 12: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 13: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 14: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 15: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 16: Green Energy Saved: 0.77, Brown Energy Saved:0.00\n",
      "Hour 17: Green Energy Saved: 1.28, Brown Energy Saved:0.00\n",
      "Hour 18: Green Energy Saved: 0.61, Brown Energy Saved:0.00\n",
      "Hour 19: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 20: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 21: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 22: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 23: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "Hour 24: Green Energy Saved: 0.00, Brown Energy Saved:0.00\n",
      "\n",
      "Total Day workload: 267.27 , Total Energy Saved: 20.82\n",
      "\n",
      "Total Green Energy Saved: 20.82 , Total Brown Energy Saved: 0.00\n",
      "\n",
      "Verdict: Deficiency!!!\n",
      "\t189.02 energy deficit!\n",
      "################################:::DAY-END:::################################\n"
     ]
    }
   ],
   "source": [
    "# test \n",
    "import pandas as pd\n",
    "\n",
    "df = pd.read_csv('preprocessed.csv')\n",
    "\n",
    "# om\n",
    "b = Better(dataframe=df)\n",
    "# d = int(b.days())\n",
    "# b.evalute(d)\n",
    "b.evalute(2)"
   ]
  }
 ],
 "metadata": {
  "datalore": {
   "base_environment": "default",
   "computation_mode": "JUPYTER",
   "package_manager": "pip",
   "packages": [],
   "version": 1
  },
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.10.6"
  },
  "vscode": {
   "interpreter": {
    "hash": "736c99ac65ffe663dad8a098d261ce22f56c92b51794a29064362fc2c664560f"
   }
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}