redis_pubsub.py

    def connect_channel(self, channel, delay=1/4):
        listen = self.r.pubsub()
        listen.subscribe(channel)

        self.r.publish(channel, "a::1")

        def start_process():
            while True:
                message = listen.get_message()
                time.sleep(delay)
                if message and not message["data"] == 1:
                    message = message["data"].decode("utf-8")
                    print(f"Received command: {message}")
                    action, platform = message.split("::")
                    print(f"Action: {action} on platform: {platform}")

        p1 = Process(target=start_process, name="zzzzzzzzz")
        p1.start()
        p1.join(timeout=5)
        p1.terminate()
        return "xxxxxxxxxx"