Atlas Cluster Automation Using Scheduled Triggers

1
✗  npm install -g atlas-app-services-cli

1
✗ appservices login --api-key="<Public API Key>" --private-api-key="<Private API Key>"
2
3
Successfully logged in

1
appservices push --remote="<Your App ID>"
2
3
...
4
A summary of changes
5
...
6
7
? Please confirm the changes shown above Yes
8
9
Creating draft
10
Pushing changes
11
Deploying draft
12
Deployment complete
13
Successfully pushed app up:

1
 // Supply projectIDs and clusterNames...
2
  const projectIDs =[
3
  {
4
    id: '5c5db514c56c983b7e4a8701',
5
    names: [
6
      'Demo',
7
      'Demo2'
8
    ]
9
  },
10
  {
11
    id: '62d05595f08bd53924fa3634',
12
    names: [
13
      'ShardedMultiRegion'
14
    ]
15
  }
16
];

1
/*
2
 * Modifies the cluster as defined by the body parameter. 
3
 * See https://mongodb.prakticum-team.ru/docs/atlas/reference/api-resources-spec/v2/#tag/Clusters/operation/updateCluster
4
 *
5
 */
6
exports = async function(username, password, projectID, clusterName, body) {
7
  
8
  // Easy testing from the console
9
  if (username == "Hello world!") { 
10
    username = await context.values.get("AtlasPublicKey");
11
    password = await context.values.get("AtlasPrivateKey");
12
    projectID = "5c5db514c56c983b7e4a8701";
13
    clusterName = "Demo";
14
    body = {paused: false}
15
  }
16
17
  const arg = { 
18
    scheme: 'https', 
19
    host: 'cloud.mongodb.com', 
20
    path: 'api/atlas/v2/groups/' + projectID + '/clusters/' + clusterName, 
21
    username: username, 
22
    password: password,
23
    headers: {'Accept': ['application/vnd.atlas.2023-11-15+json'], 'Content-Type': ['application/json'], 'Accept-Encoding': ['bzip, deflate']}, 
24
    digestAuth:true,
25
    body: JSON.stringify(body)
26
  };
27
  
28
  // The response body is a BSON.Binary object. Parse it and return.
29
  response = await context.http.patch(arg);
30
31
  return EJSON.parse(response.body.text()); 
32
};

1
  // Easy testing from the console
2
  if (username == "Hello world!") { 
3
    username = await context.values.get("AtlasPublicKey");
4
    password = await context.values.get("AtlasPrivateKey");
5
    projectID = "5c5db514c56c983b7e4a8701";
6
    clusterName = "Demo";
7
    body = {paused: false}
8
  }

1
/*
2
 * Iterates over the provided projects and clusters, pausing those clusters
3
 */
4
exports = async function() {
5
  
6
  // Supply projectIDs and clusterNames...
7
  const projectIDs = [{id:'5c5db514c56c983b7e4a8701', names:['Demo', 'Demo2']}, {id:'62d05595f08bd53924fa3634', names:['ShardedMultiRegion']}];
8
9
  // Get stored credentials...
10
  const username = context.values.get("AtlasPublicKey");
11
  const password = context.values.get("AtlasPrivateKey");
12
13
  // Set desired state...
14
  const body = {paused: true};
15
16
  var result = "";
17
  
18
  projectIDs.forEach(async function (project) {
19
    
20
    project.names.forEach(async function (cluster) {
21
      result = await context.functions.execute('modifyCluster', username, password, project.id, cluster, body);
22
      console.log("Cluster " + cluster + ": " + EJSON.stringify(result));
23
    });
24
  });
25
  
26
  return "Clusters Paused";
27
};

1
/*
2
 * Iterates over the provided projects and clusters, resuming those clusters
3
 */
4
exports = async function() {
5
  
6
  // Supply projectIDs and clusterNames...
7
  const projectIDs = [{id:'5c5db514c56c983b7e4a8701', names:['Demo', 'Demo2']}, {id:'62d05595f08bd53924fa3634', names:['ShardedMultiRegion']}];
8
9
  // Get stored credentials...
10
  const username = context.values.get("AtlasPublicKey");
11
  const password = context.values.get("AtlasPrivateKey");
12
13
  // Set desired state...
14
  const body = {paused: false};
15
16
  var result = "";
17
  
18
  projectIDs.forEach(async function (project) {
19
    
20
    project.names.forEach(async function (cluster) {
21
      result = await context.functions.execute('modifyCluster', username, password, project.id, cluster, body);
22
      console.log("Cluster " + cluster + ": " + EJSON.stringify(result));
23
    });
24
  });
25
  
26
  return "Clusters Paused";
27
};

