| Task Name | Get SR ID details |
| Description | |
| Prerequisites |
|
| Category | Workflow |
| Components | vSphere 5.x |
| User Inputs |
Instructions for Regular Workflow Use:
- Download the attached .ZIP file below to your computer. *Remember the location of the saved file on your computer.
- Unzip the file on your computer. Should end up with a .WFD file.
- Log in to UCS Director as a user that has "system-admin" privileges.
- Navigate to "Policies-->Orchestration" and click on "Import".
- Click "Browse" and navigate to the location on your computer where the .WFD file resides. Choose the .WFD file and click "Open".
- Click "Upload" and then "OK" once the file upload is completed. Then click "Next".
- Click the "Select" button next to "Import Workflows". Click the "Check All" button to check all checkboxes and then the "Select" button.
- Click "Submit".
- A new folder should appear in "Policies-->Orchestration" that contains the imported workflow. You will now need to update the included tasks with information about the specific environment.
The workflow:
The Workflow run:
Picture when the SR ID in question is failed (Over all workflow runs in 19 sec):
The API call from the RESTAPI tab:
Option #1 to get the SR ID details:
//app/api/rest?formatType=json&opName=userAPIGetServiceRequestDetails&opData={param0:1000}
var srid = ctxt.getInput("sr_id");
logger.addInfo("---1---");
var x = ctxt.getAPI().userAPIGetServiceRequestDetails(srid).getStatus();
logger.addInfo("Status: " + x);
logger.addInfo("---2---");
ctxt.setTaskStatusMessage("SR ID " + srid + " is " + x);
This code runs in about 1 sec:
The code that was previous in used in many posting on this site runs 10 seconds even when a SR ID is complete:
Typical old code segment:
for (var i=0; i<childSrIdArray.length; i++)
{
var childSrId = childSrIdArray[i];
var status = ctxt.waitForCompletion(childSrId, 1800000);
if (status == 0)
{
logger.addInfo("Provisioned SR ID ="+ childSrId+ " successfully.");
} else {
logger.addError("SR ID ="+ childSrId+ " failed");
}
}
Input / Output for the last two tasks:
Code for this task:
importPackage(com.cloupia.model.cIM);
importPackage(java.util);
importPackage(java.lang);
importPackage(java.io);
importPackage(com.cloupia.lib.util);
importPackage(com.cloupia.model.cIM);
importPackage(com.cloupia.service.cIM.inframgr);
importPackage(org.apache.commons.httpclient);
importPackage(org.apache.commons.httpclient.cookie);
importPackage(org.apache.commons.httpclient.methods);
importPackage(org.apache.commons.httpclient.auth);
importPackage(com.cloupia.model.cEvent.notify);
importPackage(com.cloupia.lib.util.mail);
importPackage(com.cloupia.fw.objstore);
importPackage(com.cloupia.lib.util.managedreports);
//
// GENERIC HTTP Function
//
function GenericHTTPFunction(P1, P2){
var ucsdIP = input.UCSDip;
var ucsdUser = input.UCSDuser;
var ucsdPassword = input.UCSDpassword;
var ucsdPort = input.UCSDport;
var Https = input.UCSDhttps;
var key = input.UCSDkey;
//var apiUri = "/cloupia/api-v2/vdc";
//var apiUri = "/cloupia/api-v2/hyperVDeploymentPolicy";
var apiUri = P1;
var xmlBody = P2;
//xmlBody = "1";
var url = apiUri + "/" + xmlBody;
logger.addInfo(" URL : " + url);
var httpClient = new HttpClient();
//httpClient.getHostConfiguration().setHost(ucsdIP, input.UCSDport, input.https);
httpClient.getHostConfiguration().setHost(ucsdIP, ucsdPort, Https);
httpClient.getParams().setCookiePolicy("default");
httpClient.getParams().setAuthenticationPreemptive(true);
var defaultcreds = new UsernamePasswordCredentials(ucsdUser, ucsdPassword);
httpClient.getState().setCredentials(new AuthScope(ucsdIP, -1, null), defaultcreds);
var httpMethod = new PostMethod(apiUri);
//var httpMethod = new GetMethod (apiUri);
//var httpMethod = new GetMethod (url);
httpMethod.setRequestEntity(new StringRequestEntity(xmlBody));
httpMethod.addRequestHeader("Content-Type", "application/xml");
httpMethod.addRequestHeader("X-Cloupia-Request-Key", key);
httpClient.executeMethod(httpMethod);
var statuscode = httpMethod.getStatusCode();
if (statuscode != 201 && statuscode != 200)
{
logger.addError("Request failed. HTTP response code: "+statuscode);
logger.addError("Response = "+httpMethod.getResponseBodyAsString());
httpMethod.releaseConnection();
// Set this task as failed.
ctxt.setFailed("Request failed.");
} else {
logger.addInfo("Request was Succcessful.");
logger.addInfo("Response = "+httpMethod.getResponseBodyAsString());
var x2 = httpMethod.getResponseBodyAsString();
// All done. Release HTTP connection anyway.
httpMethod.releaseConnection();
return x2;
}
}
//
// generic http call end
//
output.APIResult = GenericHTTPFunction(input.APIuri, input.APIuriItem);
Code for this task:
loadLibrary("JSON-JS-Module/JSON-JS-ModuleLibrary");
var i1 = input.input1;
//var opName = "userAPIGetVMSummary";
function showObject(obj) {
var result = "";
for (var p in obj) {
if( obj.hasOwnProperty(p) ) {
logger.addInfo("Objact name: " + p + " Object value: " + obj[p] );
}
}
return result;
}
logger.addInfo("The input: " + i1);
var resultObj = JSON2.parse(i1);
//
// The data that is being parsed in this example looks like this:
//{ 'serviceResult':{'rows':[{'Overview_VM_ID':1...
//
// If something different is parsed then the following items need
// to be changed in the code below
//
// serviceResult
// rows
// ****
//
// ****
if(resultObj.serviceResult == null){
logger.addError(responseObj.serviceError);
ctxt.setFailed();
ctxt.exit();
}
var jsonInString = JSON2.stringify(resultObj);
logger.addInfo(jsonInString);
logger.addInfo("Show all object(s)");
// ****
//showObject(resultObj.serviceResult.rows[0]);
showObject(resultObj.serviceResult);
// other ways of getting information
// ****
//Mar 27, 2017 21:36:15 UTC {'serviceResult':{'requestId':524,'requestType':7,'initiatingUser':'admin','groupName':null,'requestTime':1490634256008,'comments':'','provisionQuantity':1,'provisionCatalog':null,'provisionVDCName':null,'provisionDurationHours':0,'status':'Complete','isChild':false,'parentRequestId':0,'isArchived':false,'workflowName':'HTTPS_get_VM_Details_userAPIGetVMSummary','containerName':'','tenantIdentity':'','rollbackStatus':''},'serviceError':null,'serviceName':'InfraMgr','opName':'userAPIGetServiceRequestDetails'}
logger.addInfo(resultObj.serviceResult.initiatingUser);
logger.addInfo(resultObj.serviceResult.workflowName);
logger.addInfo(resultObj.serviceResult.status);
logger.addInfo(resultObj.serviceResult.requestId);
//logger.addInfo(resultObj.serviceResult.requestId.Overview_Hostname);
//logger.addInfo(resultObj.serviceResult.requestId.Overview_Image_ID);
//
// Sample output
//
output.JSONout = resultObj.status
//
//@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
//
importPackage(java.util);
importPackage(java.lang);
importPackage(com.cloupia.lib.util);
importPackage(com.cloupia.service.cIM.inframgr);
importPackage(com.google.gson);
var msg = i1;
var gson = new Gson();
var json = gson.toJson(msg);
logger.addInfo('orig msg = '+i1);
logger.addInfo("typeof i1: " + typeof i1 );
var parser = new JsonParser();
var jsonTree = parser.parse(msg).getAsJsonObject();
var serviceResult = jsonTree.get("serviceResult").getAsJsonObject();
logger.addInfo("serviceResult - JSON Object: " + serviceResult.isJsonObject());
logger.addInfo("requestId: " + serviceResult.get("requestId"));
logger.addInfo("initiatingUser: " + serviceResult.get("initiatingUser"));
logger.addInfo("workflowName: " + serviceResult.get("workflowName"));
logger.addInfo("status: " + serviceResult.get("status"));
The Log:
