X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=examples%2Fallwatcher.py;h=ecd6e82cd730bfde280f4991e651cccbe68f8edb;hb=e8bc07a4dd87d202f2f4d5dced88ad0a6785ee0a;hp=6c549b47fb13bbacd819f007d938ee7b2b3a9cfe;hpb=edf3beda420d3a2c66d6ef8fe9b5e45a76d052b9;p=osm%2FN2VC.git diff --git a/examples/allwatcher.py b/examples/allwatcher.py index 6c549b4..ecd6e82 100644 --- a/examples/allwatcher.py +++ b/examples/allwatcher.py @@ -1,13 +1,19 @@ +""" +This example: + +1. Connects to the current model +2. Starts an AllWatcher +3. Prints all changes received from the AllWatcher +4. Runs forever (kill with Ctrl-C) + +""" import asyncio +import logging from juju.client.connection import Connection from juju.client import watcher -loop = asyncio.get_event_loop() -conn = loop.run_until_complete(Connection.connect_current()) - - async def watch(): allwatcher = watcher.AllWatcher() allwatcher.connect(conn) @@ -16,4 +22,8 @@ async def watch(): for delta in change.deltas: print(delta.deltas) + +logging.basicConfig(level=logging.DEBUG) +loop = asyncio.get_event_loop() +conn = loop.run_until_complete(Connection.connect_current()) loop.run_until_complete(watch())