DevOps-Python-tools/find_active_hbase_stargate.py at master · avalonca/DevOps-Python-tools · GitHub

History

executable file

93 lines (74 loc) · 2.85 KB

Raw

#!/usr/bin/env python3

# 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()

DevOps-Python-tools/find_active_hbase_stargate.py at master · avalonca/DevOps-Python-tools · GitHub

Expand file tree

Breadcrumbs

find_active_hbase_stargate.py

Latest commit

History

Breadcrumbs

find_active_hbase_stargate.py

File metadata and controls