def on_stream_event()

in src/streamHandlers.py [0:0]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    def on_stream_event(self, event: SubscriptionResponseMessage) -> None:
        """
        When we receive a message over IPC on the local telemetry topic, publish the telemetry event to InfluxDB

        Parameters
        ----------
            event(SubscriptionResponseMessage): The received IPC message

        Returns
        -------
            None
        """
        try:
            if event is None:
                raise ValueError("Received telemetry event was None!")
            message = str(event.binary_message.message, "utf-8")
            jsonString = json.loads(message)
            if (len(jsonString) == 0):
                raise ValueError("Retrieved telemetry is empty!")
            parsedPoints = self.createPoints(jsonString)
            self.write_client.write(
                bucket=self.influxdb_parameters['InfluxDBBucket'],
                org=self.influxdb_parameters['InfluxDBOrg'],
                record=parsedPoints
            )
        except Exception:
            logging.error("Received an error while writing to InfluxDB.", exc_info=True)
            exit(1)