golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.py
35 B
Del
OK
__pycache__
-
Del
OK
acme.py
12.74 KB
Del
OK
aix_group.py
4.12 KB
Del
OK
aix_shadow.py
1.93 KB
Del
OK
aixpkg.py
24.15 KB
Del
OK
aliases.py
5.07 KB
Del
OK
alternatives.py
5.71 KB
Del
OK
ansiblegate.py
19.51 KB
Del
OK
apache.py
12.47 KB
Del
OK
apcups.py
2.15 KB
Del
OK
apf.py
3.09 KB
Del
OK
apkpkg.py
16 KB
Del
OK
aptly.py
15.28 KB
Del
OK
aptpkg.py
116.64 KB
Del
OK
archive.py
48.63 KB
Del
OK
arista_pyeapi.py
22.06 KB
Del
OK
artifactory.py
24.78 KB
Del
OK
at.py
10.72 KB
Del
OK
at_solaris.py
8.51 KB
Del
OK
augeas_cfg.py
13.93 KB
Del
OK
aws_sqs.py
6.55 KB
Del
OK
azurearm_compute.py
20.8 KB
Del
OK
azurearm_dns.py
15.8 KB
Del
OK
azurearm_network.py
82.99 KB
Del
OK
azurearm_resource.py
35.75 KB
Del
OK
bamboohr.py
7.36 KB
Del
OK
baredoc.py
11.13 KB
Del
OK
bcache.py
28.97 KB
Del
OK
beacons.py
27.82 KB
Del
OK
bigip.py
69.11 KB
Del
OK
bluez_bluetooth.py
6.76 KB
Del
OK
boto3_elasticache.py
37.34 KB
Del
OK
boto3_elasticsearch.py
53.17 KB
Del
OK
boto3_route53.py
39.82 KB
Del
OK
boto3_sns.py
12.93 KB
Del
OK
boto_apigateway.py
61.86 KB
Del
OK
boto_asg.py
35.69 KB
Del
OK
boto_cfn.py
7.95 KB
Del
OK
boto_cloudfront.py
12.75 KB
Del
OK
boto_cloudtrail.py
14.45 KB
Del
OK
boto_cloudwatch.py
10.99 KB
Del
OK
boto_cloudwatch_event.py
9.48 KB
Del
OK
boto_cognitoidentity.py
14.63 KB
Del
OK
boto_datapipeline.py
6.94 KB
Del
OK
boto_dynamodb.py
14.98 KB
Del
OK
boto_ec2.py
79.27 KB
Del
OK
boto_efs.py
14.05 KB
Del
OK
boto_elasticache.py
23.69 KB
Del
OK
boto_elasticsearch_domain.py
15.85 KB
Del
OK
boto_elb.py
35.53 KB
Del
OK
boto_elbv2.py
10.78 KB
Del
OK
boto_iam.py
75.62 KB
Del
OK
boto_iot.py
26.2 KB
Del
OK
boto_kinesis.py
19.62 KB
Del
OK
boto_kms.py
17.29 KB
Del
OK
boto_lambda.py
35.05 KB
Del
OK
boto_rds.py
34.92 KB
Del
OK
boto_route53.py
32.55 KB
Del
OK
boto_s3.py
4.24 KB
Del
OK
boto_s3_bucket.py
31.8 KB
Del
OK
boto_secgroup.py
25.22 KB
Del
OK
boto_sns.py
7.22 KB
Del
OK
boto_sqs.py
6.43 KB
Del
OK
boto_ssm.py
3.63 KB
Del
OK
boto_vpc.py
113.08 KB
Del
OK
bower.py
5.85 KB
Del
OK
bridge.py
10.81 KB
Del
OK
bsd_shadow.py
6.25 KB
Del
OK
btrfs.py
33.66 KB
Del
OK
cabal.py
3.79 KB
Del
OK
capirca_acl.py
40.04 KB
Del
OK
cassandra_cql.py
54.16 KB
Del
OK
cassandra_mod.py
4.3 KB
Del
OK
celery.py
3.33 KB
Del
OK
ceph.py
15.82 KB
Del
OK
chassis.py
1.52 KB
Del
OK
chef.py
4.66 KB
Del
OK
chocolatey.py
41.55 KB
Del
OK
chronos.py
2.89 KB
Del
OK
chroot.py
11.73 KB
Del
OK
cimc.py
23.02 KB
Del
OK
ciscoconfparse_mod.py
14.79 KB
Del
OK
cisconso.py
3.83 KB
Del
OK
cloud.py
9.39 KB
Del
OK
cmdmod.py
163.73 KB
Del
OK
composer.py
10.31 KB
Del
OK
config.py
16.98 KB
Del
OK
consul.py
69.3 KB
Del
OK
container_resource.py
12.94 KB
Del
OK
cp.py
31.98 KB
Del
OK
cpan.py
5.54 KB
Del
OK
cron.py
28.09 KB
Del
OK
cryptdev.py
10.08 KB
Del
OK
csf.py
16.04 KB
Del
OK
cyg.py
8.32 KB
Del
OK
daemontools.py
5.41 KB
Del
OK
data.py
3.85 KB
Del
OK
datadog_api.py
7.76 KB
Del
OK
ddns.py
7.12 KB
Del
OK
deb_apache.py
7.41 KB
Del
OK
deb_postgres.py
4.18 KB
Del
OK
debconfmod.py
4.06 KB
Del
OK
debian_ip.py
64.91 KB
Del
OK
debian_service.py
6.55 KB
Del
OK
debuild_pkgbuild.py
34.68 KB
Del
OK
defaults.py
6.55 KB
Del
OK
devinfo.py
9.07 KB
Del
OK
devmap.py
627 B
Del
OK
dig.py
8.75 KB
Del
OK
disk.py
30.82 KB
Del
OK
djangomod.py
7.53 KB
Del
OK
dnsmasq.py
5.71 KB
Del
OK
dnsutil.py
11.51 KB
Del
OK
dockercompose.py
32.62 KB
Del
OK
dockermod.py
224.85 KB
Del
OK
dpkg_lowpkg.py
12.94 KB
Del
OK
drac.py
10.97 KB
Del
OK
dracr.py
38.53 KB
Del
OK
drbd.py
7.19 KB
Del
OK
dummyproxy_pkg.py
2.46 KB
Del
OK
dummyproxy_service.py
2.91 KB
Del
OK
ebuildpkg.py
38.74 KB
Del
OK
eix.py
1.58 KB
Del
OK
elasticsearch.py
51.44 KB
Del
OK
environ.py
8.96 KB
Del
OK
eselect.py
4.99 KB
Del
OK
esxcluster.py
1.66 KB
Del
OK
esxdatacenter.py
1.68 KB
Del
OK
esxi.py
2.79 KB
Del
OK
esxvm.py
1.63 KB
Del
OK
etcd_mod.py
8.56 KB
Del
OK
ethtool.py
11.12 KB
Del
OK
event.py
7.67 KB
Del
OK
extfs.py
8.78 KB
Del
OK
file.py
232.18 KB
Del
OK
firewalld.py
20.51 KB
Del
OK
freebsd_sysctl.py
4.99 KB
Del
OK
freebsd_update.py
6.19 KB
Del
OK
freebsdjail.py
7.16 KB
Del
OK
freebsdkmod.py
6.17 KB
Del
OK
freebsdpkg.py
17.04 KB
Del
OK
freebsdports.py
13.13 KB
Del
OK
freebsdservice.py
12.53 KB
Del
OK
freezer.py
10.2 KB
Del
OK
gcp_addon.py
4.07 KB
Del
OK
gem.py
10.6 KB
Del
OK
genesis.py
21.75 KB
Del
OK
gentoo_service.py
9.18 KB
Del
OK
gentoolkitmod.py
8.39 KB
Del
OK
git.py
172.01 KB
Del
OK
github.py
53.19 KB
Del
OK
glanceng.py
4.69 KB
Del
OK
glassfish.py
19.49 KB
Del
OK
glusterfs.py
19.55 KB
Del
OK
gnomedesktop.py
6.85 KB
Del
OK
google_chat.py
1.52 KB
Del
OK
gpg.py
39.09 KB
Del
OK
grafana4.py
30.27 KB
Del
OK
grains.py
21.81 KB
Del
OK
groupadd.py
11.87 KB
Del
OK
grub_legacy.py
3.08 KB
Del
OK
guestfs.py
2.37 KB
Del
OK
hadoop.py
3.76 KB
Del
OK
haproxyconn.py
10.17 KB
Del
OK
hashutil.py
6.77 KB
Del
OK
heat.py
25.25 KB
Del
OK
helm.py
39.27 KB
Del
OK
hg.py
7.16 KB
Del
OK
highstate_doc.py
22.76 KB
Del
OK
hosts.py
10.47 KB
Del
OK
http.py
3.76 KB
Del
OK
icinga2.py
4.46 KB
Del
OK
idem.py
1.75 KB
Del
OK
ifttt.py
2.28 KB
Del
OK
ilo.py
15.98 KB
Del
OK
incron.py
7.68 KB
Del
OK
influxdb08mod.py
15.07 KB
Del
OK
influxdbmod.py
16.13 KB
Del
OK
infoblox.py
17.53 KB
Del
OK
ini_manage.py
14.63 KB
Del
OK
inspectlib
-
Del
OK
inspector.py
8.19 KB
Del
OK
introspect.py
4.02 KB
Del
OK
iosconfig.py
14.78 KB
Del
OK
ipmi.py
25.47 KB
Del
OK
ipset.py
17.97 KB
Del
OK
iptables.py
57.44 KB
Del
OK
iwtools.py
3.99 KB
Del
OK
jboss7.py
20.51 KB
Del
OK
jboss7_cli.py
15.23 KB
Del
OK
jenkinsmod.py
11.9 KB
Del
OK
jinja.py
2.66 KB
Del
OK
jira_mod.py
7.07 KB
Del
OK
junos.py
73.96 KB
Del
OK
k8s.py
24.87 KB
Del
OK
kapacitor.py
5.37 KB
Del
OK
kerberos.py
5.42 KB
Del
OK
kernelpkg_linux_apt.py
6.71 KB
Del
OK
kernelpkg_linux_yum.py
7.26 KB
Del
OK
key.py
1007 B
Del
OK
keyboard.py
2.64 KB
Del
OK
keystone.py
43.14 KB
Del
OK
keystoneng.py
21.82 KB
Del
OK
keystore.py
7.18 KB
Del
OK
kmod.py
7.65 KB
Del
OK
kubeadm.py
34.64 KB
Del
OK
kubernetesmod.py
46.77 KB
Del
OK
launchctl_service.py
9.69 KB
Del
OK
layman.py
4.22 KB
Del
OK
ldap3.py
18.81 KB
Del
OK
ldapmod.py
5.9 KB
Del
OK
libcloud_compute.py
23.48 KB
Del
OK
libcloud_dns.py
9.73 KB
Del
OK
libcloud_loadbalancer.py
13.14 KB
Del
OK
libcloud_storage.py
12.16 KB
Del
OK
linux_acl.py
7.7 KB
Del
OK
linux_ip.py
5.55 KB
Del
OK
linux_lvm.py
17.86 KB
Del
OK
linux_service.py
4.64 KB
Del
OK
linux_shadow.py
12.96 KB
Del
OK
linux_sysctl.py
7.5 KB
Del
OK
localemod.py
11.84 KB
Del
OK
locate.py
2.58 KB
Del
OK
logadm.py
9.44 KB
Del
OK
logmod.py
1.25 KB
Del
OK
logrotate.py
7.72 KB
Del
OK
lvs.py
11.54 KB
Del
OK
lxc.py
147.27 KB
Del
OK
lxd.py
90.07 KB
Del
OK
mac_assistive.py
11.37 KB
Del
OK
mac_brew_pkg.py
19.91 KB
Del
OK
mac_desktop.py
2.77 KB
Del
OK
mac_group.py
6.62 KB
Del
OK
mac_keychain.py
6.39 KB
Del
OK
mac_pkgutil.py
2.84 KB
Del
OK
mac_portspkg.py
11.36 KB
Del
OK
mac_power.py
13.29 KB
Del
OK
mac_service.py
19.64 KB
Del
OK
mac_shadow.py
14.23 KB
Del
OK
mac_softwareupdate.py
14.52 KB
Del
OK
mac_sysctl.py
5.13 KB
Del
OK
mac_system.py
15.07 KB
Del
OK
mac_timezone.py
8.34 KB
Del
OK
mac_user.py
16.41 KB
Del
OK
mac_xattr.py
6.27 KB
Del
OK
macdefaults.py
2.33 KB
Del
OK
macpackage.py
6.66 KB
Del
OK
makeconf.py
17.31 KB
Del
OK
mandrill.py
6.31 KB
Del
OK
marathon.py
5.36 KB
Del
OK
match.py
13 KB
Del
OK
mattermost.py
3.4 KB
Del
OK
mdadm_raid.py
9.86 KB
Del
OK
mdata.py
3.38 KB
Del
OK
memcached.py
6.13 KB
Del
OK
mine.py
18.84 KB
Del
OK
minion.py
7.68 KB
Del
OK
mod_random.py
7.18 KB
Del
OK
modjk.py
12.48 KB
Del
OK
mongodb.py
29.75 KB
Del
OK
monit.py
5.51 KB
Del
OK
moosefs.py
3.87 KB
Del
OK
mount.py
58.44 KB
Del
OK
mssql.py
14.64 KB
Del
OK
msteams.py
2.11 KB
Del
OK
munin.py
2.4 KB
Del
OK
mysql.py
90.66 KB
Del
OK
nacl.py
9.72 KB
Del
OK
nagios.py
6.53 KB
Del
OK
nagios_rpc.py
5.09 KB
Del
OK
namecheap_domains.py
12.84 KB
Del
OK
namecheap_domains_dns.py
5.93 KB
Del
OK
namecheap_domains_ns.py
4.51 KB
Del
OK
namecheap_ssl.py
25.69 KB
Del
OK
namecheap_users.py
2.4 KB
Del
OK
napalm_bgp.py
9.72 KB
Del
OK
napalm_formula.py
11.33 KB
Del
OK
napalm_mod.py
61.37 KB
Del
OK
napalm_netacl.py
28.59 KB
Del
OK
napalm_network.py
93.22 KB
Del
OK
napalm_ntp.py
10.22 KB
Del
OK
napalm_probes.py
13.25 KB
Del
OK
napalm_route.py
5.09 KB
Del
OK
napalm_snmp.py
7.05 KB
Del
OK
napalm_users.py
6.49 KB
Del
OK
napalm_yang_mod.py
20.28 KB
Del
OK
netaddress.py
1.6 KB
Del
OK
netbox.py
32.22 KB
Del
OK
netbsd_sysctl.py
3.92 KB
Del
OK
netbsdservice.py
6.43 KB
Del
OK
netmiko_mod.py
19.61 KB
Del
OK
netscaler.py
27.02 KB
Del
OK
network.py
63.42 KB
Del
OK
neutron.py
44.92 KB
Del
OK
neutronng.py
15.02 KB
Del
OK
nexus.py
22.95 KB
Del
OK
nfs3.py
3.9 KB
Del
OK
nftables.py
33.58 KB
Del
OK
nginx.py
3.83 KB
Del
OK
nilrt_ip.py
36.18 KB
Del
OK
nix.py
8.03 KB
Del
OK
nova.py
19.6 KB
Del
OK
npm.py
10.4 KB
Del
OK
nspawn.py
41.35 KB
Del
OK
nxos.py
24.65 KB
Del
OK
nxos_api.py
14.72 KB
Del
OK
nxos_upgrade.py
14.74 KB
Del
OK
omapi.py
3.6 KB
Del
OK
openbsd_sysctl.py
3.74 KB
Del
OK
openbsdpkg.py
10.97 KB
Del
OK
openbsdrcctl_service.py
6.33 KB
Del
OK
openbsdservice.py
8.31 KB
Del
OK
openscap.py
2.81 KB
Del
OK
openstack_config.py
3.21 KB
Del
OK
openstack_mng.py
2.71 KB
Del
OK
openvswitch.py
17.19 KB
Del
OK
opkg.py
49.67 KB
Del
OK
opsgenie.py
3.29 KB
Del
OK
oracle.py
5.82 KB
Del
OK
osquery.py
24.93 KB
Del
OK
out.py
2.53 KB
Del
OK
pacmanpkg.py
31.92 KB
Del
OK
pagerduty.py
4.7 KB
Del
OK
pagerduty_util.py
13.48 KB
Del
OK
pam.py
2.01 KB
Del
OK
panos.py
61.05 KB
Del
OK
parallels.py
19.85 KB
Del
OK
parted_partition.py
21.53 KB
Del
OK
pcs.py
14.11 KB
Del
OK
pdbedit.py
10.79 KB
Del
OK
pecl.py
3.79 KB
Del
OK
peeringdb.py
8.39 KB
Del
OK
pf.py
9.51 KB
Del
OK
philips_hue.py
1.55 KB
Del
OK
pillar.py
21.37 KB
Del
OK
pip.py
53.42 KB
Del
OK
pkg_resource.py
12.3 KB
Del
OK
pkgin.py
17.29 KB
Del
OK
pkgng.py
61.07 KB
Del
OK
pkgutil.py
9.85 KB
Del
OK
portage_config.py
22.73 KB
Del
OK
postfix.py
16.24 KB
Del
OK
postgres.py
88.24 KB
Del
OK
poudriere.py
7.85 KB
Del
OK
powerpath.py
2.57 KB
Del
OK
proxy.py
11.49 KB
Del
OK
ps.py
20.89 KB
Del
OK
publish.py
10.25 KB
Del
OK
puppet.py
10.9 KB
Del
OK
purefa.py
33.59 KB
Del
OK
purefb.py
13.69 KB
Del
OK
pushbullet.py
1.88 KB
Del
OK
pushover_notify.py
3.48 KB
Del
OK
pw_group.py
4.62 KB
Del
OK
pw_user.py
12.47 KB
Del
OK
pyenv.py
6.93 KB
Del
OK
qemu_img.py
1.53 KB
Del
OK
qemu_nbd.py
3.28 KB
Del
OK
quota.py
6.43 KB
Del
OK
rabbitmq.py
38.4 KB
Del
OK
rallydev.py
6.09 KB
Del
OK
random_org.py
23.76 KB
Del
OK
rbac_solaris.py
16.05 KB
Del
OK
rbenv.py
10.75 KB
Del
OK
rdp.py
6.08 KB
Del
OK
rebootmgr.py
7.68 KB
Del
OK
redismod.py
16.36 KB
Del
OK
reg.py
16.36 KB
Del
OK
rest_pkg.py
2.26 KB
Del
OK
rest_sample_utils.py
558 B
Del
OK
rest_service.py
3.63 KB
Del
OK
restartcheck.py
24.1 KB
Del
OK
restconf.py
3.15 KB
Del
OK
ret.py
1.27 KB
Del
OK
rh_ip.py
38.55 KB
Del
OK
rh_service.py
16.61 KB
Del
OK
riak.py
5.19 KB
Del
OK
rpm_lowpkg.py
27.67 KB
Del
OK
rpmbuild_pkgbuild.py
24.53 KB
Del
OK
rsync.py
8.04 KB
Del
OK
runit.py
17.17 KB
Del
OK
rvm.py
11.1 KB
Del
OK
s3.py
9.93 KB
Del
OK
s6.py
3.62 KB
Del
OK
salt_proxy.py
4.48 KB
Del
OK
salt_version.py
4.58 KB
Del
OK
saltcheck.py
46.66 KB
Del
OK
saltcloudmod.py
954 B
Del
OK
saltutil.py
57.49 KB
Del
OK
schedule.py
50.81 KB
Del
OK
scp_mod.py
6.22 KB
Del
OK
scsi.py
2.66 KB
Del
OK
sdb.py
2.48 KB
Del
OK
seed.py
8.87 KB
Del
OK
selinux.py
24.2 KB
Del
OK
sensehat.py
7.79 KB
Del
OK
sensors.py
1.3 KB
Del
OK
serverdensity_device.py
8.1 KB
Del
OK
servicenow.py
4.36 KB
Del
OK
slack_notify.py
7.83 KB
Del
OK
slackware_service.py
6.84 KB
Del
OK
slsutil.py
19.04 KB
Del
OK
smartos_imgadm.py
12.04 KB
Del
OK
smartos_nictagadm.py
6.46 KB
Del
OK
smartos_virt.py
5.21 KB
Del
OK
smartos_vmadm.py
26.2 KB
Del
OK
smbios.py
10.05 KB
Del
OK
smf_service.py
8.52 KB
Del
OK
smtp.py
5.41 KB
Del
OK
snapper.py
27.14 KB
Del
OK
solaris_fmadm.py
11.2 KB
Del
OK
solaris_group.py
2.8 KB
Del
OK
solaris_shadow.py
7.98 KB
Del
OK
solaris_system.py
3.72 KB
Del
OK
solaris_user.py
11.06 KB
Del
OK
solarisipspkg.py
18.68 KB
Del
OK
solarispkg.py
15.4 KB
Del
OK
solr.py
45.54 KB
Del
OK
solrcloud.py
14.63 KB
Del
OK
splunk.py
8.14 KB
Del
OK
splunk_search.py
8.76 KB
Del
OK
sqlite3.py
2.54 KB
Del
OK
ssh.py
43.89 KB
Del
OK
ssh_pkg.py
1.08 KB
Del
OK
ssh_service.py
3.39 KB
Del
OK
state.py
82.34 KB
Del
OK
status.py
57.79 KB
Del
OK
statuspage.py
14.67 KB
Del
OK
supervisord.py
11.15 KB
Del
OK
suse_apache.py
2.45 KB
Del
OK
suse_ip.py
35.72 KB
Del
OK
svn.py
10.75 KB
Del
OK
swarm.py
13.5 KB
Del
OK
swift.py
5.53 KB
Del
OK
sysbench.py
6.62 KB
Del
OK
sysfs.py
6.61 KB
Del
OK
syslog_ng.py
31.52 KB
Del
OK
sysmod.py
22.59 KB
Del
OK
sysrc.py
3.38 KB
Del
OK
system.py
19.28 KB
Del
OK
system_profiler.py
3.54 KB
Del
OK
systemd_service.py
46.29 KB
Del
OK
telegram.py
3.28 KB
Del
OK
telemetry.py
12.87 KB
Del
OK
temp.py
831 B
Del
OK
test.py
15.4 KB
Del
OK
test_virtual.py
237 B
Del
OK
testinframod.py
9.92 KB
Del
OK
textfsm_mod.py
16.22 KB
Del
OK
timezone.py
19.98 KB
Del
OK
tls.py
58.63 KB
Del
OK
tomcat.py
18.59 KB
Del
OK
trafficserver.py
10.44 KB
Del
OK
transactional_update.py
35.83 KB
Del
OK
travisci.py
2.05 KB
Del
OK
tuned.py
2.34 KB
Del
OK
twilio_notify.py
2.95 KB
Del
OK
udev.py
3.72 KB
Del
OK
upstart_service.py
16.92 KB
Del
OK
uptime.py
3.23 KB
Del
OK
useradd.py
22.63 KB
Del
OK
uwsgi.py
996 B
Del
OK
vagrant.py
20.4 KB
Del
OK
varnish.py
3.08 KB
Del
OK
vault.py
15.61 KB
Del
OK
vbox_guest.py
10.55 KB
Del
OK
vboxmanage.py
14.71 KB
Del
OK
vcenter.py
1.61 KB
Del
OK
victorops.py
6.54 KB
Del
OK
virt.py
287.71 KB
Del
OK
virtualenv_mod.py
15.09 KB
Del
OK
vmctl.py
9.56 KB
Del
OK
vsphere.py
380.41 KB
Del
OK
webutil.py
3.66 KB
Del
OK
win_auditpol.py
4.74 KB
Del
OK
win_autoruns.py
2.29 KB
Del
OK
win_certutil.py
4.55 KB
Del
OK
win_dacl.py
32.27 KB
Del
OK
win_disk.py
1.8 KB
Del
OK
win_dism.py
20.7 KB
Del
OK
win_dns_client.py
4.19 KB
Del
OK
win_dsc.py
27.54 KB
Del
OK
win_event.py
22.32 KB
Del
OK
win_file.py
64.39 KB
Del
OK
win_firewall.py
20.15 KB
Del
OK
win_groupadd.py
11.27 KB
Del
OK
win_iis.py
68.78 KB
Del
OK
win_ip.py
11.43 KB
Del
OK
win_lgpo.py
491.76 KB
Del
OK
win_lgpo_reg.py
17.9 KB
Del
OK
win_license.py
2.72 KB
Del
OK
win_network.py
13.9 KB
Del
OK
win_ntp.py
1.8 KB
Del
OK
win_path.py
11.12 KB
Del
OK
win_pkg.py
86.43 KB
Del
OK
win_pki.py
15.8 KB
Del
OK
win_powercfg.py
9.85 KB
Del
OK
win_psget.py
8.97 KB
Del
OK
win_servermanager.py
14.21 KB
Del
OK
win_service.py
32.96 KB
Del
OK
win_shadow.py
3.03 KB
Del
OK
win_shortcut.py
16.49 KB
Del
OK
win_smtp_server.py
17.67 KB
Del
OK
win_snmp.py
13.38 KB
Del
OK
win_status.py
16.94 KB
Del
OK
win_system.py
40.61 KB
Del
OK
win_task.py
79.17 KB
Del
OK
win_timezone.py
13.3 KB
Del
OK
win_useradd.py
27.39 KB
Del
OK
win_wua.py
38.29 KB
Del
OK
win_wusa.py
5.88 KB
Del
OK
winrepo.py
6.09 KB
Del
OK
wordpress.py
4.71 KB
Del
OK
x509.py
63.1 KB
Del
OK
x509_v2.py
74.15 KB
Del
OK
xapi_virt.py
24.07 KB
Del
OK
xbpspkg.py
15.84 KB
Del
OK
xfs.py
15.35 KB
Del
OK
xml.py
2.14 KB
Del
OK
xmpp.py
5.28 KB
Del
OK
yaml.py
1.94 KB
Del
OK
yumpkg.py
116.5 KB
Del
OK
zabbix.py
97.55 KB
Del
OK
zcbuildout.py
28.16 KB
Del
OK
zenoss.py
5.64 KB
Del
OK
zfs.py
34.44 KB
Del
OK
zk_concurrency.py
11.16 KB
Del
OK
znc.py
2.26 KB
Del
OK
zoneadm.py
15.05 KB
Del
OK
zonecfg.py
21.85 KB
Del
OK
zookeeper.py
14.72 KB
Del
OK
zpool.py
44.02 KB
Del
OK
zypperpkg.py
94.87 KB
Del
OK
Edit: boto3_route53.py
""" Execution module for Amazon Route53 written against Boto 3 .. versionadded:: 2017.7.0 :configuration: This module accepts explicit route53 credentials but can also utilize IAM roles assigned to the instance through Instance Profiles. Dynamic credentials are then automatically obtained from AWS API and no further configuration is necessary. More Information available at: .. code-block:: yaml http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/iam-roles-for-amazon-ec2.html If IAM roles are not used you need to specify them either in a pillar or in the minion's config file: .. code-block:: yaml route53.keyid: GKTADJGHEIQSXMKKRBJ08H route53.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml route53.region: us-east-1 It's also possible to specify key, keyid and region via a profile, either as a passed in dict, or as a string to pull from pillars or minion config: .. code-block:: yaml myprofile: keyid: GKTADJGHEIQSXMKKRBJ08H key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs region: us-east-1 Note that Route53 essentially ignores all (valid) settings for 'region', since there is only one Endpoint (in us-east-1 if you care) and any (valid) region setting will just send you there. It is entirely safe to set it to None as well. :depends: boto3 """ # keep lint from choking on _get_conn and _cache_id # pylint: disable=E0602,W0106 import logging import re import time import salt.utils.compat import salt.utils.versions from salt.exceptions import CommandExecutionError, SaltInvocationError log = logging.getLogger(__name__) try: # pylint: disable=unused-import import boto3 # pylint: enable=unused-import from botocore.exceptions import ClientError logging.getLogger("boto3").setLevel(logging.CRITICAL) HAS_BOTO3 = True except ImportError: HAS_BOTO3 = False def __virtual__(): """ Only load if boto libraries exist and if boto libraries are greater than a given version. """ return salt.utils.versions.check_boto_reqs() def __init__(opts): if HAS_BOTO3: __utils__["boto3.assign_funcs"](__name__, "route53") def _collect_results(func, item, args, marker="Marker", nextmarker="NextMarker"): ret = [] Marker = args.get(marker, "") tries = 10 while Marker is not None: try: r = func(**args) except ClientError as e: if tries and e.response.get("Error", {}).get("Code") == "Throttling": # Rate limited - retry log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error("Could not collect results from %s(): %s", func, e) return [] i = r.get(item, []) if item else r i.pop("ResponseMetadata", None) if isinstance(i, dict) else None ret += i if isinstance(i, list) else [i] Marker = r.get(nextmarker) args.update({marker: Marker}) return ret def _wait_for_sync(change, conn, tries=10, sleep=20): for retry in range(1, tries + 1): log.info("Getting route53 status (attempt %s)", retry) status = "wait" try: status = conn.get_change(Id=change)["ChangeInfo"]["Status"] except ClientError as e: if e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") else: raise if status == "INSYNC": return True time.sleep(sleep) log.error("Timed out waiting for Route53 INSYNC status.") return False def find_hosted_zone( Id=None, Name=None, PrivateZone=None, region=None, key=None, keyid=None, profile=None, ): """ Find a hosted zone with the given characteristics. Id The unique Zone Identifier for the Hosted Zone. Exclusive with Name. Name The domain name associated with the Hosted Zone. Exclusive with Id. Note this has the potential to match more then one hosted zone (e.g. a public and a private if both exist) which will raise an error unless PrivateZone has also been passed in order split the different. PrivateZone Boolean - Set to True if searching for a private hosted zone. region Region to connect to. key Secret key to be used. keyid Access key to be used. profile Dict, or pillar key pointing to a dict, containing AWS region/key/keyid. CLI Example: .. code-block:: bash salt myminion boto3_route53.find_hosted_zone Name=salt.org. \ profile='{"region": "us-east-1", "keyid": "A12345678AB", "key": "xblahblahblah"}' """ if not _exactly_one((Id, Name)): raise SaltInvocationError("Exactly one of either Id or Name is required.") if PrivateZone is not None and not isinstance(PrivateZone, bool): raise SaltInvocationError( "If set, PrivateZone must be a bool (e.g. True / False)." ) if Id: ret = get_hosted_zone(Id, region=region, key=key, keyid=keyid, profile=profile) else: ret = get_hosted_zones_by_domain( Name, region=region, key=key, keyid=keyid, profile=profile ) if PrivateZone is not None: ret = [ m for m in ret if m["HostedZone"]["Config"]["PrivateZone"] is PrivateZone ] if len(ret) > 1: log.error( "Request matched more than one Hosted Zone (%s). Refine your " "criteria and try again.", [z["HostedZone"]["Id"] for z in ret], ) ret = [] return ret def get_hosted_zone(Id, region=None, key=None, keyid=None, profile=None): """ Return detailed info about the given zone. Id The unique Zone Identifier for the Hosted Zone. region Region to connect to. key Secret key to be used. keyid Access key to be used. profile Dict, or pillar key pointing to a dict, containing AWS region/key/keyid. CLI Example: .. code-block:: bash salt myminion boto3_route53.get_hosted_zone Z1234567690 \ profile='{"region": "us-east-1", "keyid": "A12345678AB", "key": "xblahblahblah"}' """ conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) args = {"Id": Id} return _collect_results(conn.get_hosted_zone, None, args) def get_hosted_zones_by_domain(Name, region=None, key=None, keyid=None, profile=None): """ Find any zones with the given domain name and return detailed info about them. Note that this can return multiple Route53 zones, since a domain name can be used in both public and private zones. Name The domain name associated with the Hosted Zone(s). region Region to connect to. key Secret key to be used. keyid Access key to be used. profile Dict, or pillar key pointing to a dict, containing AWS region/key/keyid. CLI Example: .. code-block:: bash salt myminion boto3_route53.get_hosted_zones_by_domain salt.org. \ profile='{"region": "us-east-1", "keyid": "A12345678AB", "key": "xblahblahblah"}' """ conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) zones = [ z for z in _collect_results(conn.list_hosted_zones, "HostedZones", {}) if z["Name"] == _aws_encode(Name) ] ret = [] for z in zones: ret += get_hosted_zone( Id=z["Id"], region=region, key=key, keyid=keyid, profile=profile ) return ret def list_hosted_zones( DelegationSetId=None, region=None, key=None, keyid=None, profile=None ): """ Return detailed info about all zones in the bound account. DelegationSetId If you're using reusable delegation sets and you want to list all of the hosted zones that are associated with a reusable delegation set, specify the ID of that delegation set. region Region to connect to. key Secret key to be used. keyid Access key to be used. profile Dict, or pillar key pointing to a dict, containing AWS region/key/keyid. CLI Example: .. code-block:: bash salt myminion boto3_route53.describe_hosted_zones \ profile='{"region": "us-east-1", "keyid": "A12345678AB", "key": "xblahblahblah"}' """ conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) args = {"DelegationSetId": DelegationSetId} if DelegationSetId else {} return _collect_results(conn.list_hosted_zones, "HostedZones", args) def create_hosted_zone( Name, VPCId=None, VPCName=None, VPCRegion=None, CallerReference=None, Comment="", PrivateZone=False, DelegationSetId=None, region=None, key=None, keyid=None, profile=None, ): """ Create a new Route53 Hosted Zone. Returns a Python data structure with information about the newly created Hosted Zone. Name The name of the domain. This should be a fully-specified domain, and should terminate with a period. This is the name you have registered with your DNS registrar. It is also the name you will delegate from your registrar to the Amazon Route 53 delegation servers returned in response to this request. VPCId When creating a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCName. Ignored if passed for a non-private zone. VPCName When creating a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCId. Ignored if passed for a non-private zone. VPCRegion When creating a private hosted zone, the region of the associated VPC is required. If not provided, an effort will be made to determine it from VPCId or VPCName, if possible. If this fails, you'll need to provide an explicit value for this option. Ignored if passed for a non-private zone. CallerReference A unique string that identifies the request and that allows create_hosted_zone() calls to be retried without the risk of executing the operation twice. This is a required parameter when creating new Hosted Zones. Maximum length of 128. Comment Any comments you want to include about the hosted zone. PrivateZone Boolean - Set to True if creating a private hosted zone. DelegationSetId If you want to associate a reusable delegation set with this hosted zone, the ID that Amazon Route 53 assigned to the reusable delegation set when you created it. Note that XXX TODO create_delegation_set() is not yet implemented, so you'd need to manually create any delegation sets before utilizing this. region Region endpoint to connect to. key AWS key to bind with. keyid AWS keyid to bind with. profile Dict, or pillar key pointing to a dict, containing AWS region/key/keyid. CLI Example: .. code-block:: bash salt myminion boto3_route53.create_hosted_zone example.org. """ if not Name.endswith("."): raise SaltInvocationError( "Domain must be fully-qualified, complete with trailing period." ) Name = _aws_encode(Name) conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) deets = find_hosted_zone( Name=Name, PrivateZone=PrivateZone, region=region, key=key, keyid=keyid, profile=profile, ) if deets: log.info( "Route 53 hosted zone %s already exists. You may want to pass " "e.g. 'PrivateZone=True' or similar...", Name, ) return None args = { "Name": Name, "CallerReference": CallerReference, "HostedZoneConfig": {"Comment": Comment, "PrivateZone": PrivateZone}, } args.update({"DelegationSetId": DelegationSetId}) if DelegationSetId else None if PrivateZone: if not _exactly_one((VPCName, VPCId)): raise SaltInvocationError( "Either VPCName or VPCId is required when creating a private zone." ) vpcs = __salt__["boto_vpc.describe_vpcs"]( vpc_id=VPCId, name=VPCName, region=region, key=key, keyid=keyid, profile=profile, ).get("vpcs", []) if VPCRegion and vpcs: vpcs = [v for v in vpcs if v["region"] == VPCRegion] if not vpcs: log.error( "Private zone requested but no VPC matching given criteria found." ) return None if len(vpcs) > 1: log.error( "Private zone requested but multiple VPCs matching given " "criteria found: %s.", [v["id"] for v in vpcs], ) return None vpc = vpcs[0] if VPCName: VPCId = vpc["id"] if not VPCRegion: VPCRegion = vpc["region"] args.update({"VPC": {"VPCId": VPCId, "VPCRegion": VPCRegion}}) else: if any((VPCId, VPCName, VPCRegion)): log.info( "Options VPCId, VPCName, and VPCRegion are ignored when creating " "non-private zones." ) tries = 10 while tries: try: r = conn.create_hosted_zone(**args) r.pop("ResponseMetadata", None) if _wait_for_sync(r["ChangeInfo"]["Id"], conn): return [r] return [] except ClientError as e: if tries and e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error("Failed to create hosted zone %s: %s", Name, e) return [] return [] def update_hosted_zone_comment( Id=None, Name=None, Comment=None, PrivateZone=None, region=None, key=None, keyid=None, profile=None, ): """ Update the comment on an existing Route 53 hosted zone. Id The unique Zone Identifier for the Hosted Zone. Name The domain name associated with the Hosted Zone(s). Comment Any comments you want to include about the hosted zone. PrivateZone Boolean - Set to True if changing a private hosted zone. CLI Example: .. code-block:: bash salt myminion boto3_route53.update_hosted_zone_comment Name=example.org. \ Comment="This is an example comment for an example zone" """ if not _exactly_one((Id, Name)): raise SaltInvocationError("Exactly one of either Id or Name is required.") conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) if Name: args = { "Name": Name, "PrivateZone": PrivateZone, "region": region, "key": key, "keyid": keyid, "profile": profile, } zone = find_hosted_zone(**args) if not zone: log.error("Couldn't resolve domain name %s to a hosted zone ID.", Name) return [] Id = zone[0]["HostedZone"]["Id"] tries = 10 while tries: try: r = conn.update_hosted_zone_comment(Id=Id, Comment=Comment) r.pop("ResponseMetadata", None) return [r] except ClientError as e: if tries and e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error("Failed to update comment on hosted zone %s: %s", Name or Id, e) return [] def associate_vpc_with_hosted_zone( HostedZoneId=None, Name=None, VPCId=None, VPCName=None, VPCRegion=None, Comment=None, region=None, key=None, keyid=None, profile=None, ): """ Associates an Amazon VPC with a private hosted zone. To perform the association, the VPC and the private hosted zone must already exist. You can't convert a public hosted zone into a private hosted zone. If you want to associate a VPC from one AWS account with a zone from a another, the AWS account owning the hosted zone must first submit a CreateVPCAssociationAuthorization (using create_vpc_association_authorization() or by other means, such as the AWS console). With that done, the account owning the VPC can then call associate_vpc_with_hosted_zone() to create the association. Note that if both sides happen to be within the same account, associate_vpc_with_hosted_zone() is enough on its own, and there is no need for the CreateVPCAssociationAuthorization step. Also note that looking up hosted zones by name (e.g. using the Name parameter) only works within a single account - if you're associating a VPC to a zone in a different account, as outlined above, you unfortunately MUST use the HostedZoneId parameter exclusively. HostedZoneId The unique Zone Identifier for the Hosted Zone. Name The domain name associated with the Hosted Zone(s). VPCId When working with a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCName. VPCName When working with a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCId. VPCRegion When working with a private hosted zone, the region of the associated VPC is required. If not provided, an effort will be made to determine it from VPCId or VPCName, if possible. If this fails, you'll need to provide an explicit value for VPCRegion. Comment Any comments you want to include about the change being made. CLI Example: .. code-block:: bash salt myminion boto3_route53.associate_vpc_with_hosted_zone \ Name=example.org. VPCName=myVPC \ VPCRegion=us-east-1 Comment="Whoo-hoo! I added another VPC." """ if not _exactly_one((HostedZoneId, Name)): raise SaltInvocationError( "Exactly one of either HostedZoneId or Name is required." ) if not _exactly_one((VPCId, VPCName)): raise SaltInvocationError("Exactly one of either VPCId or VPCName is required.") if Name: # {'PrivateZone': True} because you can only associate VPCs with private hosted zones. args = { "Name": Name, "PrivateZone": True, "region": region, "key": key, "keyid": keyid, "profile": profile, } zone = find_hosted_zone(**args) if not zone: log.error( "Couldn't resolve domain name %s to a private hosted zone ID.", Name ) return False HostedZoneId = zone[0]["HostedZone"]["Id"] vpcs = __salt__["boto_vpc.describe_vpcs"]( vpc_id=VPCId, name=VPCName, region=region, key=key, keyid=keyid, profile=profile ).get("vpcs", []) if VPCRegion and vpcs: vpcs = [v for v in vpcs if v["region"] == VPCRegion] if not vpcs: log.error("No VPC matching the given criteria found.") return False if len(vpcs) > 1: log.error( "Multiple VPCs matching the given criteria found: %s.", ", ".join([v["id"] for v in vpcs]), ) return False vpc = vpcs[0] if VPCName: VPCId = vpc["id"] if not VPCRegion: VPCRegion = vpc["region"] args = { "HostedZoneId": HostedZoneId, "VPC": {"VPCId": VPCId, "VPCRegion": VPCRegion}, } args.update({"Comment": Comment}) if Comment is not None else None conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) tries = 10 while tries: try: r = conn.associate_vpc_with_hosted_zone(**args) return _wait_for_sync(r["ChangeInfo"]["Id"], conn) except ClientError as e: if e.response.get("Error", {}).get("Code") == "ConflictingDomainExists": log.debug("VPC Association already exists.") # return True since the current state is the desired one return True if tries and e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error( "Failed to associate VPC %s with hosted zone %s: %s", VPCName or VPCId, Name or HostedZoneId, e, ) return False def disassociate_vpc_from_hosted_zone( HostedZoneId=None, Name=None, VPCId=None, VPCName=None, VPCRegion=None, Comment=None, region=None, key=None, keyid=None, profile=None, ): """ Disassociates an Amazon VPC from a private hosted zone. You can't disassociate the last VPC from a private hosted zone. You also can't convert a private hosted zone into a public hosted zone. Note that looking up hosted zones by name (e.g. using the Name parameter) only works XXX FACTCHECK within a single AWS account - if you're disassociating a VPC in one account from a hosted zone in a different account you unfortunately MUST use the HostedZoneId parameter exclusively. XXX FIXME DOCU HostedZoneId The unique Zone Identifier for the Hosted Zone. Name The domain name associated with the Hosted Zone(s). VPCId When working with a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCName. VPCName When working with a private hosted zone, either the VPC ID or VPC Name to associate with is required. Exclusive with VPCId. VPCRegion When working with a private hosted zone, the region of the associated VPC is required. If not provided, an effort will be made to determine it from VPCId or VPCName, if possible. If this fails, you'll need to provide an explicit value for VPCRegion. Comment Any comments you want to include about the change being made. CLI Example: .. code-block:: bash salt myminion boto3_route53.disassociate_vpc_from_hosted_zone \ Name=example.org. VPCName=myVPC \ VPCRegion=us-east-1 Comment="Whoops! Don't wanna talk to this-here zone no more." """ if not _exactly_one((HostedZoneId, Name)): raise SaltInvocationError( "Exactly one of either HostedZoneId or Name is required." ) if not _exactly_one((VPCId, VPCName)): raise SaltInvocationError("Exactly one of either VPCId or VPCName is required.") if Name: # {'PrivateZone': True} because you can only associate VPCs with private hosted zones. args = { "Name": Name, "PrivateZone": True, "region": region, "key": key, "keyid": keyid, "profile": profile, } zone = find_hosted_zone(**args) if not zone: log.error( "Couldn't resolve domain name %s to a private hosted zone ID.", Name ) return False HostedZoneId = zone[0]["HostedZone"]["Id"] vpcs = __salt__["boto_vpc.describe_vpcs"]( vpc_id=VPCId, name=VPCName, region=region, key=key, keyid=keyid, profile=profile ).get("vpcs", []) if VPCRegion and vpcs: vpcs = [v for v in vpcs if v["region"] == VPCRegion] if not vpcs: log.error("No VPC matching the given criteria found.") return False if len(vpcs) > 1: log.error( "Multiple VPCs matching the given criteria found: %s.", ", ".join([v["id"] for v in vpcs]), ) return False vpc = vpcs[0] if VPCName: VPCId = vpc["id"] if not VPCRegion: VPCRegion = vpc["region"] args = { "HostedZoneId": HostedZoneId, "VPC": {"VPCId": VPCId, "VPCRegion": VPCRegion}, } args.update({"Comment": Comment}) if Comment is not None else None conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) tries = 10 while tries: try: r = conn.disassociate_vpc_from_hosted_zone(**args) return _wait_for_sync(r["ChangeInfo"]["Id"], conn) except ClientError as e: if e.response.get("Error", {}).get("Code") == "VPCAssociationNotFound": log.debug("No VPC Association exists.") # return True since the current state is the desired one return True if tries and e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error( "Failed to associate VPC %s with hosted zone %s: %s", VPCName or VPCId, Name or HostedZoneId, e, ) return False # def create_vpc_association_authorization(*args, **kwargs): # ''' # unimplemented # ''' # pass # def delete_vpc_association_authorization(*args, **kwargs): # ''' # unimplemented # ''' # pass # def list_vpc_association_authorizations(*args, **kwargs): # ''' # unimplemented # ''' # pass def delete_hosted_zone(Id, region=None, key=None, keyid=None, profile=None): """ Delete a Route53 hosted zone. CLI Example: .. code-block:: bash salt myminion boto3_route53.delete_hosted_zone Z1234567890 """ conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) try: r = conn.delete_hosted_zone(Id=Id) return _wait_for_sync(r["ChangeInfo"]["Id"], conn) except ClientError as e: log.error("Failed to delete hosted zone %s: %s", Id, e) return False def delete_hosted_zone_by_domain( Name, PrivateZone=None, region=None, key=None, keyid=None, profile=None ): """ Delete a Route53 hosted zone by domain name, and PrivateZone status if provided. CLI Example: .. code-block:: bash salt myminion boto3_route53.delete_hosted_zone_by_domain example.org. """ args = { "Name": Name, "PrivateZone": PrivateZone, "region": region, "key": key, "keyid": keyid, "profile": profile, } # Be extra pedantic in the service of safety - if public/private is not provided and the domain # name resolves to both, fail and require them to declare it explicitly. zone = find_hosted_zone(**args) if not zone: log.error("Couldn't resolve domain name %s to a hosted zone ID.", Name) return False Id = zone[0]["HostedZone"]["Id"] return delete_hosted_zone( Id=Id, region=region, key=key, keyid=keyid, profile=profile ) def _aws_encode(x): """ An implementation of the encoding required to support AWS's domain name rules defined here__: .. __: http://docs.aws.amazon.com/Route53/latest/DeveloperGuide/DomainNameFormat.html While AWS's documentation specifies individual ASCII characters which need to be encoded, we instead just try to force the string to one of escaped unicode or idna depending on whether there are non-ASCII characters present. This means that we support things like ドメイン.テスト as a domain name string. More information about IDNA encoding in python is found here__: .. __: https://pypi.org/project/idna """ ret = None try: x.encode("ascii") ret = re.sub(rb"\\x([a-f0-8]{2})", _hexReplace, x.encode("unicode_escape")) except UnicodeEncodeError: ret = x.encode("idna") except Exception as e: # pylint: disable=broad-except log.error( "Couldn't encode %s using either 'unicode_escape' or 'idna' codecs", x ) raise CommandExecutionError(e) log.debug("AWS-encoded result for %s: %s", x, ret) return ret.decode("utf-8") def _aws_encode_changebatch(o): """ helper method to process a change batch & encode the bits which need encoding. """ change_idx = 0 while change_idx < len(o["Changes"]): o["Changes"][change_idx]["ResourceRecordSet"]["Name"] = _aws_encode( o["Changes"][change_idx]["ResourceRecordSet"]["Name"] ) if "ResourceRecords" in o["Changes"][change_idx]["ResourceRecordSet"]: rr_idx = 0 while rr_idx < len( o["Changes"][change_idx]["ResourceRecordSet"]["ResourceRecords"] ): o["Changes"][change_idx]["ResourceRecordSet"]["ResourceRecords"][ rr_idx ]["Value"] = _aws_encode( o["Changes"][change_idx]["ResourceRecordSet"]["ResourceRecords"][ rr_idx ]["Value"] ) rr_idx += 1 if "AliasTarget" in o["Changes"][change_idx]["ResourceRecordSet"]: o["Changes"][change_idx]["ResourceRecordSet"]["AliasTarget"][ "DNSName" ] = _aws_encode( o["Changes"][change_idx]["ResourceRecordSet"]["AliasTarget"]["DNSName"] ) change_idx += 1 return o def _aws_decode(x): """ An implementation of the decoding required to support AWS's domain name rules defined here__: .. __: http://docs.aws.amazon.com/Route53/latest/DeveloperGuide/DomainNameFormat.html The important part is this: If the domain name includes any characters other than a to z, 0 to 9, - (hyphen), or _ (underscore), Route 53 API actions return the characters as escape codes. This is true whether you specify the characters as characters or as escape codes when you create the entity. The Route 53 console displays the characters as characters, not as escape codes." For a list of ASCII characters the corresponding octal codes, do an internet search on "ascii table". We look for the existence of any escape codes which give us a clue that we're received an escaped unicode string; or we assume it's idna encoded and then decode as necessary. """ if "\\" in x: return x.decode("unicode_escape") if type(x) == bytes: return x.decode("idna") return x def _hexReplace(x): """ Converts a hex code to a base 16 int then the octal of it, minus the leading zero. This is necessary because x.encode('unicode_escape') automatically assumes you want a hex string, which AWS will accept but doesn't result in what you really want unless it's an octal escape sequence """ c = int(x.group(1), 16) return "\\" + str(oct(c))[1:] def get_resource_records( HostedZoneId=None, Name=None, StartRecordName=None, StartRecordType=None, PrivateZone=None, region=None, key=None, keyid=None, profile=None, ): """ Get all resource records from a given zone matching the provided StartRecordName (if given) or all records in the zone (if not), optionally filtered by a specific StartRecordType. This will return any and all RRs matching, regardless of their special AWS flavors (weighted, geolocation, alias, etc.) so your code should be prepared for potentially large numbers of records back from this function - for example, if you've created a complex geolocation mapping with lots of entries all over the world providing the same server name to many different regional clients. If you want EXACTLY ONE record to operate on, you'll need to implement any logic required to pick the specific RR you care about from those returned. Note that if you pass in Name without providing a value for PrivateZone (either True or False), CommandExecutionError can be raised in the case of both public and private zones matching the domain. XXX FIXME DOCU CLI Example: .. code-block:: bash salt myminion boto3_route53.get_records test.example.org example.org A """ if not _exactly_one((HostedZoneId, Name)): raise SaltInvocationError( "Exactly one of either HostedZoneId or Name must be provided." ) if Name: args = { "Name": Name, "region": region, "key": key, "keyid": keyid, "profile": profile, } args.update({"PrivateZone": PrivateZone}) if PrivateZone is not None else None zone = find_hosted_zone(**args) if not zone: log.error("Couldn't resolve domain name %s to a hosted zone ID.", Name) return [] HostedZoneId = zone[0]["HostedZone"]["Id"] conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) ret = [] next_rr_name = StartRecordName next_rr_type = StartRecordType next_rr_id = None done = False while True: if done: return ret args = {"HostedZoneId": HostedZoneId} args.update( {"StartRecordName": _aws_encode(next_rr_name)} ) if next_rr_name else None # Grrr, can't specify type unless name is set... We'll do this via filtering later instead args.update( {"StartRecordType": next_rr_type} ) if next_rr_name and next_rr_type else None args.update({"StartRecordIdentifier": next_rr_id}) if next_rr_id else None try: r = conn.list_resource_record_sets(**args) rrs = r["ResourceRecordSets"] next_rr_name = r.get("NextRecordName") next_rr_type = r.get("NextRecordType") next_rr_id = r.get("NextRecordIdentifier") for rr in rrs: rr["Name"] = _aws_decode(rr["Name"]) # now iterate over the ResourceRecords and replace any encoded # value strings with the decoded versions if "ResourceRecords" in rr: x = 0 while x < len(rr["ResourceRecords"]): if "Value" in rr["ResourceRecords"][x]: rr["ResourceRecords"][x]["Value"] = _aws_decode( rr["ResourceRecords"][x]["Value"] ) x += 1 # or if we are an AliasTarget then decode the DNSName if "AliasTarget" in rr: rr["AliasTarget"]["DNSName"] = _aws_decode( rr["AliasTarget"]["DNSName"] ) if StartRecordName and rr["Name"] != StartRecordName: done = True break if StartRecordType and rr["Type"] != StartRecordType: if StartRecordName: done = True break else: # We're filtering by type alone, and there might be more later, so... continue ret += [rr] if not next_rr_name: done = True except ClientError as e: # Try forever on a simple thing like this... if e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) continue raise def change_resource_record_sets( HostedZoneId=None, Name=None, PrivateZone=None, ChangeBatch=None, region=None, key=None, keyid=None, profile=None, ): """ See the `AWS Route53 API docs`__ as well as the `Boto3 documentation`__ for all the details... .. __: https://docs.aws.amazon.com/Route53/latest/APIReference/API_ChangeResourceRecordSets.html .. __: http://boto3.readthedocs.io/en/latest/reference/services/route53.html#Route53.Client.change_resource_record_sets The syntax for a ChangeBatch parameter is as follows, but note that the permutations of allowed parameters and combinations thereof are quite varied, so perusal of the above linked docs is highly recommended for any non-trival configurations. .. code-block:: text { "Comment": "string", "Changes": [ { "Action": "CREATE"|"DELETE"|"UPSERT", "ResourceRecordSet": { "Name": "string", "Type": "SOA"|"A"|"TXT"|"NS"|"CNAME"|"MX"|"NAPTR"|"PTR"|"SRV"|"SPF"|"AAAA", "SetIdentifier": "string", "Weight": 123, "Region": "us-east-1"|"us-east-2"|"us-west-1"|"us-west-2"|"ca-central-1"|"eu-west-1"|"eu-west-2"|"eu-central-1"|"ap-southeast-1"|"ap-southeast-2"|"ap-northeast-1"|"ap-northeast-2"|"sa-east-1"|"cn-north-1"|"ap-south-1", "GeoLocation": { "ContinentCode": "string", "CountryCode": "string", "SubdivisionCode": "string" }, "Failover": "PRIMARY"|"SECONDARY", "TTL": 123, "ResourceRecords": [ { "Value": "string" }, ], "AliasTarget": { "HostedZoneId": "string", "DNSName": "string", "EvaluateTargetHealth": True|False }, "HealthCheckId": "string", "TrafficPolicyInstanceId": "string" } }, ] } CLI Example: .. code-block:: bash foo='{ "Name": "my-cname.example.org.", "TTL": 600, "Type": "CNAME", "ResourceRecords": [ { "Value": "my-host.example.org" } ] }' foo=`echo $foo` # Remove newlines salt myminion boto3_route53.change_resource_record_sets DomainName=example.org. \ keyid=A1234567890ABCDEF123 key=xblahblahblah \ ChangeBatch="{'Changes': [{'Action': 'UPSERT', 'ResourceRecordSet': $foo}]}" """ if not _exactly_one((HostedZoneId, Name)): raise SaltInvocationError( "Exactly one of either HostZoneId or Name must be provided." ) if Name: args = { "Name": Name, "region": region, "key": key, "keyid": keyid, "profile": profile, } args.update({"PrivateZone": PrivateZone}) if PrivateZone is not None else None zone = find_hosted_zone(**args) if not zone: log.error("Couldn't resolve domain name %s to a hosted zone ID.", Name) return [] HostedZoneId = zone[0]["HostedZone"]["Id"] args = { "HostedZoneId": HostedZoneId, "ChangeBatch": _aws_encode_changebatch(ChangeBatch), } conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile) tries = 20 # A bit more headroom while tries: try: r = conn.change_resource_record_sets(**args) return _wait_for_sync( r["ChangeInfo"]["Id"], conn, 30 ) # And a little extra time here except ClientError as e: if tries and e.response.get("Error", {}).get("Code") == "Throttling": log.debug("Throttled by AWS API.") time.sleep(3) tries -= 1 continue log.error( "Failed to apply requested changes to the hosted zone %s: %s", (Name or HostedZoneId), str(e), ) raise e return False
Save