2012-04-30 23:27:57 +02:00
|
|
|
#!/usr/bin/env python
|
|
|
|
|
|
|
|
# (c) 2012, Stephen Fromm <sfromm@gmail.com>
|
|
|
|
#
|
|
|
|
# Ansible is free software: you can redistribute it and/or modify
|
|
|
|
# it under the terms of the GNU General Public License as published by
|
|
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
|
|
# (at your option) any later version.
|
|
|
|
#
|
|
|
|
# Ansible is distributed in the hope that it will be useful,
|
|
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
# GNU General Public License for more details.
|
|
|
|
#
|
|
|
|
# You should have received a copy of the GNU General Public License
|
|
|
|
# along with Ansible. If not, see <http://www.gnu.org/licenses/>.
|
2013-07-23 19:28:12 +02:00
|
|
|
#
|
2012-10-05 23:31:13 +02:00
|
|
|
# ansible-pull is a script that runs ansible in local mode
|
2013-07-23 19:28:12 +02:00
|
|
|
# after checking out a playbooks directory from source repo. There is an
|
2012-10-05 23:31:13 +02:00
|
|
|
# example playbook to bootstrap this script in the examples/ dir which
|
|
|
|
# installs ansible and sets it up to run on cron.
|
|
|
|
|
|
|
|
# usage:
|
|
|
|
# ansible-pull -d /var/lib/ansible \
|
|
|
|
# -U http://example.net/content.git [-C production] \
|
|
|
|
# [path/playbook.yml]
|
|
|
|
#
|
|
|
|
# the -d and -U arguments are required; the -C argument is optional.
|
|
|
|
#
|
|
|
|
# ansible-pull accepts an optional argument to specify a playbook
|
2013-07-23 19:28:12 +02:00
|
|
|
# location underneath the workdir and then searches the source repo
|
2012-10-05 23:31:13 +02:00
|
|
|
# for playbooks in the following order, stopping at the first match:
|
|
|
|
#
|
|
|
|
# 1. $workdir/path/playbook.yml, if specified
|
|
|
|
# 2. $workdir/$hostname.yml
|
|
|
|
# 3. $workdir/local.yml
|
|
|
|
#
|
2013-07-23 19:28:12 +02:00
|
|
|
# the source repo must contain at least one of these playbooks.
|
2012-04-30 23:27:57 +02:00
|
|
|
|
|
|
|
import os
|
2012-10-12 16:53:56 +02:00
|
|
|
import shutil
|
2012-05-02 18:48:15 +02:00
|
|
|
import subprocess
|
2012-04-30 23:27:57 +02:00
|
|
|
import sys
|
2012-10-05 23:31:13 +02:00
|
|
|
import datetime
|
2012-09-13 08:42:54 +02:00
|
|
|
import socket
|
2013-07-23 19:28:12 +02:00
|
|
|
from ansible import utils
|
2012-04-30 23:27:57 +02:00
|
|
|
|
2013-07-23 19:28:12 +02:00
|
|
|
DEFAULT_REPO_TYPE = 'git'
|
2012-04-30 23:27:57 +02:00
|
|
|
DEFAULT_PLAYBOOK = 'local.yml'
|
2013-06-30 23:20:58 +02:00
|
|
|
PLAYBOOK_ERRORS = {1: 'File does not exist',
|
|
|
|
2: 'File is not readable'}
|
|
|
|
|
2012-04-30 23:27:57 +02:00
|
|
|
|
2012-05-02 18:48:15 +02:00
|
|
|
def _run(cmd):
|
2012-10-12 16:35:21 +02:00
|
|
|
print >>sys.stderr, "Running: '%s'" % cmd
|
2012-05-02 18:48:15 +02:00
|
|
|
cmd = subprocess.Popen(cmd, shell=True,
|
|
|
|
stdout=subprocess.PIPE, stderr=subprocess.PIPE)
|
|
|
|
(out, err) = cmd.communicate()
|
|
|
|
print out
|
|
|
|
if cmd.returncode != 0:
|
2012-10-12 16:35:21 +02:00
|
|
|
print >>sys.stderr, err
|
2013-06-30 23:20:58 +02:00
|
|
|
return cmd.returncode, out
|
|
|
|
|
2012-05-02 18:48:15 +02:00
|
|
|
|
2012-10-12 16:35:21 +02:00
|
|
|
def try_playbook(path):
|
|
|
|
if not os.path.exists(path):
|
|
|
|
return 1
|
|
|
|
if not os.access(path, os.R_OK):
|
|
|
|
return 2
|
|
|
|
return 0
|
|
|
|
|
2013-06-30 23:20:58 +02:00
|
|
|
|
2012-10-12 16:35:21 +02:00
|
|
|
def select_playbook(path, args):
|
|
|
|
playbook = None
|
|
|
|
if len(args) > 0 and args[0] is not None:
|
|
|
|
playbook = "%s/%s" % (path, args[0])
|
|
|
|
rc = try_playbook(playbook)
|
|
|
|
if rc != 0:
|
|
|
|
print >>sys.stderr, "%s: %s" % (playbook, PLAYBOOK_ERRORS[rc])
|
|
|
|
return None
|
|
|
|
return playbook
|
|
|
|
else:
|
|
|
|
hostpb = "%s/%s.yml" % (path, socket.getfqdn())
|
|
|
|
localpb = "%s/%s" % (path, DEFAULT_PLAYBOOK)
|
|
|
|
errors = []
|
|
|
|
for pb in [hostpb, localpb]:
|
|
|
|
rc = try_playbook(pb)
|
|
|
|
if rc == 0:
|
|
|
|
playbook = pb
|
|
|
|
break
|
|
|
|
else:
|
|
|
|
errors.append("%s: %s" % (pb, PLAYBOOK_ERRORS[rc]))
|
|
|
|
if playbook is None:
|
|
|
|
print >>sys.stderr, "\n".join(errors)
|
|
|
|
return playbook
|
|
|
|
|
2013-06-30 23:20:58 +02:00
|
|
|
|
2012-04-30 23:27:57 +02:00
|
|
|
def main(args):
|
|
|
|
""" Set up and run a local playbook """
|
2012-10-12 16:35:21 +02:00
|
|
|
usage = "%prog [options] [playbook.yml]"
|
2013-07-23 19:28:12 +02:00
|
|
|
parser = utils.SortedOptParser(usage=usage)
|
2012-10-12 16:53:56 +02:00
|
|
|
parser.add_option('--purge', default=False, action='store_true',
|
2013-07-23 19:28:12 +02:00
|
|
|
help='purge checkout after playbook run')
|
2013-06-30 23:20:58 +02:00
|
|
|
parser.add_option('-o', '--only-if-changed', dest='ifchanged', default=False, action='store_true',
|
2013-07-01 01:31:37 +02:00
|
|
|
help='only run the playbook if the repository has been updated')
|
2013-09-03 22:39:19 +02:00
|
|
|
parser.add_option('-f', '--force', dest='force', default=False,
|
|
|
|
action='store_true',
|
|
|
|
help='run the playbook even if the repository could '
|
|
|
|
'not be updated')
|
2012-04-30 23:27:57 +02:00
|
|
|
parser.add_option('-d', '--directory', dest='dest', default=None,
|
2013-07-23 19:28:12 +02:00
|
|
|
help='directory to checkout repository to')
|
2012-10-05 23:31:13 +02:00
|
|
|
parser.add_option('-U', '--url', dest='url', default=None,
|
2013-07-23 19:28:12 +02:00
|
|
|
help='URL of the playbook repository')
|
2012-05-02 18:48:15 +02:00
|
|
|
parser.add_option('-C', '--checkout', dest='checkout',
|
2013-07-23 19:28:12 +02:00
|
|
|
help='branch/tag/commit to checkout. '
|
|
|
|
'Defaults to behavior of repository module.')
|
2013-05-21 07:25:01 +02:00
|
|
|
parser.add_option('-i', '--inventory-file', dest='inventory',
|
2013-06-27 03:57:31 +02:00
|
|
|
help="location of the inventory host file")
|
2013-07-23 19:28:12 +02:00
|
|
|
parser.add_option('-m', '--module-name', dest='module_name',
|
|
|
|
default=DEFAULT_REPO_TYPE,
|
|
|
|
help='Module name used to check out repository. '
|
|
|
|
'Default is %s.' % DEFAULT_REPO_TYPE)
|
2012-04-30 23:27:57 +02:00
|
|
|
options, args = parser.parse_args(args)
|
|
|
|
|
2012-10-05 23:31:13 +02:00
|
|
|
if not options.dest:
|
2012-10-12 16:35:21 +02:00
|
|
|
parser.error("Missing required directory argument")
|
|
|
|
return 1
|
2012-10-05 23:31:13 +02:00
|
|
|
|
2013-07-05 19:57:01 +02:00
|
|
|
options.dest = os.path.abspath(options.dest)
|
|
|
|
|
2012-10-05 23:31:13 +02:00
|
|
|
if not options.url:
|
2013-07-23 19:28:12 +02:00
|
|
|
parser.error("URL for repository not specified, use -h for help")
|
2012-10-12 16:35:21 +02:00
|
|
|
return 1
|
2012-10-05 23:31:13 +02:00
|
|
|
|
|
|
|
now = datetime.datetime.now()
|
2012-10-12 16:35:21 +02:00
|
|
|
print >>sys.stderr, now.strftime("Starting ansible-pull at %F %T")
|
2012-10-05 23:31:13 +02:00
|
|
|
|
2013-05-21 07:25:01 +02:00
|
|
|
inv_opts = 'localhost,'
|
2012-11-11 09:11:58 +01:00
|
|
|
limit_opts = 'localhost:%s:127.0.0.1' % socket.getfqdn()
|
2013-07-23 19:28:12 +02:00
|
|
|
base_opts = '-c local --limit "%s"' % limit_opts
|
|
|
|
repo_opts = "name=%s dest=%s" % (options.url, options.dest)
|
|
|
|
if options.checkout:
|
|
|
|
repo_opts += ' version=%s' % options.checkout
|
|
|
|
path = utils.plugins.module_finder.find_plugin(options.module_name)
|
|
|
|
if path is None:
|
|
|
|
sys.stderr.write("module '%s' not found.\n" % options.module_name)
|
|
|
|
return 1
|
|
|
|
cmd = 'ansible all -i "%s" %s -m %s -a "%s"' % (
|
|
|
|
inv_opts, base_opts, options.module_name, repo_opts
|
2013-05-21 07:25:01 +02:00
|
|
|
)
|
2013-06-30 23:20:58 +02:00
|
|
|
rc, out = _run(cmd)
|
2012-09-13 02:07:02 +02:00
|
|
|
if rc != 0:
|
2013-09-03 22:39:19 +02:00
|
|
|
if options.force:
|
|
|
|
print("Unable to update repository. Continuing with (forced) "
|
|
|
|
"run of playbook.")
|
|
|
|
else:
|
|
|
|
return rc
|
2013-06-30 23:20:58 +02:00
|
|
|
elif options.ifchanged and '"changed": true' not in out:
|
|
|
|
print "Repository has not changed, quitting."
|
|
|
|
return 0
|
2012-09-13 02:07:02 +02:00
|
|
|
|
2012-10-12 16:35:21 +02:00
|
|
|
playbook = select_playbook(options.dest, args)
|
|
|
|
|
|
|
|
if playbook is None:
|
|
|
|
print >>sys.stderr, "Could not find a playbook to run."
|
|
|
|
return 1
|
2012-10-05 23:31:13 +02:00
|
|
|
|
2013-07-23 19:28:12 +02:00
|
|
|
cmd = 'ansible-playbook %s %s' % (base_opts, playbook)
|
2013-05-21 07:25:01 +02:00
|
|
|
if options.inventory:
|
|
|
|
cmd += ' -i "%s"' % options.inventory
|
2012-04-30 23:27:57 +02:00
|
|
|
os.chdir(options.dest)
|
2013-06-30 23:20:58 +02:00
|
|
|
rc, out = _run(cmd)
|
2012-10-12 16:53:56 +02:00
|
|
|
|
|
|
|
if options.purge:
|
|
|
|
os.chdir('/')
|
|
|
|
try:
|
|
|
|
shutil.rmtree(options.dest)
|
|
|
|
except Exception, e:
|
|
|
|
print >>sys.stderr, "Failed to remove %s: %s" % (options.dest, str(e))
|
|
|
|
|
2012-05-02 18:48:15 +02:00
|
|
|
return rc
|
2012-04-30 23:27:57 +02:00
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
try:
|
|
|
|
sys.exit(main(sys.argv[1:]))
|
2012-05-02 18:48:15 +02:00
|
|
|
except KeyboardInterrupt, e:
|
|
|
|
print >>sys.stderr, "Exit on user request.\n"
|
2012-04-30 23:27:57 +02:00
|
|
|
sys.exit(1)
|