diff options
Diffstat (limited to 'scripts')
| -rwxr-xr-x | scripts/designate_import.py | 138 | ||||
| -rw-r--r-- | scripts/designate_input_onap.yaml | 107 |
2 files changed, 245 insertions, 0 deletions
diff --git a/scripts/designate_import.py b/scripts/designate_import.py new file mode 100755 index 0000000..df09f50 --- /dev/null +++ b/scripts/designate_import.py @@ -0,0 +1,138 @@ +#!/usr/bin/env python +# ============LICENSE_START======================================================= +# org.onap.dcae +# ================================================================================ +# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. +# ================================================================================ +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# ============LICENSE_END========================================================= +# +# ECOMP is a trademark and service mark of AT&T Intellectual Property. + +import designateclient +from designateclient.v2 import client as designate_client +from designateclient import shell + +from keystoneauth1.identity import generic +from keystoneauth1 import session as keystone_session +import json +import socket +import sys +import yaml + +def find_entry_by_name(entry_list, entry_name): + for entry in entry_list: + if entry['name'] == entry_name: + return entry + return none + + + +def main(): + if len(sys.argv) != 6 and len(sys.argv) != 2: + print("Usgae: {} input_file [auth_url username password tenant]".format(sys.argv[0])) + exit(1) + if len(sys.argv) == 6: + print("Creating DNS records using record defs from {}, authurl {}, usernaem {}, tenant {}".format( + sys.argv[1], sys.argv[2], sys.argv[3], sys.argv[5])) + else: + print("Creating DNS records using record defs from {}, authurl {}, usernaem {}, tenant {}".format( + shell.env('OS_AUTH_URL'), shell.env('OS_USERNAME'), shell.env('OS_PASSWORD'), shell.env('OS_PROJECT_NAME'))) + + inputfilepath = sys.argv[1] + auth = "" + + if len(sys.argv) == 2: + auth = generic.Password( + auth_url=shell.env('OS_AUTH_URL'), + username=shell.env('OS_USERNAME'), + password=shell.env('OS_PASSWORD'), + project_name=shell.env('OS_PROJECT_NAME'), + project_domain_id='default', + user_domain_id='default') + else: + auth = generic.Password( + auth_url=sys.argv[2], + username=sys.argv[3], + password=sys.argv[4], + project_name=sys.argv[5], + project_domain_id='default', + user_domain_id='default') + + if not auth: + print("Fail to get authenticated from OpenStack") + exit(1) + + session = keystone_session.Session(auth=auth) + client = designate_client.Client(session=session) + + zone_name = 'simpledemo.onap.org' + zone_name_dot = zone_name + '.' + + zone_list = client.zones.list() + print("before: \n{}".format(json.dumps(zone_list, indent=4))) + + zone = find_entry_by_name(entry_list = zone_list, entry_name = zone_name_dot) + if zone: + print("exitsing zone: zone id {}".format(zone['id'])) + else: + zone = client.zones.create(zone_name_dot, email='lji@research.att.com') + print("newly created zone: zone id {}".format(zone['id'])) + + recordsets = client.recordsets.list(zone['id']) + # delete all exitsing A and CNAME records under the zone_name + for recordset in recordsets: + if not recordset['name'].endswith(zone_name_dot): + continue + print("Deleting recordset {}".format(recordset['name'])) + if recordset['type'] == 'A': + client.recordsets.delete(zone['id'], recordset['id']) + elif recordset['type'] == 'CNAME': + client.recordsets.delete(zone['id'], recordset['id']) + + + with open(inputfilepath, 'r') as inputfile: + records_to_add = yaml.load(inputfile) + for key, value in records_to_add.iteritems(): + if not key.endswith(zone_name): + continue + try: + socket.inet_aton(value) + # take zone name out (including the . before it) + key = key[:-(len(zone_name)+1)] + print("Creating DNS A record for: {} - {}".format(key, value)) + rs = client.recordsets.create(zone['id'], key, 'A', [value]) + except: + print() + + for key, value in records_to_add.iteritems(): + if not key.endswith(zone_name): + continue + try: + socket.inet_aton(value) + except: + # take zone name out (and the . before it) + key = key[:-(len(zone_name)+1)] + if not value.endswith('.'): + value = value + '.' + print("Creating DNS CNAME record for: {} - {}".format(key, value)) + rs = client.recordsets.create(zone['id'], key, 'CNAME', [value]) + + recordsets = client.recordsets.list(zone['id']) + print("before: \n{}".format(json.dumps(recordsets, indent=4))) + + +######################################## +if __name__ == "__main__": + main() + diff --git a/scripts/designate_input_onap.yaml b/scripts/designate_input_onap.yaml new file mode 100644 index 0000000..04f8a5b --- /dev/null +++ b/scripts/designate_input_onap.yaml @@ -0,0 +1,107 @@ +simpledemo.onap.org: {{ dns_floating_ip_addr }} + +vm1.aai.simpledemo.onap.org: {{ aai1_floating_ip_addr }} +c1.vm1.aai.simpledemo.onap.org: {{ aai1_floating_ip_adr }} +c2.vm1.aai.simpledemo.onap.org: {{ aai1_floating_ip_addr }} +c3.vm1.aai.simpledemo.onap.org: {{ aai1_floating_ip_addr }} + +vm2.aai.simpledemo.onap.org: {{ aai2_floating_ip_addr }} +c1.vm2.aai.simpledemo.onap.org: {{ aai2_floating_ip_addr }} +c2.vm2.aai.simpledemo.onap.org: {{ aai2_floating_ip_addr }} +c3.vm2.aai.simpledemo.onap.org: {{ aai2_floating_ip_addr }} + +vm1.appc.simpledemo.onap.org: {{ appc_floating_ip_addr }} +c1.vm1.appc.simpledemo.onap.org: {{ appc_floating_ip_addr }} +c2.vm1.appc.simpledemo.onap.org: {{ appc_floating_ip_addr }} + +vm1.sdc.simpledemo.onap.org: {{ sdc_floating_ip_addr }} +c1.vm1.sdc.simpledemo.onap.org: {{ sdc_floating_ip_addr }} +c2.vm1.sdc.simpledemo.onap.org: {{ sdc_floating_ip_addr }} +c3.vm1.sdc.simpledemo.onap.org: {{ sdc_floating_ip_addr }} +c4.vm1.sdc.simpledemo.onap.org: {{ sdc_floating_ip_addr }} + +vm1.dcae.simpledemo.onap.org: {{ dcae_floating_ip_addr }} +c1.vm1.dcae.simpledemo.onap.org: {{ dcae_floating_ip_addr }} +c2.vm1.dcae.simpledemo.onap.org: {{ dcae_floating_ip_addr }} +c3.vm1.dcae.simpledemo.onap.org: {{ dcae_floating_ip_addr }} + +vm1.mso.simpledemo.onap.org: {{ so_floating_ip_addr }} +c1.vm1.mso.simpledemo.onap.org: {{ so_floating_ip_addr }} +c1.vm1.mso.simpledemo.onap.org: {{ so_floating_ip_addr }} + +vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c1.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c2.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c3.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c4.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c5.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c6.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c7.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} +c8.vm1.policy.simpledemo.onap.org: {{ policy_floating_ip_addr }} + +vm1.sdnc.simpledemo.onap.org: {{ sdnc_floating_ip_addr }} +c1.vm1.sdnc.simpledemo.onap.org: {{ sdnc_floating_ip_addr }} +c2.vm1.sdnc.simpledemo.onap.org: {{ sdnc_floating_ip_addr }} +c3.vm1.sdnc.simpledemo.onap.org: {{ sdnc_floating_ip_addr }} +c4.vm1.sdnc.simpledemo.onap.org: {{ sdnc_floating_ip_addr }} + +vm1.vid.simpledemo.onap.org: {{ vid_floating_ip_addr }} +c1.vm1.vid.simpledemo.onap.org: {{ vid_floating_ip_addr }} +c2.vm1.vid.simpledemo.onap.org: {{ vid_floating_ip_addr }} + +vm1.portal.simpledemo.onap.org: {{ portal_floating_ip_addr }} +c1.vm1.portal.simpledemo.onap.org: {{ portal_floating_ip_addr }} +c2.vm1.portal.simpledemo.onap.org: {{ portal_floating_ip_addr }} + +vm1.robot.simpledemo.onap.org: {{ robot_floating_ip_addr }} +c1.vm1.robot.simpledemo.onap.org: {{ robot_floating_ip_addr }} +c2.vm1.robot.simpledemo.onap.org: {{ robot_floating_ip_addr }} + +vm1.clamp.simpledemo.onap.org: {{ clamp_floating_ip_addr }} +c1.vm1.clamp.simpledemo.onap.org: {{ clamp_floating_ip_addr }} +c2.vm1.clamp.simpledemo.onap.org: {{ clamp_floating_ip_addr }} + +vm1.mr.simpledemo.onap.org: {{ mr_floating_ip_addr }} + +vm1.openo.simpledemo.onap.org: {{ openo_floating_ip_addr }} + +collector.api.simpledemo.onap.org: {{ dcae_coll_floating_ip_addr }} + + +aai.api.simpledemo.onap.org: 'vm1.aai.simpledemo.onap.org' +aai.ui.simpledemo.onap.org: 'vm1.aai.simpledemo.onap.org' +aai.searchservice.simpledemo.onap.org: 'vm1.aai.simpledemo.onap.org' +aai.hbase.simpledemo.onap.org: 'vm2.aai.simpledemo.onap.org' +aai.gremlinserver.simpledemo.onap.org: 'vm2.aai.simpledemo.onap.org' +aai.elasticsearch.simpledemo.onap.org: 'vm2.aai.simpledemo.onap.org' + +appc.api.simpledemo.onap.org: 'vm1.appc.simpledemo.onap.org' + +sdc.api.simpledemo.onap.org: 'vm1.sdc.simpledemo.onap.org' + +dcae.api.simpledemo.onap.org: 'vm1.dcae.simpledemo.onap.org' + +mso.api.simpledemo.onap.org: 'vm1.mso.simpledemo.onap.org' + +policy.api.simpledemo.onap.org: 'vm1.policy.simpledemo.onap.org' + +sdnc.api.simpledemo.onap.org: 'vm1.sdnc.simpledemo.onap.org' + +vid.api.simpledemo.onap.org: 'vm1.vid.simpledemo.onap.org' + +portal.api.simpledemo.onap.org: 'vm1.portal.simpledemo.onap.org' + +ueb.api.simpledemo.onap.org: 'vm1.mr.simpledemo.onap.org' + +clamp.api.simpledemo.onap.org: 'vm1.clamp.simpledemo.onap.org' + +robot.api.simpledemo.onap.org: 'vm1.robot.simpledemo.onap.org' +sniro.api.simpledemo.onap.org: 'vm1.robot.simpledemo.onap.org' + +msb.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' +mvim.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' +vnfsdk.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' +vfc.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' +uui.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' +esr.api.simpledemo.onap.org: 'vm1.openo.simpledemo.onap.org' + |