Skip to main content

More about MQTT on the Pioreactor

You can view the MQTT data using

pio mqtt

And to follow a specific topic, use:

pio mqtt -t "pioreactor/unit/experiment/..."

How do you structure topics for MQTT?​

We suggest using the following prefix:

pioreactor/{unit name or $broadcast}/{experiment name or $experiment}/...

How do I publish data to MQTT?​

  1. If you're writing code for Job, you can simply use Job's methods:

        def some_method(self, ...):
            ...

            self.publish(f"pioreactor/{self.unit}/{self.experiment}/{self.job_name}/more/topics", payload)

  2. If writing a script:

    from pioreactor.utils import publish


    publish(f"pioreactor/{unit}/{experiment}/more/topics", payload)

How do I subscribe to data on MQTT?​

  1. If you're writing code for Job, you can simply use Job's methods:

        def some_method(self, ...):
            ...

            msg = self.subscribe(f"pioreactor/{self.unit}/{self.experiment}/{self.job_name}/more/topics")

        def callback(self, msg):
            ...

        def some_method(self, ...):
            ...

            msg = self.subscribe_and_callback(f"pioreactor/{self.unit}/{self.experiment}/{self.job_name}/more/topics", self.callback)

  2. If writing a script:

    from pioreactor.pubsub import subscribe, subscribe_and_callback