1.6 JavaScript SDK

优质
小牛编辑
140浏览
2023-12-01
Example

<!DOCTYPE html>
<!--
-->
<html lang="en">
  <head>
    <meta charset="utf-8">
    <title>EMR jQuery Client Test</title>
  </head>
  <body>
    <input type="button" id="runTest" value="Test EMR Server API" >

    <table style="width:600px">
    <tr>
      <td>API</td>
      <td>Result</td>
    </tr>
    <tr>
      <td>getServerVersion</td>
      <td id="getServerVersion">NA</td>
    </tr>
    <tr>
      <td>createCluster</td>
      <td id="createCluster">NA</td>
    </tr>
    <tr>
      <td>listClusters</td>
      <td id="listClusters">NA</td>
    </tr>
    <tr>
      <td>terminateCluster</td>
      <td id="terminateCluster">NA</td>
    </tr>
    </table>

    <script src="../../src/jquery.js"></script>
    <script src="../../src/rpc/thrift.js"></script>
    <script src="../../src/rpc/Common_types.js"></script>
    <script src="../../src/rpc/Errors_types.js"></script>
    <script src="../../src/rpc/BaseService.js"></script>
    <script src="../../src/emr/EMRService_types.js"></script>
    <script src="../../src/emr/EMRSchedulerService.js"></script>

    <script>
      (function() {
        var transport = new Thrift.TXHRTransport("http://emr.api.xiaomi.com/v1/api/scheduler");
        var protocol  = new Thrift.TJSONProtocol(transport);
        var client    = new EMRSchedulerServiceClient(protocol);
        var serverVersionElement = document.getElementById("getServerVersion");
        var createClusterElement = document.getElementById("createCluster");
        var listClustersElement = document.getElementById("listClusters");
        var terminateClusterElment = document.getElementById("terminateCluster");
        document.getElementById("runTest")
          .addEventListener("click", function() {
            client.getServerVersion(function(ver) {
              serverVersionElement.innerHTML = "Server Version: " + ver.major +
              "." + ver.minor + "." + ver.revision;
            });

            // createCluster
            var createClusterRequest = new CreateClusterRequest();
            createClusterRequest.name = "CreateClusterTest";
            createClusterRequest.region="ec2.cn-norht-1";
            createClusterRequest.purpose="emr";
            createClusterRequest.addInstanceGroupRequests = [
              new AddInstanceGroupRequest({
                name: "master",
                role: InstanceGroupRole.MASTER,
                instanceType: "master.test",
                requestedInstanceCount: 1}),
              new AddInstanceGroupRequest({
                name: "control",
                role: InstanceGroupRole.CONTROL,
                instanceType: "control.test",
                requestedInstanceCount: 3}),
              new AddInstanceGroupRequest({
                name: "core",
                role: InstanceGroupRole.CORE,
                instanceType: "core.test",
                requestedInstanceCount: 1}),
            ];
            // send request to server
            var clusterId = null;
            client.createCluster(createClusterRequest, function(createClusterResponse) {
              clusterId = createClusterResponse.cluserId;
              createClusterElement.innerHTML = "CreateClusterResponse: " + createClusterResponse;
            }).error(function(xhr, status, e) {
              createClusterElement.innerHTML = "Error code " + e.errorCode + ": " + e.errorMessage;
            });

            client.listClusters(0, 0x7FFFFFFF, function(clusterList){
              for (var idx in clusterList) {
                listClusterElement.innerHTML = listClusterElement.innerHTML + 
                "[id:" + clusterList[idx].clusterId + ",name:" + clusterList[idx].name + "]<br>";
              }
            }).error(function(xhr, status, e) {
              listClustersElement.innerHTML = "Error code " + e.errorCode + ": " + e.errorMessage;
            });

            if (clusterId != null) {
              client.terminateCluster(new TerminateClusterRequest({clusterId: clusterId}), function(response) {
                terminateClusterElment.innerHTML = "terminate cluster " + clusterId + " " + response;
              }).error(function(xhr, status, e) {
                terminateClusterElment.innerHTML = "Error code " + e.errorCode + ": " + e.errorMessage;
              });
            }
          });
      })();
    </script>
  </body>
</html>