Mercurial > repos > shellac > guppy_basecaller
comparison env/bin/route53 @ 0:26e78fe6e8c4 draft
"planemo upload commit c699937486c35866861690329de38ec1a5d9f783"
author | shellac |
---|---|
date | Sat, 02 May 2020 07:14:21 -0400 |
parents | |
children |
comparison
equal
deleted
inserted
replaced
-1:000000000000 | 0:26e78fe6e8c4 |
---|---|
1 #!/Users/pldms/Development/Projects/2020/david-matthews-galaxy/guppy_basecaller/env/bin/python3 | |
2 # Author: Chris Moyer | |
3 # | |
4 # route53 is similar to sdbadmin for Route53, it's a simple | |
5 # console utility to perform the most frequent tasks with Route53 | |
6 # | |
7 # Example usage. Use route53 get after each command to see how the | |
8 # zone changes. | |
9 # | |
10 # Add a non-weighted record, change its value, then delete. Default TTL: | |
11 # | |
12 # route53 add_record ZPO9LGHZ43QB9 rr.example.com A 4.3.2.1 | |
13 # route53 change_record ZPO9LGHZ43QB9 rr.example.com A 9.8.7.6 | |
14 # route53 del_record ZPO9LGHZ43QB9 rr.example.com A 9.8.7.6 | |
15 # | |
16 # Add a weighted record with two different weights. Note that the TTL | |
17 # must be specified as route53 uses positional parameters rather than | |
18 # option flags: | |
19 # | |
20 # route53 add_record ZPO9LGHZ43QB9 wrr.example.com A 1.2.3.4 600 foo9 10 | |
21 # route53 add_record ZPO9LGHZ43QB9 wrr.example.com A 4.3.2.1 600 foo8 10 | |
22 # | |
23 # route53 change_record ZPO9LGHZ43QB9 wrr.example.com A 9.9.9.9 600 foo8 10 | |
24 # | |
25 # route53 del_record ZPO9LGHZ43QB9 wrr.example.com A 1.2.3.4 600 foo9 10 | |
26 # route53 del_record ZPO9LGHZ43QB9 wrr.example.com A 9.9.9.9 600 foo8 10 | |
27 # | |
28 # Add a non-weighted alias, change its value, then delete. Alaises inherit | |
29 # their TTLs from the backing ELB: | |
30 # | |
31 # route53 add_alias ZPO9LGHZ43QB9 alias.example.com A Z3DZXE0Q79N41H lb-1218761514.us-east-1.elb.amazonaws.com. | |
32 # route53 change_alias ZPO9LGHZ43QB9 alias.example.com. A Z3DZXE0Q79N41H lb2-1218761514.us-east-1.elb.amazonaws.com. | |
33 # route53 delete_alias ZPO9LGHZ43QB9 alias.example.com. A Z3DZXE0Q79N41H lb2-1218761514.us-east-1.elb.amazonaws.com. | |
34 | |
35 def _print_zone_info(zoneinfo): | |
36 print "="*80 | |
37 print "| ID: %s" % zoneinfo['Id'].split("/")[-1] | |
38 print "| Name: %s" % zoneinfo['Name'] | |
39 print "| Ref: %s" % zoneinfo['CallerReference'] | |
40 print "="*80 | |
41 print zoneinfo['Config'] | |
42 print | |
43 | |
44 | |
45 def create(conn, hostname, caller_reference=None, comment=''): | |
46 """Create a hosted zone, returning the nameservers""" | |
47 response = conn.create_hosted_zone(hostname, caller_reference, comment) | |
48 print "Pending, please add the following Name Servers:" | |
49 for ns in response.NameServers: | |
50 print "\t", ns | |
51 | |
52 def delete_zone(conn, hosted_zone_id): | |
53 """Delete a hosted zone by ID""" | |
54 response = conn.delete_hosted_zone(hosted_zone_id) | |
55 print response | |
56 | |
57 def ls(conn): | |
58 """List all hosted zones""" | |
59 response = conn.get_all_hosted_zones() | |
60 for zoneinfo in response['ListHostedZonesResponse']['HostedZones']: | |
61 _print_zone_info(zoneinfo) | |
62 | |
63 def get(conn, hosted_zone_id, type=None, name=None, maxitems=None): | |
64 """Get all the records for a single zone""" | |
65 response = conn.get_all_rrsets(hosted_zone_id, type, name, maxitems=maxitems) | |
66 # If a maximum number of items was set, we limit to that number | |
67 # by turning the response into an actual list (copying it) | |
68 # instead of allowing it to page | |
69 if maxitems: | |
70 response = response[:] | |
71 print '%-40s %-5s %-20s %s' % ("Name", "Type", "TTL", "Value(s)") | |
72 for record in response: | |
73 print '%-40s %-5s %-20s %s' % (record.name, record.type, record.ttl, record.to_print()) | |
74 | |
75 def _add_del(conn, hosted_zone_id, change, name, type, identifier, weight, values, ttl, comment): | |
76 from boto.route53.record import ResourceRecordSets | |
77 changes = ResourceRecordSets(conn, hosted_zone_id, comment) | |
78 change = changes.add_change(change, name, type, ttl, | |
79 identifier=identifier, weight=weight) | |
80 for value in values.split(','): | |
81 change.add_value(value) | |
82 print changes.commit() | |
83 | |
84 def _add_del_alias(conn, hosted_zone_id, change, name, type, identifier, weight, alias_hosted_zone_id, alias_dns_name, comment): | |
85 from boto.route53.record import ResourceRecordSets | |
86 changes = ResourceRecordSets(conn, hosted_zone_id, comment) | |
87 change = changes.add_change(change, name, type, | |
88 identifier=identifier, weight=weight) | |
89 change.set_alias(alias_hosted_zone_id, alias_dns_name) | |
90 print changes.commit() | |
91 | |
92 def add_record(conn, hosted_zone_id, name, type, values, ttl=600, | |
93 identifier=None, weight=None, comment=""): | |
94 """Add a new record to a zone. identifier and weight are optional.""" | |
95 _add_del(conn, hosted_zone_id, "CREATE", name, type, identifier, | |
96 weight, values, ttl, comment) | |
97 | |
98 def del_record(conn, hosted_zone_id, name, type, values, ttl=600, | |
99 identifier=None, weight=None, comment=""): | |
100 """Delete a record from a zone: name, type, ttl, identifier, and weight must match.""" | |
101 _add_del(conn, hosted_zone_id, "DELETE", name, type, identifier, | |
102 weight, values, ttl, comment) | |
103 | |
104 def add_alias(conn, hosted_zone_id, name, type, alias_hosted_zone_id, | |
105 alias_dns_name, identifier=None, weight=None, comment=""): | |
106 """Add a new alias to a zone. identifier and weight are optional.""" | |
107 _add_del_alias(conn, hosted_zone_id, "CREATE", name, type, identifier, | |
108 weight, alias_hosted_zone_id, alias_dns_name, comment) | |
109 | |
110 def del_alias(conn, hosted_zone_id, name, type, alias_hosted_zone_id, | |
111 alias_dns_name, identifier=None, weight=None, comment=""): | |
112 """Delete an alias from a zone: name, type, alias_hosted_zone_id, alias_dns_name, weight and identifier must match.""" | |
113 _add_del_alias(conn, hosted_zone_id, "DELETE", name, type, identifier, | |
114 weight, alias_hosted_zone_id, alias_dns_name, comment) | |
115 | |
116 def change_record(conn, hosted_zone_id, name, type, newvalues, ttl=600, | |
117 identifier=None, weight=None, comment=""): | |
118 """Delete and then add a record to a zone. identifier and weight are optional.""" | |
119 from boto.route53.record import ResourceRecordSets | |
120 changes = ResourceRecordSets(conn, hosted_zone_id, comment) | |
121 # Assume there are not more than 10 WRRs for a given (name, type) | |
122 responses = conn.get_all_rrsets(hosted_zone_id, type, name, maxitems=10) | |
123 for response in responses: | |
124 if response.name != name or response.type != type: | |
125 continue | |
126 if response.identifier != identifier or response.weight != weight: | |
127 continue | |
128 change1 = changes.add_change("DELETE", name, type, response.ttl, | |
129 identifier=response.identifier, | |
130 weight=response.weight) | |
131 for old_value in response.resource_records: | |
132 change1.add_value(old_value) | |
133 | |
134 change2 = changes.add_change("UPSERT", name, type, ttl, | |
135 identifier=identifier, weight=weight) | |
136 for new_value in newvalues.split(','): | |
137 change2.add_value(new_value) | |
138 print changes.commit() | |
139 | |
140 def change_alias(conn, hosted_zone_id, name, type, new_alias_hosted_zone_id, new_alias_dns_name, identifier=None, weight=None, comment=""): | |
141 """Delete and then add an alias to a zone. identifier and weight are optional.""" | |
142 from boto.route53.record import ResourceRecordSets | |
143 changes = ResourceRecordSets(conn, hosted_zone_id, comment) | |
144 # Assume there are not more than 10 WRRs for a given (name, type) | |
145 responses = conn.get_all_rrsets(hosted_zone_id, type, name, maxitems=10) | |
146 for response in responses: | |
147 if response.name != name or response.type != type: | |
148 continue | |
149 if response.identifier != identifier or response.weight != weight: | |
150 continue | |
151 change1 = changes.add_change("DELETE", name, type, | |
152 identifier=response.identifier, | |
153 weight=response.weight) | |
154 change1.set_alias(response.alias_hosted_zone_id, response.alias_dns_name) | |
155 change2 = changes.add_change("UPSERT", name, type, identifier=identifier, weight=weight) | |
156 change2.set_alias(new_alias_hosted_zone_id, new_alias_dns_name) | |
157 print changes.commit() | |
158 | |
159 def help(conn, fnc=None): | |
160 """Prints this help message""" | |
161 import inspect | |
162 self = sys.modules['__main__'] | |
163 if fnc: | |
164 try: | |
165 cmd = getattr(self, fnc) | |
166 except: | |
167 cmd = None | |
168 if not inspect.isfunction(cmd): | |
169 print "No function named: %s found" % fnc | |
170 sys.exit(2) | |
171 (args, varargs, varkw, defaults) = inspect.getargspec(cmd) | |
172 print cmd.__doc__ | |
173 print "Usage: %s %s" % (fnc, " ".join([ "[%s]" % a for a in args[1:]])) | |
174 else: | |
175 print "Usage: route53 [command]" | |
176 for cname in dir(self): | |
177 if not cname.startswith("_"): | |
178 cmd = getattr(self, cname) | |
179 if inspect.isfunction(cmd): | |
180 doc = cmd.__doc__ | |
181 print "\t%-20s %s" % (cname, doc) | |
182 sys.exit(1) | |
183 | |
184 | |
185 if __name__ == "__main__": | |
186 import boto | |
187 import sys | |
188 conn = boto.connect_route53() | |
189 self = sys.modules['__main__'] | |
190 if len(sys.argv) >= 2: | |
191 try: | |
192 cmd = getattr(self, sys.argv[1]) | |
193 except: | |
194 cmd = None | |
195 args = sys.argv[2:] | |
196 else: | |
197 cmd = help | |
198 args = [] | |
199 if not cmd: | |
200 cmd = help | |
201 try: | |
202 cmd(conn, *args) | |
203 except TypeError as e: | |
204 print e | |
205 help(conn, cmd.__name__) |