System.log("Agent: " + event.getValue("agent")); var key = event.getValue("key"); var snmpResult = SnmpService.retrievePolicyData(key); // Get data as Array of Properties var data = System.getModule("com.vmware.library.snmp").processSnmpResult(snmpResult); System.log("Enterprise: " + snmpResult.enterprise); // Log data System.getModule("com.vmware.library.snmp").logResult(data); for each (var element in data) { if (element.get("snmpType") == "Octet String") { var value = element.get("value"); var ipPort = value.substring(value.indexOf("pool-member") + 12, value.length).split(" ")[0]; var ip = ipPort.split(":")[0]; var port = ipPort.split(":")[1]; System.log("ip : " + ip); System.log("port : " + port); if (value.indexOf("Workload-Analytics Average Server Latency below") > -1) { //Downscaling var workflowToLaunch = Server.getWorkflowWithId("7e81523f-1478-4b08-8a86-eb77b194c322"); if (workflowToLaunch == null) { throw "Workflow not found"; } var workflowParameters = new Properties(); workflowParameters.put("ip",ip); workflowParameters.put("port",port); var wfToken = workflowToLaunch.execute(workflowParameters); } if (value.indexOf("Workload-Analytics Average Server Latency above") > -1) { //upscaling var workflowToLaunch = Server.getWorkflowWithId("ae871d09-1bf5-4085-9505-c7281d0977d3"); if (workflowToLaunch == null) { throw "Workflow not found"; } var workflowParameters = new Properties(); workflowParameters.put("ip",ip); workflowParameters.put("port",port); var wfToken = workflowToLaunch.execute(workflowParameters); } } } |