elastic

0.1.10 • Public • Published

"elastic" - elastic architecture on EC2 made automatic and easy!

How do I use this?

Here's a sample. Run this code somewhere and you'll contact Amazon, create a HTTP service cluster with load balancer, wire it all up, set up firewalls and start serving requests! All you need to start are the keys and cert from your EC2 account, a keypair in your account, and an AMI that launches apache on boot.

#!/usr/bin/env node
 
// Change this based on your particular setup.  This works on OS X.
process.env.JAVA_HOME = '/System/Library/Frameworks/JavaVM.framework/Home/';
 
// Probably leave these alone.
process.env.EC2_PRIVATE_KEY = __dirname + '/keys/pk-<your file here>.pem';
process.env.EC2_CERT = __dirname + '/keys/cert-<your file here>.pem';
 
var async = require( 'async' );
var elastic = require( 'elastic' );
var ec2 = elastic.ec2Client;
 
var cluster = new elastic.LoadBalancedCluster( 
    {
        'region': 'us-east-1',
        'zones': [ 'us-east-1a', 'us-east-1b', 'us-east-1d' ],
        'name': 'test-lb-cluster',
        'ami': 'ami-0d3aba64',
        'securityGroup': 'test-cluster-group',
        'firewallAllow': [
            {
                'port': 80,
                'subnet': '0.0.0.0/0',
                // 'group': 'sg-4251245',
            },
        ],
        'externalPort': 80,
        'internalPort': 80,
        'protocol': 'http',
        'keypair': '<your keypair name>',
        'type': 't1.micro'
    }
);
cluster.start( function( error, clusterDns ) {
    if( error )
        console.log( error );
    else
        console.log( cluster.config.name + ' is running at ' + clusterDns );
});

Logging

By default, elastic spouts progress and status reports to the console, but you can replace the logger with any object that has a '''log( message )``` function. For example, this will prepend a message "CUSTOM!" to every log entry:

var elastic = require( 'elastic' );
elastic.setLogger( {
    log: function( obj ) {
        console.log( 'CUSTOM!' + obj );
    }
} );

Running tasks on a remote server before shutting it down.

Part of autoscaling is shutting down servers in your cluster when they're no longer needed, and there may be things you want to do on them, such as recovering logs. Elastic provides some mechanisms to accomodate this.

For example, if you wanted to perform some task on an instance before it is shut down, you would add something similar to this on that server:

var elastic = require( 'elastic' );
 
var listener = new elastic.ShutdownListener ( {
    listenPort: 3000,
    onShutdown: function( callback ) {
        console.log( 'Remote has been informed of its impending shutdown, and will claim to have finished its shutdown tasks in 10 sec.' );
        setTimeout( function() {
            console.log( 'Remote is reporting that it has finished shutdown tasks.' );
            callback( null );
        }, 10000 );
    }
} );

This will result in a simple express server running on that instance which executes the "onShutdown" function when informed that it is about to be shut down. On the machine coordinating the server shutdowns:

var elastic = require( 'elastic' );
 
var notifier = new elastic.ShutdownNotifier( {
    notifyPort: 3000,
});

will create a simple object which informs the a given server of an impending shutdown. Sending the shutdown notification can then be done thusly:

notifier.announceShutdown( '127.0.0.1', function( error ) {
    if( error )
    {
        console.log( "Controller detected an error informing remote of shutdown." );
        console.log( error );
    }
    else
    {
        console.log( 'Controller has been informed that the remote system has completed shutdown tasks.' );
    }
    // Go on to actually command shutdown of the remote instance.
} );

Executing arbitrary commands on a remote server

You may find that you need to execute arbitrary commands on a remote server. If the remote system is running an SSH server, and your local system has SSH installed, and you are using public-key authentication (It feels like a lot, but EC2 linux instances generally work this way), you can use ssh to execute arbitrary commands on a remote server and get the results. Here's a sample:

var elastic = require( 'elastic' );
 
var remoteServer = new elastic.RemoteSystem( {
    'key': '/Users/cmlacy/SSH-Keys/EC2PrivateKey.pem',
    'user': 'ubuntu',
    'address': 'ec2-50-17-85-113.compute-1.amazonaws.com'
} );
 
remoteServer.exec( 'cd directory-I-care-about ; ls -al', function( error, result ) {
    if( error )
        console.log( 'ERROR: ' + require( 'util' ).inspect( error ) );
    else
    {
        console.log( result );
        remoteServer.exec( 'df -h', function( error, result ) {
            if( error )
                console.log( 'ERROR: ' + require( 'util' ).inspect( error ) );
            else
            {
                console.log( result );
            }
        });
 
    }
});

That will connect to the server specified using the given private key file, and execute a directory change and ls -l. If that is successful, it will then connect again and get the disk usage report. Results of the exec are returned as strings.

Waiting for a server to start up before issuing commands.

If you start a new EC2 instance, some time will pass between starting the instance and it becoming available for SSH commands. Elastic has a utility function which makes it easy to wait until a new instance has started up, ping it periodically to see when it becomes available for login, and then begin issuing commands to it:

var elastic = require( 'elastic' );
 
// Launch a stock Ubuntu 12.10 Server micro instance, and then run uname on it.
elastic.ec2Client.launchInstance( 
    'us-east-1', 'ami-7539b41c', 'Nova-Util', 't1.micro', 'sg-d4dba9bc', 
    elastic.Util.waitForStartup( {
            'zone': 'us-east-1',
            'key': '/Users/cmlacy/SSH Keys/Nova-Util.pem',
            'user': 'ubuntu',
        }, 
        function( error, launched ) {
            if( error )
                console.log( 'ERROR: ' + require( 'util' ).inspect( error ));
            else
            {
                console.log( launched );
                launched.remoteSystem.exec( 'uname -a', function( error, result ) {
                if( error )
                    console.log( 'ERROR: ' + require( 'util' ).inspect( error ));
                else
                    console.log( 'STARTED: ' + result );
                } );
            }
        }
    )
);

The above results in the following output:

{ instance: 'i-932e25e3',
  ami: 'ami-7539b41c',
  external: 'ec2-54-234-197-107.compute-1.amazonaws.com',
  internal: 'ip-10-203-37-142.ec2.internal',
  type't1.micro',
  zone: 'us-east-1b',
  remoteSystem: 
   { config: 
      { key: '/Users/cmlacy/Dropbox/Engine/SSH Keys/Nova-Util.pem',
        user: 'ubuntu',
        address: 'ec2-54-234-197-107.compute-1.amazonaws.com' } } }
STARTED: Linux ip-10-203-37-142 3.5.0-21-generic #32-Ubuntu SMP Tue Dec 11 18:51:59 UTC 2012 x86_64 x86_64 x86_64 GNU/Linux 

Note that the launched object contains not only a lot of critical information about the new system, it also contains a RemoteSystem object (at the property remoteSystem), which can be used to issue commands directly to the new system via SSH.

License

Some components of this product are released under specific license terms. See ec2-api-tools-1.6.5.2/THIRDPARTYLICENSE.TXT and ec2-api-tools-1.6.5.2/license.txt.

Other portions of this product are released under the MIT License:

The MIT License (MIT) Copyright © 2012 Engine, Inc.

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the “Software”), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED “AS IS”, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

Readme

Keywords

none

Package Sidebar

Install

npm i elastic

Weekly Downloads

101

Version

0.1.10

License

none

Last publish

Collaborators

  • curtis.lacy.ldengine