def on_stream_event()

in modules/influxdb-subscriber/src/main.py [0:0]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    def on_stream_event(self, event: SubscriptionResponseMessage):
        print("received streaming event")
        message_string = str(event.binary_message.message, "utf-8")
        inputs= json.loads(message_string)
        print(message_string)

        writerecord= write2influxdb()
        writerecord.write_data(inputs, self.token_string, self.url, self.bucket_name,self.org, self.measurement_name)
        print(self.bucket_name)