find_active_hbase_stargate.py

#!/usr/bin/env python
#  vim:ts=4:sts=4:sw=4:et
#
#  Author: Hari Sekhon
#  Date: Wed Sep 13 13:58:21 CEST 2017
#
#  https://github.com/harisekhon/devops-python-tools
#
#  License: see accompanying Hari Sekhon LICENSE file
#
#  If you're using my code you're welcome to connect with me on LinkedIn
#  and optionally send me feedback to help steer this or other code I publish
#
#  https://www.linkedin.com/in/harisekhon
#

"""

Tool to return an active HBase Stargate Rest server from an argument list of hosts

Can mix and match between a comma separated list of hosts (--host server1,server2 or contents of the $HOST
environment variable if not specified) and general free-form space separated arguments, which is useful if piping
a host list through xargs.

Multi-threaded for speed and exits upon first available host response to minimize delay to ~ 1 second or less.

Useful for simplying scripting or generically extending tools that don't support HBase High Availability directly

By default checks the same --port on all servers. Hosts may have optional :<port> suffixes added to individually
override each one.

Exits with return code 1 and NO_AVAILABLE_SERVER if none of the namenodes are active, --quiet mode will not print
NO_AVAILABLE_SERVER.

Tested on Apache HBase 0.96, 0.98, 1.0, 1.1, 1.2, 1.3

"""

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
#from __future__ import unicode_literals

import os
import sys
import traceback
#from random import shuffle
srcdir = os.path.abspath(os.path.dirname(__file__))
libdir = os.path.join(srcdir, 'pylib')
sys.path.append(libdir)
try:
    # pylint: disable=wrong-import-position
    from find_active_server import FindActiveServer
except ImportError as _:
    print(traceback.format_exc(), end='')
    sys.exit(4)

__author__ = 'Hari Sekhon'
__version__ = '0.7.1'


class FindActiveHBaseStargate(FindActiveServer):

    def __init__(self):
        # Python 2.x
        super(FindActiveHBaseStargate, self).__init__()
        # Python 3.x
        # super().__init__()
        self.protocol = 'http'
        self.default_port = 8085
        self.url_path = '/rest.jsp'
        self.regex = r'HBase.+REST'
        # the below would check REST API port instead
        #self.url_path = '/status/cluster'
        #self.regex = r'hbase'
        # but the deployed port differs between Apache HBase and Cloudera HBase deployments
        # Apache HBase
        #self.default_port = 8080
        # Cloudera Manager deployed HBase
        #self.default_port = 20050
        self.default_num_threads = 5

    def add_options(self):
        self.add_hostoption(name='HBase Stargate', default_port=self.default_port)
        self.add_ssl_opt()
        self.add_common_opts()

    def process_options(self):
        self.validate_common_opts()


if __name__ == '__main__':
    FindActiveHBaseStargate().main()