blob: 6d41c4ca00b50a66f2b7a47f629f1efd3007bcbe [file] [log] [blame]
#!/usr/bin/env python3
# -*- encoding: utf-8 -*-
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
""" """
import json
import traceback
import tornado.gen
import tornado.web
from heron.common.src.python.utils.log import Log
from import utils
from import BaseHandler
from import getInstancePid
class JmapHandler(BaseHandler):
URL - /topologies/jmap?cluster=<cluster>&topology=<topology> \
- cluster - Name of cluster.
- role - (optional) Role used to submit the topology.
- environ - Running environment.
- topology - Name of topology (Note: Case sensitive. Can only
include [a-zA-Z0-9-_]+)
- instance - Instance Id
Issue a jmap for instance and save the result in a file like
The response JSON is a dict with following format:
'command': Full command executed at server.
'stdout': Text on stdout of executing the command.
'stderr': <optional> Text on stderr.
# pylint: disable=attribute-defined-outside-init
def initialize(self, tracker):
""" initialize """
self.tracker = tracker
def get(self):
""" get method """
cluster = self.get_argument_cluster()
role = self.get_argument_role()
environ = self.get_argument_environ()
topology_name = self.get_argument_topology()
instance = self.get_argument_instance()
topology_info = self.tracker.getTopologyInfo(topology_name, cluster, role, environ)
ret = yield self.runInstanceJmap(topology_info, instance)
except Exception as e:
# pylint: disable=no-self-use
def runInstanceJmap(self, topology_info, instance_id):
Fetches Instance jstack from heron-shell.
pid_response = yield getInstancePid(topology_info, instance_id)
http_client = tornado.httpclient.AsyncHTTPClient()
pid_json = json.loads(pid_response)
pid = pid_json['stdout'].strip()
if pid == '':
raise Exception('Failed to get pid')
endpoint = utils.make_shell_endpoint(topology_info, instance_id)
url = "%s/jmap/%s" % (endpoint, pid)
response = yield http_client.fetch(url)
Log.debug("HTTP call for url: %s", url)
raise tornado.gen.Return(response.body)
except tornado.httpclient.HTTPError as e:
raise Exception(str(e))