1
exports = async function() {
2
  
3
  // Supply projectID and clusterNames...
4
  const projectID = '<Project ID>';
5
  const clusterName = '<Cluster Name>';
6
7
  // Get stored credentials...
8
  const username = context.values.get("AtlasPublicKey");
9
  const password = context.values.get("AtlasPrivateKey");
10
11
  // Set the desired instance size...
12
 const body =   {
13
    "replicationSpecs": [
14
      {
15
        "regionConfigs": [
16
          {
17
            "electableSpecs": {
18
              "instanceSize": "M10",
19
              "nodeCount":3
20
            },
21
            "priority":7,
22
            "providerName": "AZURE",
23
            "regionName": "US_EAST_2",
24
          },
25
        ]
26
      }
27
    ]
28
  };
29
  
30
  result = await context.functions.execute('modifyCluster', username, password, projectID, clusterName, body);
31
  console.log(EJSON.stringify(result));
32
  
33
  if (result.error) {
34
    return result;
35
  }
36
37
  return clusterName + " scaled up"; 
38
};

1
/*
2
 * Returns an array of the projects in the organization
3
 * See https://docs.atlas.mongodb.com/reference/api/project-get-all/
4
 *
5
 * Returns an array of objects, e.g.
6
 *
7
 * {
8
 * "clusterCount": {
9
 *      "$numberInt": "1"
10
 *    },
11
 *    "created": "2021-05-11T18:24:48Z",
12
 *    "id": "609acbef1b76b53fcd37c8e1",
13
 *    "links": [
14
 *      {
15
 *        "href": "https://mongodb.prakticum-team.ru/proxy/cloud.mongodb.com/api/atlas/v1.0/groups/609acbef1b76b53fcd37c8e1",
16
 *        "rel": "self"
17
 *      }
18
 *    ],
19
 *    "name": "mg-training-sample",
20
 *    "orgId": "5b4e2d803b34b965050f1835"
21
 *  }
22
  *
23
 */
24
exports = async function() {
25
  
26
  // Get stored credentials...
27
  const username = await context.values.get("AtlasPublicKey");
28
  const password = await context.values.get("AtlasPrivateKey");
29
  
30
  const arg = { 
31
    scheme: 'https', 
32
    host: 'cloud.mongodb.com', 
33
    path: 'api/atlas/v1.0/groups', 
34
    username: username, 
35
    password: password,
36
    headers: {'Content-Type': ['application/json'], 'Accept-Encoding': ['bzip, deflate']}, 
37
    digestAuth:true,
38
  };
39
  
40
  // The response body is a BSON.Binary object. Parse it and return.
41
  response = await context.http.get(arg);
42
43
  return EJSON.parse(response.body.text()).results; 
44
};

1
/*
2
 * Returns an array of the clusters for the supplied project ID.
3
 * See https://docs.atlas.mongodb.com/reference/api/clusters-get-all/
4
 *
5
 * Returns an array of objects. See the API documentation for details.
6
 * 
7
 */
8
exports = async function(project_id) {
9
  
10
  if (project_id == "Hello world!") { // Easy testing from the console
11
    project_id = "5e8f8268d896f55ac04969a1"
12
  }
13
  
14
  // Get stored credentials...
15
  const username = await context.values.get("AtlasPublicKey");
16
  const password = await context.values.get("AtlasPrivateKey");
17
  
18
  const arg = { 
19
    scheme: 'https', 
20
    host: 'cloud.mongodb.com', 
21
    path: `api/atlas/v1.0/groups/${project_id}/clusters`, 
22
    username: username, 
23
    password: password,
24
    headers: {'Content-Type': ['application/json'], 'Accept-Encoding': ['bzip, deflate']}, 
25
    digestAuth:true,
26
  };
27
  
28
  // The response body is a BSON.Binary object. Parse it and return.
29
  response = await context.http.get(arg);
30
31
  return EJSON.parse(response.body.text()).results; 
32
};