mirror of
https://github.com/jupyterhub/the-littlest-jupyterhub.git
synced 2025-12-18 21:54:05 +08:00
Add tljh-config command
We do not want users to hand-edit YAML files. This has been a major source of bugs and confusion for users in z2jh. Doing so in a terminal text editor makes it even worse. This lets users type commands directly to modify config.yaml file rather than edit files directly. This makes it a lot less error prone and user friendly. Advanced users can still edit config.yaml manually. Fixes #38
This commit is contained in:
7
setup.py
7
setup.py
@@ -13,5 +13,10 @@ setup(
|
||||
install_requires=[
|
||||
'pyyaml==3.*',
|
||||
'ruamel.yaml==0.15.*'
|
||||
]
|
||||
],
|
||||
entry_points={
|
||||
'console_scripts': [
|
||||
'tljh-config = tljh.config:main'
|
||||
]
|
||||
}
|
||||
)
|
||||
|
||||
78
tests/test_config.py
Normal file
78
tests/test_config.py
Normal file
@@ -0,0 +1,78 @@
|
||||
"""
|
||||
Test configuration commandline tools
|
||||
"""
|
||||
from tljh import config
|
||||
from contextlib import redirect_stdout
|
||||
import io
|
||||
import tempfile
|
||||
|
||||
|
||||
def test_set_no_mutate():
|
||||
conf = {}
|
||||
|
||||
new_conf = config.set_item_in_config(conf, 'a.b', 'c')
|
||||
assert new_conf['a']['b'] == 'c'
|
||||
assert conf == {}
|
||||
|
||||
def test_set_one_level():
|
||||
conf = {}
|
||||
|
||||
new_conf = config.set_item_in_config(conf, 'a', 'b')
|
||||
assert new_conf['a'] == 'b'
|
||||
|
||||
def test_set_multi_level():
|
||||
conf = {}
|
||||
|
||||
new_conf = config.set_item_in_config(conf, 'a.b', 'c')
|
||||
new_conf = config.set_item_in_config(new_conf, 'a.d', 'e')
|
||||
new_conf = config.set_item_in_config(new_conf, 'f', 'g')
|
||||
assert new_conf == {
|
||||
'a': {'b': 'c', 'd': 'e'},
|
||||
'f': 'g'
|
||||
}
|
||||
|
||||
def test_set_overwrite():
|
||||
"""
|
||||
We can overwrite already existing config items.
|
||||
|
||||
This might be surprising destructive behavior to some :D
|
||||
"""
|
||||
conf = {
|
||||
'a': 'b'
|
||||
}
|
||||
|
||||
new_conf = config.set_item_in_config(conf, 'a', 'c')
|
||||
assert new_conf == {'a': 'c'}
|
||||
|
||||
new_conf = config.set_item_in_config(new_conf, 'a.b', 'd')
|
||||
assert new_conf == {'a': {'b': 'd'}}
|
||||
|
||||
new_conf = config.set_item_in_config(new_conf, 'a', 'hi')
|
||||
assert new_conf == {'a': 'hi'}
|
||||
|
||||
|
||||
def test_show_config():
|
||||
"""
|
||||
Test stdout output when showing config
|
||||
"""
|
||||
conf = """
|
||||
# Just some test YAML
|
||||
a:
|
||||
b:
|
||||
- h
|
||||
- 1
|
||||
""".strip()
|
||||
|
||||
|
||||
with tempfile.NamedTemporaryFile() as tmp:
|
||||
tmp.write(conf.encode())
|
||||
tmp.flush()
|
||||
|
||||
out = io.StringIO()
|
||||
with redirect_stdout(out):
|
||||
config.show_config(tmp.name)
|
||||
|
||||
assert out.getvalue().strip() == conf
|
||||
|
||||
|
||||
|
||||
150
tljh/config.py
Normal file
150
tljh/config.py
Normal file
@@ -0,0 +1,150 @@
|
||||
"""
|
||||
Commandline interface for setting config items in config.yaml.
|
||||
|
||||
Used as:
|
||||
|
||||
tljh-config set firstlevel.second_level something
|
||||
|
||||
tljh-config show
|
||||
|
||||
tljh-config show firstlevel
|
||||
|
||||
tljh-config show firstlevel.second_level
|
||||
"""
|
||||
import sys
|
||||
import argparse
|
||||
from ruamel.yaml import YAML
|
||||
from copy import deepcopy
|
||||
from tljh import systemd
|
||||
|
||||
|
||||
yaml = YAML(typ='rt')
|
||||
|
||||
|
||||
def set_item_in_config(config, property_path, value):
|
||||
"""
|
||||
Set key at property_path to value in config & return new config.
|
||||
|
||||
config is not mutated.
|
||||
|
||||
propert_path is a series of dot separated values. Any part of the path
|
||||
that does not exist is created.
|
||||
"""
|
||||
path_components = property_path.split('.')
|
||||
|
||||
# Mutate a copy of the config, not config itself
|
||||
cur_part = config_copy = deepcopy(config)
|
||||
for i in range(len(path_components)):
|
||||
cur_path = path_components[i]
|
||||
if i == len(path_components) - 1:
|
||||
# Final component
|
||||
cur_part[cur_path] = value
|
||||
else:
|
||||
# If we are asked to create new non-leaf nodes, we will always make them dicts
|
||||
# This means setting is *destructive* - will replace whatever is down there!
|
||||
if cur_path not in cur_part or not isinstance(cur_part[cur_path], dict):
|
||||
cur_part[cur_path] = {}
|
||||
cur_part = cur_part[cur_path]
|
||||
|
||||
return config_copy
|
||||
|
||||
|
||||
def show_config(config_path):
|
||||
"""
|
||||
Pretty print config from given config_path
|
||||
"""
|
||||
try:
|
||||
with open(config_path) as f:
|
||||
config = yaml.load(f)
|
||||
except FileNotFoundError:
|
||||
config = {}
|
||||
|
||||
yaml.dump(config, sys.stdout)
|
||||
|
||||
|
||||
def set_config_value(config_path, key_path, value):
|
||||
"""
|
||||
Set key at key_path in config_path to value
|
||||
"""
|
||||
# FIXME: Have a file lock here
|
||||
# FIXME: Validate schema here
|
||||
try:
|
||||
with open(config_path) as f:
|
||||
config = yaml.load(f)
|
||||
except FileNotFoundError:
|
||||
config = {}
|
||||
|
||||
config = set_item_in_config(config, key_path, value)
|
||||
|
||||
with open(config_path, 'w') as f:
|
||||
yaml.dump(config, f)
|
||||
|
||||
|
||||
|
||||
def reload_component(component):
|
||||
"""
|
||||
Reload a TLJH component.
|
||||
|
||||
component can be 'hub' or 'proxy'.
|
||||
"""
|
||||
if component == 'hub':
|
||||
systemd.restart_service('jupyterhub')
|
||||
# FIXME: Verify hub is back up?
|
||||
print('Hub reload with new configuration complete')
|
||||
elif component == 'proxy':
|
||||
systemd.restart_service('configurable-http-proxy')
|
||||
print('Proxy reload with new configuration complete')
|
||||
|
||||
|
||||
def main():
|
||||
argparser = argparse.ArgumentParser()
|
||||
argparser.add_argument(
|
||||
'--config-path',
|
||||
default='/opt/tljh/config.yaml',
|
||||
help='Path to TLJH config.yaml file'
|
||||
)
|
||||
subparsers = argparser.add_subparsers(dest='action')
|
||||
|
||||
show_parser = subparsers.add_parser(
|
||||
'show',
|
||||
help='Show current configuration'
|
||||
)
|
||||
|
||||
set_parser = subparsers.add_parser(
|
||||
'set',
|
||||
help='Set a configuration property'
|
||||
)
|
||||
set_parser.add_argument(
|
||||
'key_path',
|
||||
help='Dot separated path to configuration key to set'
|
||||
)
|
||||
set_parser.add_argument(
|
||||
'value',
|
||||
help='Value ot set the configuration key to'
|
||||
)
|
||||
|
||||
reload_parser = subparsers.add_parser(
|
||||
'reload',
|
||||
help='Reload a component to apply configuration change'
|
||||
)
|
||||
reload_parser.add_argument(
|
||||
'component',
|
||||
choices=('hub', 'proxy'),
|
||||
help='Which component to reload',
|
||||
default='hub',
|
||||
nargs='?'
|
||||
)
|
||||
|
||||
args = argparser.parse_args()
|
||||
|
||||
if args.action == 'show':
|
||||
show_config(args.config_path)
|
||||
elif args.action == 'set':
|
||||
set_config_value(args.config_path, args.key_path, args.value)
|
||||
elif args.action == 'reload':
|
||||
reload_config(args.component)
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user