Use python import machinery for inventory code

Change Idb7780f55e4a1fd77dd76becbf67c1ccbf220db7 restructured the python
inventory generation code so that it would be possible to install it
with pip. This change removes (most) of the import path hacks and
switches to using a pip-installed version of osa_toolkit.

Of note, the path hacks are left in place for the dynamic_inventory.py
file for now, as that file is really more of an endpoint, but is tested.

Also, the bootstrap-ansible.sh script was modified to install the code;
this is unnecessary with the tox environments because the tox directive
'usedevelop=True' does that already. Production environments still need
this, though.

Finally, to maintain usability when called directly, the interpreter for
dynamic_inventory.py was updated from `/usr/bin/env` to
`/opt/ansible-runime/python`. This change ensures that in a full
deployment the user is using the exact same code paths whether Ansible
invokes the script, or it is called directly. This also means that using
the script locally on a development machine, it must be invoked as an
argument to Python, unless the ansible-runtime directory exists.

Change-Id: Iafa573b1b144f98528d5e0aceb3f36e9de2a22a2
This commit is contained in:
Nolan Brubaker 2017-07-06 16:32:05 -04:00
parent 7dcaa46753
commit ea6954f72f
13 changed files with 47 additions and 63 deletions

View File

@ -31,6 +31,9 @@ The command can also be run manually as follows:
This invocation is useful when testing changes to the dynamic inventory script. This invocation is useful when testing changes to the dynamic inventory script.
.. note:: When running the ``dynamic_inventory.py`` script on a local
development machine, use ``python dynamic_inventory.py`` instead.
Inputs Inputs
^^^^^^ ^^^^^^

View File

@ -21,10 +21,10 @@ import datetime
import json import json
import logging import logging
import os import os
from osa_toolkit import dictutils as du
import tarfile import tarfile
import yaml import yaml
import dictutils as du
logger = logging.getLogger('osa-inventory') logger = logging.getLogger('osa-inventory')

View File

@ -15,15 +15,15 @@
# #
# (c) 2014, Kevin Carter <kevin.carter@rackspace.com> # (c) 2014, Kevin Carter <kevin.carter@rackspace.com>
import ip
import json import json
import logging import logging
import netaddr import netaddr
from osa_toolkit import dictutils as du
from osa_toolkit import filesystem as filesys
from osa_toolkit import ip
import uuid import uuid
import warnings import warnings
import dictutils as du
import filesystem as filesys
logger = logging.getLogger('osa-inventory') logger = logging.getLogger('osa-inventory')

View File

@ -1,4 +1,4 @@
#!/usr/bin/env python #!/opt/ansible-runtime/bin/python
# Copyright 2014, Rackspace US, Inc. # Copyright 2014, Rackspace US, Inc.
# #
# Licensed under the Apache License, Version 2.0 (the "License"); # Licensed under the Apache License, Version 2.0 (the "License");
@ -19,11 +19,13 @@ import argparse
import os import os
import sys import sys
current_path = os.path.abspath(os.path.dirname(os.path.realpath(__file__))) try:
lib_path = os.path.join(current_path, '..', '..', 'osa_toolkit') from osa_toolkit import generate
sys.path.append(lib_path) except ImportError:
current_path = os.path.abspath(os.path.dirname(os.path.realpath(__file__)))
import generate lib_path = os.path.join(current_path, '..', '..', 'osa_toolkit')
sys.path.append(lib_path)
from osa_toolkit import generate
# Function kept in order to use relative pathing for the env.d directory # Function kept in order to use relative pathing for the env.d directory

View File

@ -0,0 +1,6 @@
---
other:
- The inventory generation code has been switched to use standard Python
packaging tools. For most, this should not be a visible change. However,
running the dynamic inventory script on a local development environment
should now be called via ``python dynamic_inventory.py``.

View File

@ -80,6 +80,7 @@ esac
PIP_OPTS="" PIP_OPTS=""
if [ -n "$HTTPS_PROXY" ]; then if [ -n "$HTTPS_PROXY" ]; then
PIP_OPTS="--proxy $HTTPS_PROXY" PIP_OPTS="--proxy $HTTPS_PROXY"
elif [ -n "$HTTP_PROXY" ]; then elif [ -n "$HTTP_PROXY" ]; then
PIP_OPTS="--proxy $HTTP_PROXY" PIP_OPTS="--proxy $HTTP_PROXY"
fi fi
@ -141,6 +142,9 @@ PIP_OPTS+=" --constraint ${UPPER_CONSTRAINTS_FILE}"
${PIP_COMMAND} install ${PIP_OPTS} -r requirements.txt ${ANSIBLE_PACKAGE} \ ${PIP_COMMAND} install ${PIP_OPTS} -r requirements.txt ${ANSIBLE_PACKAGE} \
|| ${PIP_COMMAND} install --isolated ${PIP_OPTS} -r requirements.txt ${ANSIBLE_PACKAGE} || ${PIP_COMMAND} install --isolated ${PIP_OPTS} -r requirements.txt ${ANSIBLE_PACKAGE}
# Install our osa_toolkit code from the current checkout
$PIP_COMMAND install -e .
# Ensure that Ansible binaries run from the venv # Ensure that Ansible binaries run from the venv
pushd /opt/ansible-runtime/bin pushd /opt/ansible-runtime/bin
for ansible_bin in $(ls -1 ansible*); do for ansible_bin in $(ls -1 ansible*); do

