From 1a9da628abb15ea19dc10616528237c5b822e26f Mon Sep 17 00:00:00 2001 From: Erik Reid <erik.reid@geant.org> Date: Mon, 4 Feb 2019 21:50:24 +0100 Subject: [PATCH] added update_junosspace_device_list --- inventory_provider/tasks/worker.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 54c26e58..93603c61 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -226,3 +226,19 @@ def update_inventory_system_cache(): update_interface_statuses.s() ]) g.apply_async() + + +@app.task() +def update_junosspace_device_list(): + logger = logging.getLogger(constants.TASK_LOGGER_NAME) + logger.error('HERE: update_junosspace_device_list') + + r = get_redis(InventoryTask.config) + + logger.error(InventoryTask.config["junosspace"]) + for d in juniper.load_routers_from_junosspace( + InventoryTask.config["junosspace"]): + logger.error(d) + r.set( + 'junosspace:' + d['hostname'], + json.dumps(d).encode('utf-8')) -- GitLab