inventory.py 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. #!/usr/bin/env python
  2. """
  3. This is an Ansible dynamic inventory for OpenStack.
  4. It requires your OpenStack credentials to be set in clouds.yaml or your shell
  5. environment.
  6. """
  7. from __future__ import print_function
  8. from collections import Mapping
  9. import json
  10. import shade
  11. def build_inventory():
  12. '''Build the dynamic inventory.'''
  13. cloud = shade.openstack_cloud()
  14. inventory = {}
  15. # TODO(shadower): filter the servers based on the `OPENSHIFT_CLUSTER`
  16. # environment variable.
  17. cluster_hosts = [
  18. server for server in cloud.list_servers()
  19. if 'metadata' in server and 'clusterid' in server.metadata]
  20. masters = [server.name for server in cluster_hosts
  21. if server.metadata['host-type'] == 'master']
  22. etcd = [server.name for server in cluster_hosts
  23. if server.metadata['host-type'] == 'etcd']
  24. if not etcd:
  25. etcd = masters
  26. infra_hosts = [server.name for server in cluster_hosts
  27. if server.metadata['host-type'] == 'node' and
  28. server.metadata['sub-host-type'] == 'infra']
  29. app = [server.name for server in cluster_hosts
  30. if server.metadata['host-type'] == 'node' and
  31. server.metadata['sub-host-type'] == 'app']
  32. nodes = list(set(masters + infra_hosts + app))
  33. dns = [server.name for server in cluster_hosts
  34. if server.metadata['host-type'] == 'dns']
  35. load_balancers = [server.name for server in cluster_hosts
  36. if server.metadata['host-type'] == 'lb']
  37. osev3 = list(set(nodes + etcd + load_balancers))
  38. inventory['cluster_hosts'] = {'hosts': [s.name for s in cluster_hosts]}
  39. inventory['OSEv3'] = {'hosts': osev3}
  40. inventory['masters'] = {'hosts': masters}
  41. inventory['etcd'] = {'hosts': etcd}
  42. inventory['nodes'] = {'hosts': nodes}
  43. inventory['infra_hosts'] = {'hosts': infra_hosts}
  44. inventory['app'] = {'hosts': app}
  45. inventory['dns'] = {'hosts': dns}
  46. inventory['lb'] = {'hosts': load_balancers}
  47. for server in cluster_hosts:
  48. if 'group' in server.metadata:
  49. group = server.metadata.group
  50. if group not in inventory:
  51. inventory[group] = {'hosts': []}
  52. inventory[group]['hosts'].append(server.name)
  53. inventory['_meta'] = {'hostvars': {}}
  54. for server in cluster_hosts:
  55. ssh_ip_address = server.public_v4 or server.private_v4
  56. hostvars = {
  57. 'ansible_host': ssh_ip_address
  58. }
  59. public_v4 = server.public_v4 or server.private_v4
  60. if public_v4:
  61. hostvars['public_v4'] = server.public_v4
  62. hostvars['openshift_public_ip'] = server.public_v4
  63. # TODO(shadower): what about multiple networks?
  64. if server.private_v4:
  65. hostvars['private_v4'] = server.private_v4
  66. # NOTE(shadower): Yes, we set both hostname and IP to the private
  67. # IP address for each node. OpenStack doesn't resolve nodes by
  68. # name at all, so using a hostname here would require an internal
  69. # DNS which would complicate the setup and potentially introduce
  70. # performance issues.
  71. hostvars['openshift_ip'] = server.private_v4
  72. hostvars['openshift_hostname'] = server.private_v4
  73. hostvars['openshift_public_hostname'] = server.name
  74. node_labels = server.metadata.get('node_labels')
  75. # NOTE(shadower): the node_labels value must be a dict not string
  76. if not isinstance(node_labels, Mapping):
  77. node_labels = json.loads(node_labels)
  78. if node_labels:
  79. hostvars['openshift_node_labels'] = node_labels
  80. inventory['_meta']['hostvars'][server.name] = hostvars
  81. return inventory
  82. if __name__ == '__main__':
  83. print(json.dumps(build_inventory(), indent=4, sort_keys=True))