Commit 7d8a7078 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Monitoring component: 

- corrected error in GetInstantKpi method
parent 55ee19c0

src/monitoring/service/MonitoringServiceServicerImpl.py

+7 −7
Original line number Original line Diff line number Diff line
@@ -602,23 +602,23 @@ class MonitoringServiceServicerImpl(MonitoringServiceServicer): 
            else:

            else:

                query = f"SELECT kpi_id, timestamp, kpi_value FROM monitoring WHERE kpi_id = '{kpi_id}' " \

                query = f"SELECT kpi_id, timestamp, kpi_value FROM monitoring WHERE kpi_id = '{kpi_id}' " \

                        f"LATEST ON timestamp PARTITION BY kpi_id"

                        f"LATEST ON timestamp PARTITION BY kpi_id"

                data = self.metrics_db.run_query(query)[0]

                data = self.metrics_db.run_query(query)

                LOGGER.debug(data)

                LOGGER.debug(data)

                if len(data) == 0:

                if len(data) == 0:

                    response.kpi_id.kpi_id.uuid = request.kpi_id.uuid

                    response.kpi_id.kpi_id.uuid = request.kpi_id.uuid

                else:

                else:

                    data = data[0]

                    _data = data[0]

                    response.kpi_id.kpi_id.uuid = str(data[0])

                    response.kpi_id.kpi_id.uuid = str(_data[0])

                    response.timestamp.timestamp = timestamp_string_to_float(data[1])

                    response.timestamp.timestamp = timestamp_string_to_float(_data[1])

                    response.kpi_value.floatVal = data[2]

                    response.kpi_value.floatVal = _data[2]





            return response

            return response

        except ServiceException as e:

        except ServiceException as e:

            LOGGER.exception('SetKpi exception')

            LOGGER.exception('GetInstantKpi exception')

            # CREATEKPI_COUNTER_FAILED.inc()

            # CREATEKPI_COUNTER_FAILED.inc()

            grpc_context.abort(e.code, e.details)

            grpc_context.abort(e.code, e.details)

        except Exception as e:  # pragma: no cover

        except Exception as e:  # pragma: no cover

            LOGGER.exception('SetKpi exception')

            LOGGER.exception('GetInstantKpi exception')

            # CREATEKPI_COUNTER_FAILED.inc()

            # CREATEKPI_COUNTER_FAILED.inc()

            grpc_context.abort(grpc.StatusCode.INTERNAL, str(e))

            grpc_context.abort(grpc.StatusCode.INTERNAL, str(e))