X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=modules%2Flibjuju%2Fexamples%2Funitrun.py;fp=modules%2Flibjuju%2Fexamples%2Funitrun.py;h=805f0ae0d3dc9144eb3f115c230fee813506f449;hp=0000000000000000000000000000000000000000;hb=e2051cca7dac12aa09f6ed33555dcc4548c4b52b;hpb=9d18c22a0dc9e295adda50601fc5e2f45d2c9b8a diff --git a/modules/libjuju/examples/unitrun.py b/modules/libjuju/examples/unitrun.py new file mode 100644 index 0000000..805f0ae --- /dev/null +++ b/modules/libjuju/examples/unitrun.py @@ -0,0 +1,46 @@ +""" +This example: + +1. Connects to current model and resets it. +2. Deploys one ubuntu unit. +3. Runs an action against the unit. +4. Waits for the action results to come back, then exits. + +""" +import logging + +from juju.model import Model +from juju import loop + + +async def run_command(unit): + logging.debug('Running command on unit %s', unit.name) + + # unit.run() returns a juju.action.Action instance + action = await unit.run('unit-get public-address') + logging.debug("Action results: %s", action.results) + + +async def main(): + model = Model() + # connect to current model with current user, per Juju CLI + await model.connect() + + app = await model.deploy( + 'ubuntu-0', + application_name='ubuntu', + series='trusty', + channel='stable', + ) + + for unit in app.units: + await run_command(unit) + + await model.disconnect() + + +if __name__ == '__main__': + logging.basicConfig(level=logging.DEBUG) + ws_logger = logging.getLogger('websockets.protocol') + ws_logger.setLevel(logging.INFO) + loop.run(main())