blob: 0eb549110e44a905429434c0568d79a897dc65c8 [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 traceback
import tornado.gen
import tornado.web
from heron.common.src.python.utils.log import Log
from import utils
from import BaseHandler
def getInstancePid(topology_info, instance_id):
This method is used by other modules, and so it
is not a part of the class.
Fetches Instance pid from heron-shell.
http_client = tornado.httpclient.AsyncHTTPClient()
endpoint = utils.make_shell_endpoint(topology_info, instance_id)
url = "%s/pid/%s" % (endpoint, instance_id)
Log.debug("HTTP call for url: %s", url)
response = yield http_client.fetch(url)
raise tornado.gen.Return(response.body)
except tornado.httpclient.HTTPError as e:
raise Exception(str(e))
class PidHandler(BaseHandler):
URL - /topologies/jmap?cluster=<cluster>&topology=<topology> \
- cluster - Name of the 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
If successfule returns the pid of instance. May include training
spaces and/or linefeed before/after.
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)
result = yield getInstancePid(topology_info, instance)
except Exception as e: