one: periodical update of statistics

cloud/context_processors.py

@@ -7,8 +7,7 @@ def process_debug(req):
     return {'DEBUG': DEBUG}
     return {'DEBUG': DEBUG}
 
 
 def process_stat(req):
 def process_stat(req):
-    # stat = cache.get('cloud_stat');
-    stat = json.loads(subprocess.check_output(['/opt/webadmin/cloud/miscellaneous/stat/stat_wrap.sh']))
+    stat = cache.get('cloud_stat')
     return {
     return {
         'STAT_DEBUG': STAT_DEBUG,
         'STAT_DEBUG': STAT_DEBUG,
         'cloud_stat': stat,
         'cloud_stat': stat,

cloud/settings.py

@@ -205,6 +205,14 @@ CELERY_ROUTES = {
     'one.tasks.SendMailTask': {'queue': 'local'},
     'one.tasks.SendMailTask': {'queue': 'local'},
 }
 }
 
 
+CACHES = {
+    'default': {
+        'BACKEND': 'django.core.cache.backends.memcached.MemcachedCache',
+        'LOCATION': '127.0.0.1:11211',
+    }
+}
+
+
 store_settings = {
 store_settings = {
     "basic_auth": "True",
     "basic_auth": "True",
     "verify_ssl": "False",
     "verify_ssl": "False",

miscellaneous/devenv/nextinit.sh

@@ -6,12 +6,13 @@ do
     sudo stop $i || true
     sudo stop $i || true
 done
 done
 
 
-sudo apt-get install rabbitmq-server gettext
+sudo apt-get install rabbitmq-server gettext memcached
 sudo rabbitmqctl delete_user guest || true
 sudo rabbitmqctl delete_user guest || true
 sudo rabbitmqctl add_user nyuszi teszt || true
 sudo rabbitmqctl add_user nyuszi teszt || true
 sudo rabbitmqctl add_vhost django || true
 sudo rabbitmqctl add_vhost django || true
 sudo rabbitmqctl set_permissions -p django nyuszi '.*' '.*' '.*' || true
 sudo rabbitmqctl set_permissions -p django nyuszi '.*' '.*' '.*' || true
 
 
+sudo pip install python-memcached
 
 
 sudo cp /opt/webadmin/cloud/miscellaneous/devenv/boot_url.py /opt/
 sudo cp /opt/webadmin/cloud/miscellaneous/devenv/boot_url.py /opt/
 
 

one/jobs/quarter_hourly/stat_update.py

+from one.models import *
+from django_extensions.management.jobs import QuarterHourlyJob
+from django.core.cache import cache
+import json
+
+class Job(QuarterHourlyJob):
+    help = "Update statistics from OpenNebula."
+
+    def execute(self):
+        stat = json.loads(subprocess.check_output(['/opt/webadmin/cloud/miscellaneous/stat/stat_wrap.sh']))
+        cache.set('cloud_stat', stat)
+