| import os |
| import base64 |
| from django.db.models import F, Q |
| from planetstack.config import Config |
| from observer.syncstep import SyncStep |
| from core.models.site import Site |
| from ec2_observer.awslib import * |
| |
| class SyncSites(SyncStep): |
| provides=[Site] |
| requested_interval=3600 |
| |
| def fetch_pending(self): |
| current_sites = Site.objects.all() |
| zones = aws_run('ec2 describe-availability-zones') |
| available_sites = [zone['ZoneName'] for zone in zones] |
| |
| new_site_names = list(set(available_sites) - set(zones)) |
| |
| new_sites = [] |
| for s in new_site_names: |
| site = Site(name=s, |
| login_base=s, |
| site_url="www.amazon.com", |
| enabled=True, |
| is_public=True, |
| abbreviated_name=s) |
| new_sites.append(site) |
| |
| return new_sites |
| |
| def sync_record(self, site): |
| site.save() |
| |