Newer
Older
from . import monitoring_pb2
from . import monitoring_pb2_grpc
from . import context_pb2
from .logger import getJSONLogger
LOGGER = getJSONLogger('monitoring-client')
LOGGER.setLevel('DEBUG')
def __init__(self, server='monitoring', port='7070'):
endpoint = '{}:{}'.format(server, port)
LOGGER.info('init monitoringClient {}'.format(endpoint))
self.channel = grpc.insecure_channel(endpoint)
self.server = monitoring_pb2_grpc.MonitoringServiceStub(self.channel)
LOGGER.info('IncludeKpi: {}'.format(request))
LOGGER.info('IncludeKpi result: {}'.format(response))
LOGGER.info('MonitorKpi: {}'.format(request))
LOGGER.info('MonitorKpi result: {}'.format(response))
LOGGER.info('GetStream_kpi: {}'.format(request))
response = self.server.GetStream_kpi(request)
LOGGER.info('GetStream_kpi result: {}'.format(response))
yield response
def GetInstantKpi(self, request):
LOGGER.info('GetInstantKpi: {}'.format(request))
LOGGER.info('GetInstantKpi result: {}'.format(response))
port = sys.argv[1] if len(sys.argv) > 1 else '7070'
kpi.kpi_id.kpi_id = 'KPIID0000' # pylint: disable=maybe-no-member