4 from datetime import datetime
5 from django.db.models import F, Q
6 from planetstack.config import Config
7 from observer.openstacksyncstep import OpenStackSyncStep
8 from core.models.node import Node
9 from core.models.site import Site, Deployment
10 from util.logger import Logger, logging
12 logger = Logger(level=logging.INFO)
14 class SyncNodes(OpenStackSyncStep):
18 def fetch_pending(self, deleted):
19 # Nodes come from the back end
20 # You can't delete them
25 sites = Site.objects.all()
26 nodes = Node.objects.all()
27 node_hostnames = [node.name for node in nodes]
29 # fetch all nodes from each deployment
30 deployments = Deployment.objects.all()
32 for deployment in deployments:
34 driver = self.driver.admin_driver(deployment=deployment.name)
35 compute_nodes = driver.shell.nova.hypervisors.list()
37 logger.log_exc("Failed to get nodes from deployment %s" % str(deployment))
40 for compute_node in compute_nodes:
41 if compute_node.hypervisor_hostname not in node_hostnames:
42 # XX TODO:figure out how to correctly identify a node's site.
43 # XX pick a random site to add the node to for now
44 site_index = random.randint(0, len(sites))
45 node = Node(name=compute_node.hypervisor_hostname,
46 site=sites[site_index], deployment=deployment)
47 new_nodes.append(node)
52 def sync_record(self, node):