View File

@ -19,11 +19,7 @@ import argparse
import os import os
import sys import sys
cwd = os.path.abspath(os.path.dirname(__file__)) from osa_toolki import tools
import_path = os.path.join(cwd, '..', 'osa_toolkit')
sys.path.append(import_path)
import tools
def args(arg_list): def args(arg_list):
@ -58,6 +54,7 @@ def args(arg_list):
if __name__ == "__main__": if __name__ == "__main__":
script_args = args(sys.argv[1:]) script_args = args(sys.argv[1:])
config = tools.make_example_config( config = tools.make_example_config(
script_args['base'], script_args['base'],
script_args['conf_dir'] script_args['conf_dir']

View File

@ -23,14 +23,8 @@
# to manage.py in order to facilitate importing of the python code # to manage.py in order to facilitate importing of the python code
# This file remains for backwards compatibility # This file remains for backwards compatibility
import os
import sys
cwd = os.path.abspath(os.path.dirname(__file__)) from osa_toolkit import manage
import_path = os.path.join(cwd, '..', 'osa_toolkit')
sys.path.append(import_path)
import manage
if __name__ == "__main__": if __name__ == "__main__":
manage.main() manage.main()

View File

@ -12,16 +12,9 @@
# License for the specific language governing permissions and limitations # License for the specific language governing permissions and limitations
# under the License. # under the License.
import os
from os import path
import sys
import unittest import unittest
LIB_DIR = 'osa_toolkit' from osa_toolkit import dictutils as du
sys.path.append(path.join(os.getcwd(), LIB_DIR))
import dictutils as du
class TestMergeDictUnit(unittest.TestCase): class TestMergeDictUnit(unittest.TestCase):

View File

@ -24,12 +24,10 @@ from test_inventory import get_inventory
from test_inventory import make_config from test_inventory import make_config
INV_DIR = 'playbooks/inventory' INV_DIR = 'playbooks/inventory'
LIB_DIR = 'osa_toolkit'
sys.path.append(path.join(os.getcwd(), LIB_DIR))
sys.path.append(path.join(os.getcwd(), INV_DIR)) sys.path.append(path.join(os.getcwd(), INV_DIR))
import filesystem as fs from osa_toolkit import filesystem as fs
TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory') TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory')
USER_CONFIG_FILE = path.join(TARGET_DIR, 'openstack_user_config.yml') USER_CONFIG_FILE = path.join(TARGET_DIR, 'openstack_user_config.yml')
@ -50,14 +48,14 @@ class TestMultipleRuns(unittest.TestCase):
def test_creating_backup_file(self): def test_creating_backup_file(self):
inventory_file_path = os.path.join(TARGET_DIR, inventory_file_path = os.path.join(TARGET_DIR,
'openstack_inventory.json') 'openstack_inventory.json')
get_backup_name_path = 'filesystem._get_backup_name' get_backup_name_path = 'osa_toolkit.filesystem._get_backup_name'
backup_name = 'openstack_inventory.json-20160531_171804.json' backup_name = 'openstack_inventory.json-20160531_171804.json'
tar_file = mock.MagicMock() tar_file = mock.MagicMock()
tar_file.__enter__.return_value = tar_file tar_file.__enter__.return_value = tar_file
# run make backup with faked tarfiles and date # run make backup with faked tarfiles and date
with mock.patch('filesystem.tarfile.open') as tar_open: with mock.patch('osa_toolkit.filesystem.tarfile.open') as tar_open:
tar_open.return_value = tar_file tar_open.return_value = tar_file
with mock.patch(get_backup_name_path) as backup_mock: with mock.patch(get_backup_name_path) as backup_mock:
backup_mock.return_value = backup_name backup_mock.return_value = backup_name

View File

@ -26,16 +26,14 @@ import warnings
import yaml import yaml
INV_DIR = 'playbooks/inventory' INV_DIR = 'playbooks/inventory'
LIB_DIR = 'osa_toolkit'
sys.path.append(path.join(os.getcwd(), LIB_DIR))
sys.path.append(path.join(os.getcwd(), INV_DIR)) sys.path.append(path.join(os.getcwd(), INV_DIR))
import dictutils from osa_toolkit import dictutils
import dynamic_inventory import dynamic_inventory
import filesystem as fs from osa_toolkit import filesystem as fs
import generate as di from osa_toolkit import generate as di
import tools from osa_toolkit import tools
TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory') TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory')
BASE_ENV_DIR = INV_DIR BASE_ENV_DIR = INV_DIR
@ -483,8 +481,8 @@ class TestIps(unittest.TestCase):
self.longMessage = True self.longMessage = True
self.env = fs.load_environment(BASE_ENV_DIR, {}) self.env = fs.load_environment(BASE_ENV_DIR, {})
@mock.patch('filesystem.load_environment') @mock.patch('osa_toolkit.filesystem.load_environment')
@mock.patch('filesystem.load_user_configuration') @mock.patch('osa_toolkit.filesystem.load_user_configuration')
def test_duplicates(self, mock_load_config, mock_load_env): def test_duplicates(self, mock_load_config, mock_load_env):
"""Test that no duplicate IPs are made on any network.""" """Test that no duplicate IPs are made on any network."""
@ -1182,8 +1180,8 @@ class TestNetworkEntry(unittest.TestCase):
class TestDebugLogging(unittest.TestCase): class TestDebugLogging(unittest.TestCase):
@mock.patch('generate.logging') @mock.patch('osa_toolkit.generate.logging')
@mock.patch('generate.logger') @mock.patch('osa_toolkit.generate.logger')
def test_logging_enabled(self, mock_logger, mock_logging): def test_logging_enabled(self, mock_logger, mock_logging):
# Shadow the real value so tests don't complain about it # Shadow the real value so tests don't complain about it
mock_logging.DEBUG = 10 mock_logging.DEBUG = 10
@ -1194,8 +1192,8 @@ class TestDebugLogging(unittest.TestCase):
self.assertTrue(mock_logger.info.called) self.assertTrue(mock_logger.info.called)
self.assertTrue(mock_logger.debug.called) self.assertTrue(mock_logger.debug.called)
@mock.patch('generate.logging') @mock.patch('osa_toolkit.generate.logging')
@mock.patch('generate.logger') @mock.patch('osa_toolkit.generate.logger')
def test_logging_disabled(self, mock_logger, mock_logging): def test_logging_disabled(self, mock_logger, mock_logging):
get_inventory(extra_args={"debug": False}) get_inventory(extra_args={"debug": False})
@ -1239,7 +1237,7 @@ class TestLxcHosts(TestConfigCheckBase):
inventory['lxc_hosts']['hosts'].append('compute1') inventory['lxc_hosts']['hosts'].append('compute1')
faked_path = INV_DIR faked_path = INV_DIR
with mock.patch('filesystem.load_inventory') as inv_mock: with mock.patch('osa_toolkit.filesystem.load_inventory') as inv_mock:
inv_mock.return_value = (inventory, faked_path) inv_mock.return_value = (inventory, faked_path)
new_inventory = get_inventory() new_inventory = get_inventory()
# host should no longer be in lxc_hosts # host should no longer be in lxc_hosts
@ -1255,7 +1253,7 @@ class TestLxcHosts(TestConfigCheckBase):
self.assertNotIn('lxc_hosts', inventory.keys()) self.assertNotIn('lxc_hosts', inventory.keys())
faked_path = INV_DIR faked_path = INV_DIR
with mock.patch('filesystem.load_inventory') as inv_mock: with mock.patch('osa_toolkit.filesystem.load_inventory') as inv_mock:
inv_mock.return_value = (inventory, faked_path) inv_mock.return_value = (inventory, faked_path)
new_inventory = get_inventory() new_inventory = get_inventory()
@ -1372,7 +1370,7 @@ class TestInventoryGroupConstraints(unittest.TestCase):
'load_user_configuration': mock.DEFAULT 'load_user_configuration': mock.DEFAULT
} }
with mock.patch.multiple('filesystem', **kwargs) as mocks: with mock.patch.multiple('osa_toolkit.filesystem', **kwargs) as mocks:
mocks['load_environment'].return_value = env mocks['load_environment'].return_value = env
mocks['load_user_configuration'].return_value = config mocks['load_user_configuration'].return_value = config

View File

@ -12,16 +12,9 @@
# License for the specific language governing permissions and limitations # License for the specific language governing permissions and limitations
# under the License. # under the License.
import os
from os import path
import sys
import unittest import unittest
LIB_DIR = path.join(os.getcwd(), 'osa_toolkit') from osa_toolkit import ip
sys.path.append(LIB_DIR)
import ip
class TestIPManager(unittest.TestCase): class TestIPManager(unittest.TestCase):

View File

@ -14,16 +14,12 @@
import os import os
from os import path from os import path
import sys
import test_inventory import test_inventory
import unittest import unittest
MANAGE_DIR = path.join(os.getcwd(), 'osa_toolkit')
TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory') TARGET_DIR = path.join(os.getcwd(), 'tests', 'inventory')
sys.path.append(MANAGE_DIR) from osa_toolkit import manage as mi
import manage as mi
def setUpModule(): def setUpModule():