MQTT_Remote_Operation_of_a_Laboratory_Experiment.ipynb

{
  "nbformat": 4,
  "nbformat_minor": 0,
  "metadata": {
    "colab": {
      "name": "MQTT_Remote_Operation_of_a_Laboratory_Experiment.ipynb",
      "provenance": [],
      "collapsed_sections": [],
      "include_colab_link": true
    },
    "kernelspec": {
      "display_name": "Python 3",
      "language": "python",
      "name": "python3"
    },
    "language_info": {
      "codemirror_mode": {
        "name": "ipython",
        "version": 3
      },
      "file_extension": ".py",
      "mimetype": "text/x-python",
      "name": "python",
      "nbconvert_exporter": "python",
      "pygments_lexer": "ipython3",
      "version": "3.7.4"
    }
  },
  "cells": [
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "view-in-github",
        "colab_type": "text"
      },
      "source": [
        "<a href=\"https://colab.research.google.com/github/JosephBless/YOLO/blob/main/MQTT_Remote_Operation_of_a_Laboratory_Experiment.ipynb\" target=\"_parent\"><img src=\"https://colab.research.google.com/assets/colab-badge.svg\" alt=\"Open In Colab\"/></a>"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "d375e728"
      },
      "source": [
        "<!--NOTEBOOK_HEADER-->\n",
        "*This notebook contains material from [cbe61622](https://jckantor.github.io/cbe61622);\n",
        "content is available [on Github](https://github.com/jckantor/cbe61622.git).*\n"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "b12eceb4"
      },
      "source": [
        "<!--NAVIGATION-->\n",
        "< [3.1 Publishing an Experiment via MQTT](https://jckantor.github.io/cbe61622/03.01-Publishing_an_Experiment_via_MQTT.html) | [Contents](toc.html) | [3.3 Accessing MQTT Devices](https://jckantor.github.io/cbe61622/03.03-Miscellaneous_Notes.html) ><p><a href=\"https://colab.research.google.com/github/jckantor/cbe61622/blob/master/docs/03.02-Accessing_a_Remote_Experiment_via_MQTT.ipynb\"> <img align=\"left\" src=\"https://colab.research.google.com/assets/colab-badge.svg\" alt=\"Open in Colab\" title=\"Open in Google Colaboratory\"></a><p><a href=\"https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.ipynb\"> <img align=\"left\" src=\"https://img.shields.io/badge/Github-Download-blue.svg\" alt=\"Download\" title=\"Download Notebook\"></a>"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "kpLyVHsjDqSt",
        "nbpages": {
          "level": 1,
          "link": "[3.2 Accessing a Remote Experiment via MQTT](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2-Accessing-a-Remote-Experiment-via-MQTT)",
          "section": "3.2 Accessing a Remote Experiment via MQTT"
        }
      },
      "source": [
        "# 3.2 Accessing a Remote Experiment via MQTT"
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "Goa0-Jn_s1bx",
        "nbpages": {
          "level": 2,
          "link": "[3.2.1 Installations](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.1-Installations)",
          "section": "3.2.1 Installations"
        }
      },
      "source": [
        "## 3.2.1 Installations"
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 187
        },
        "id": "OF0o09nNjQju",
        "nbpages": {
          "level": 2,
          "link": "[3.2.1 Installations](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.1-Installations)",
          "section": "3.2.1 Installations"
        },
        "outputId": "5f2cfcb8-438b-4ed8-9ec0-0731930a3fd8"
      },
      "source": [
        "!pip install paho-mqtt"
      ],
      "execution_count": null,
      "outputs": [
        {
          "name": "stdout",
          "output_type": "stream",
          "text": [
            "Requirement already satisfied: paho-mqtt in /Users/jeff/opt/anaconda3/lib/python3.7/site-packages (1.5.1)\n"
          ]
        }
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "Vq1o8PaPD6wi",
        "nbpages": {
          "level": 2,
          "link": "[3.2.2 Remote Operation of a Laboratory Experiment](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.2-Remote-Operation-of-a-Laboratory-Experiment)",
          "section": "3.2.2 Remote Operation of a Laboratory Experiment"
        }
      },
      "source": [
        "## 3.2.2 Remote Operation of a Laboratory Experiment\n",
        "\n",
        "This cell establishes a connection to two topics on an MQTT server. The 'command' channel is used to publish a message to start a remote experiment for a duration given in seconds. A client is opened to listen to a 'measurement' channel.\n",
        "\n",
        "Before running this channel, start up up the companion notebook that simulates a remote experiment https://colab.research.google.com/drive/1cj9Y8IlVX2-ZMEMoVWi8G5WDKNr3gkr9?usp=sharing "
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "nbpages": {
          "level": 2,
          "link": "[3.2.2 Remote Operation of a Laboratory Experiment](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.2-Remote-Operation-of-a-Laboratory-Experiment)",
          "section": "3.2.2 Remote Operation of a Laboratory Experiment"
        },
        "id": "pH9LolsngCze",
        "outputId": "476b777a-ef36-4d3b-d47a-c78d2b8ac8a3"
      },
      "source": [
        "%matplotlib inline\n",
        "import paho.mqtt.client as mqtt\n",
        "import paho.mqtt.publish as publish\n",
        "import time\n",
        "import matplotlib.pyplot as plt\n",
        "import numpy as np\n",
        "from IPython import display\n",
        "import json\n",
        "import uuid\n",
        "\n",
        "# configuration\n",
        "duration = 10\n",
        "\n",
        "# set up client to interact with cbe-virtual-laboratory\n",
        "\n",
        "class CBEClient(mqtt.Client):\n",
        "    \n",
        "    def __init__(self, recv=\"\", send=\"\"):\n",
        "        super().__init__()\n",
        "        self.host = \"mqtt.eclipse.org\"\n",
        "        self.recv = recv\n",
        "        self.send = send\n",
        "\n",
        "    def on_connect(self, client, userdata, flags, rc):\n",
        "        print(f\"Connected: {self.host} with return code {rc}\")\n",
        "        if self.recv:\n",
        "            self.subscribe(self.recv, qos=2)\n",
        "            print(f\"Subscribed: {self.recv}\")\n",
        "        \n",
        "    def on_message(self, client, userdata, msg):\n",
        "        payload = json.loads(msg.payload.decode(\"utf-8\"))\n",
        "        print(f\"Receieved: {payload} from {self.recv}\")\n",
        "    \n",
        "    def connect(self):\n",
        "        super().connect(host=self.host, port=1883, keepalive=60)\n",
        "                              \n",
        "    def publish(self, payload):\n",
        "        if self.send:\n",
        "            super().publish(self.send, payload=payload)\n",
        "            print(f\"Sent: {payload} to {self.send}\")\n",
        "        else:\n",
        "            print(\"No send topic has been specified.\")\n",
        "        \n",
        "    def __enter__(self):\n",
        "        self.connect()\n",
        "        self.loop_start()\n",
        "        time.sleep(0.5)\n",
        "        print(f\"Loop Started: {self}\")\n",
        "        return self\n",
        "        \n",
        "    def __exit__(self, exc_type, exc_value, exc_traceback):\n",
        "        self.loop_stop()\n",
        "        print(f\"Loop Stopped: {self}\")\n",
        "\n",
        "# listen for response\n",
        "with CBEClient(send=\"cbe-virtual-laboratory/command\") as cbe:\n",
        "    payload = {\n",
        "        \"client_id\" : str(uuid.getnode()),\n",
        "        \"duration\" : duration\n",
        "    }\n",
        "    cbe.publish(json.dumps(payload))\n",
        "    with CBEClient(recv=\"/\".join([\"cbe-virtual-laboratory\", payload[\"client_id\"]])) as expt:\n",
        "        time.sleep(duration)\n",
        "    "
      ],
      "execution_count": null,
      "outputs": [
        {
          "name": "stdout",
          "output_type": "stream",
          "text": [
            "Connected: mqtt.eclipse.org with return code 0\n",
            "Loop Started: <__main__.CBEClient object at 0x7ffb0c31fc50>\n",
            "Sent: {\"client_id\": \"64844672765268\", \"duration\": 10} to cbe-virtual-laboratory/command\n",
            "Connected: mqtt.eclipse.org with return code 0\n",
            "Subscribed: cbe-virtual-laboratory/64844672765268\n",
            "Loop Started: <__main__.CBEClient object at 0x7ffb0c2ef510>\n",
            "Receieved: {'time': 0, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 1, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 2, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 3, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 4, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 5, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 6, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 7, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 8, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Receieved: {'time': 9, 'x': 0, 'y': 0} from cbe-virtual-laboratory/64844672765268\n",
            "Loop Stopped: <__main__.CBEClient object at 0x7ffb0c2ef510>\n",
            "Loop Stopped: <__main__.CBEClient object at 0x7ffb0c31fc50>\n"
          ]
        }
      ]
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "5_gOHgpJFg5q",
        "nbpages": {
          "level": 2,
          "link": "[3.2.3 Version 1](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.3-Version-1)",
          "section": "3.2.3 Version 1"
        }
      },
      "source": [
        "## 3.2.3 Version 1"
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "colab": {
          "base_uri": "https://localhost:8080/",
          "height": 295
        },
        "id": "OIc0GSZLjLXC",
        "nbpages": {
          "level": 2,
          "link": "[3.2.3 Version 1](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.3-Version-1)",
          "section": "3.2.3 Version 1"
        },
        "outputId": "c23c475a-6375-48cd-838e-17ec4c4b01aa"
      },
      "source": [
        "%matplotlib inline\n",
        "import paho.mqtt.client as mqtt\n",
        "import paho.mqtt.publish as publish\n",
        "import time\n",
        "import matplotlib.pyplot as plt\n",
        "import numpy as np\n",
        "from IPython import display\n",
        "\n",
        "# select experiment duration\n",
        "duration = 10\n",
        "topic = \"cbe-virtual-laboratory/command\"\n",
        "\n",
        "# setup a plotting window\n",
        "x = []\n",
        "y = []\n",
        "fig, ax = plt.subplots(1, 1)\n",
        "ax.plot(x, y, '.', ms=10)\n",
        "ax.set_xlim(0, 40)\n",
        "ax.set_ylim(0, 2.1)\n",
        "ax.set_xlabel('time / seconds')\n",
        "ax.set_ylabel('level')\n",
        "ax.set_title(topic)\n",
        "line = ax.lines[0]\n",
        "display.display(fig)\n",
        "\n",
        "# callbacks\n",
        "def on_connect(client, userdata, flags, rc):\n",
        "    print(f\"Connected with result code {rc}\")\n",
        "    client.subscribe(\"cbe-virtual-laboratory/expt\")\n",
        "\n",
        "# call back to process message from remote experiment\n",
        "def on_message(client, userdata, msg):\n",
        "    #print(msg.topic + \" \" + msg.payload.decode(\"utf-8\"))\n",
        "    xdata, ydata = [float(i) for i in msg.payload.decode(\"utf-8\").split(',')]\n",
        "    x.append(xdata)\n",
        "    y.append(ydata)\n",
        "    line.set_data(x, y)\n",
        "    display.clear_output(wait=True)\n",
        "    display.display(fig)\n",
        "\n",
        "# setup client\n",
        "client = mqtt.Client()\n",
        "client.on_connect = on_connect\n",
        "client.on_message = on_message\n",
        "\n",
        "# connect to measurement channel\n",
        "client.connect(\"mqtt.eclipse.org\", 1883, 60)\n",
        "\n",
        "# tell experiment to start\n",
        "msg = f'{{\"duration\": {duration}}}'\n",
        "publish.single(\"cbe-virtual-laboratory/command\", msg, hostname=\"mqtt.eclipse.org\")\n",
        "\n",
        "# listen for measurement information\n",
        "client.loop_start()\n",
        "time.sleep(duration)\n",
        "client.loop_stop()\n",
        "\n",
        "# prevent the plot showing again after completion\n",
        "plt.close()"
      ],
      "execution_count": null,
      "outputs": [
        {
          "data": {
            "image/png": "iVBORw0KGgoAAAANSUhEUgAAAY4AAAEWCAYAAABxMXBSAAAABHNCSVQICAgIfAhkiAAAAAlwSFlzAAALEgAACxIB0t1+/AAAADh0RVh0U29mdHdhcmUAbWF0cGxvdGxpYiB2ZXJzaW9uMy4yLjIsIGh0dHA6Ly9tYXRwbG90bGliLm9yZy+WH4yJAAAgAElEQVR4nO3deZxcZZ3v8c+XJmFLIEACl2wENBdZhKBlUEGJKBhQWV6jkgzKIpoRwRG83hFGrzCoV0fHYUZAMUKGxWGTxYleFGKAF4wjSwfCkgQkBDSbSSBAwiJMkt/94zwNJ0V3dZ2kTld19ff9etWrz3mes/zqdHf96jznnOdRRGBmZlavLZodgJmZ9S9OHGZmVogTh5mZFeLEYWZmhThxmJlZIU4cZmZWiBPHACbpZEn/2Qf7eZ+kx8veT9U+Q9Jbe6ibJGlJndvpk2Nk5Sjyu7b6OXFY6SLi7ojYq9Yykp6W9KG+iqlV1Up4DdzHSH+Y2uZw4rCmkrRls2PoK2W/1wLbPwr4TZmxWHtz4hggJI2RdJOkVZKelXTRG1W6SNILkh6T9MHcOjtIukzScklLJX1LUkc3295K0vOS9suVjZD0iqRdqpsL0tnFVyU9DLwk6RpgLPBLSS9K+rvumhjyZyWSJkr6fdrv8vQeBm/isTlb0pOS1kqaL+m4Ny/S4zEaKWmmpNWSFkr6XK7uPEk3SPqZpDXAybXilnRXWvWhdByOT+WfS9tenfY1MrePkHS6pCeAJyRdLOkHVcHPlHRWrugo4JZU1+3fhaQtJH1d0h8lrZR0paQdUt24tN9TJC2W9Jykz0t6l6SH03u7KLf/kyX9TtIFqW6RpPem8sVp+yfllv+IpAclrUn15+XquvZ9kqQ/SXpG0tdy9dtIujzFNB94Vz1/A1ZQRPjV5i+gA3gIuADYDtgaOAQ4GVgHnAUMAo4HXgB2SuvdDPwkrbMLcB/wNz3sYwbw7dz86cBv0vQkYEmu7mlgLjAG2CZX9qHcMhutU70M8E7g3cCWwDhgAXBmbtkA3tpDrNXxfAIYSfZF6njgJWC3VNfbMboL+FE6phOAVcBhqe484L+BY9O2tykaN3AY8AzwDmAr4ELgrqrlZwE7pe1PBJYBW6T64cDLwK5pflDa3tCe/i7Scp8BFgJ7AkOAm4CrUt24tN9L0jpHAH8BfkH2dzIKWAkcWnUMT0n7/BbwJ+Di9J6OANYCQ3K/n7enY7Y/sAI4tmrfP03v9wDgVWDvVP9d4O50PMYAj1L1d+RXAz5Tmh2AX33wS4b3pA+0LavKT04fMsqV3Qd8Gtg1/UNuk6ubCtzRwz4+BDyZm/8dcGKansSbE8dnqtZ/mgKJo5v9nwncnJuvO3F0Uz8XOKaOYzQGWA8MzdV9B7g8TZ9H7kN+U+IGLgO+l5sfQpaMxuWWP6xqmwuAw9P0GcAtuboPArNr/V2kutnAF3Lze6X9diW8AEbl6p8Fjs/N30hKiOkYPpGre3taf9eq9Sf0cIz+BbggTXfte3TV72NKml4ETM7VTav1u/Zr015uqhoYxgB/jIh13dQtjfQflvyR7Nv37mTfTpen5oXnyc4+dgGQNC81p7wo6X3AHcC2kg6SNI7s2/fNNWJavDlvSNL/lPQrSX9OzUD/l+zbdfVyY3NxvtjDtk6UNDf3Pver2lZPx2gksDoi1lbVjcrNb/Q+6407Z2TaJgAR8SLZh2yP+wCuAD6Vpj8FXJWre72Zitp/FxvtN01vSfaFosuK3PQr3cwPqbEsEdHt8ulv6I7UfPYC8HnefIz+nJt+ObevkWx8PPLvwRrEiWNgWAyMVfcXT0dJUm5+LNk37MVkZxzDI2JYem0fEfsCRMS+ETEkve6OiPXA9WRnJVOBX1V9oFar7pa5ev4lYNuuGWXXVkbk6n8MPAaMj4jtgb8HRJWI+FMuziHV9ZJ2J2v2OAPYOSKGkTVv5LfV0zFaBuwkaWhV3dIa76uuuHOWkSXxrni3A3buZR8/A46RdACwN1kTUpd84qj1d7HRfsne1zo2TgBluRqYCYyJiB3ImsRqHaO85WQJscvYBsdmOHEMFPeR/UN9V9J2kraWdHCq2wX4W0mDJH2C7IPmlohYDtwG/EDS9uli6VskHVpjP1eTXQM4IU0XsYKsPb3LH4Ct04XSQcDXydrDuwwF1gAvSnobcFrB/XXZjuyDdxWApFPIzjjyejpGi4H/Ar6Tjun+wKlkH9w96S3u6uNwDXCKpAmStiI7Q7k3Ip7uaQcRsQS4n+xM48aIeCW9tz2ArSJiQVq01t/FNcBZkvaQNCTt97oezk4abSjZmdxfJE0E/rrAutcD50jaUdJo4IulRDjAOXEMAOls4GPAW8kuSi4h+4AHuBcYT3bB9NvAxyPi2VR3IjAYmA88B9wA7FZjP/eSnSmMBH5dMMzvAF9PzUVfiYgXgC8Al5J9u34pxd3lK2QfKGvJzhiuK7i/rpjnAz8Afk/2of12suszebWO0VSydvdlZE1z50bEb2vssre4zwOuSMfhk2lb/4fsmsFy4C3AlDre2hXpveSbqT7CG2cbvf1dzEjr3gU8RXbxu68+hL8AnC9pLfANsmRQr38ga556iuyLz1W1F7dNoY2bbs2sHUh6P9mZz+5d12ck3QJcFBG31FzZrBc+4zBrM6lp70vApVUX9e8ku4nBbLP4jMOsjUjaG+gkez5jckSsaXJI1oacOMzMrBA3VZmZWSFt1cHc8OHDY9y4cc0Ow8ys35gzZ84zETGi9yXf0FaJY9y4cXR2djY7DDOzfkNS4afr3VRlZmaFOHGYmVkhThxmZlaIE4eZmRXixGFmZoU4cZiZWSGlJQ5lYxnfoWwM53mSvtTNMpL0Q2XjKT8s6R25upMkPZFeJ1Wv252Va19l9oIVrN/gp+HNzMpS5hnHOuB/RcQ+ZGMsny5pn6pljiTrrno82RCPPwaQtBNwLnAQ2RjK50rasbcdrljzF754zYN8+rJ7nTzMzEpSWuKIiOUR8UCaXks2DvKoqsWOAa6MzD3AMEm7AR8GZkXE6oh4DpgFTK5nvy+/tp65i5/nzsdXNuy9mJnZG/rkGkcag/pAsgFx8kax8fjAS1JZT+XdbXuapE5Jrz8y/spr65m/zJ2CmpmVofTEkYadvBE4s4wuniNiekRUIqLSVbbN4A72Gbl9o3dlZmaUnDjSgDI3Av8eETd1s8hSNh5YfnQq66m8V9sO7mDCmGFM2muXTQvazMxqKvOuKgGXAQsi4p97WGwmcGK6u+rdwAsRsRy4FTgiDTi/I3BEKqtp1+235sKpB3LVqQfRsYUa9E7MzCyvzN5xDwY+DTwiaW4q+3tgLEBEXALcAhwFLAReBk5JdaslfRO4P613fkSs7m2Huwzdig/uvWtD34SZmW2stMQREf8J1Pzan8ZDPr2HuhnAjBJCMzOzzeAnx83MrBAnDjMzK8SJw8zMCnHiMDOzQpw4zMysECcOMzMrxInDzMwKceIwM7NCnDjMzKwQJw4zMyvEicPMzAops5PDlrB+Q3Dn4yuZt2wN+47cnkl77eKec83MNkNbJ471G4JPX3Yvcxc/zyuvrWebNFaHu103M9t0bd1UdefjK5m7+Hlefm09gccjNzNrhLZOHPOWreGV19ZvVObxyM3MNk9bJ459R27PNoM7NirzeORmZpunzKFjZ0haKenRHur/t6S56fWopPWSdkp1T0t6JNV1bmoMk/bahQljhrHt4A6ExyM3M2sEZYPwlbBh6f3Ai8CVEbFfL8t+DDgrIg5L808DlYh4psg+K5VKdHZunGe67qqav2wN+/iuKjOzjUiaExGVIuuUOXTsXZLG1bn4VOCaMuLo2EJ8cO9dPRa5mVmDNP0ah6RtgcnAjbniAG6TNEfStOZEZmZm3WmF5zg+BvwuIlbnyg6JiKWSdgFmSXosIu7qbuWUWKYBjB07tvxozcwGuKafcQBTqGqmioil6edK4GZgYk8rR8T0iKhERGXEiBGlBmpmZk1OHJJ2AA4F/iNXtp2koV3TwBFAt3dmmZlZ3yutqUrSNcAkYLikJcC5wCCAiLgkLXYccFtEvJRbdVfgZkld8V0dEb8pK04zMyumzLuqptaxzOXA5VVli4ADyonKzMw2Vytc4zAzs37EicPMzApx4jAzs0KcOMzMrBAnDjMzK6QVnhxvOg8va2ZWvwGfODy8rJlZMQO+qcrDy5qZFTPgE4eHlzUzK2bAJw4PL2tmVsyATxweXtbMrJgBf3G8Ywtx1akHeXhZM7M6DfjEAR5e1sysiAHfVGVmZsU4cZiZWSFOHGZmVogTh5mZFVJa4pA0Q9JKSd2OFy5pkqQXJM1Nr2/k6iZLelzSQklnlxWjmZkVV+YZx+XA5F6WuTsiJqTX+QCSOoCLgSOBfYCpkvYpMU4zMyugtMQREXcBqzdh1YnAwohYFBGvAdcCxzQ0ODMz22TNvsbxHkkPSfq1pH1T2ShgcW6ZJamsW5KmSeqU1Llq1aoyYzUzM5qbOB4Ado+IA4ALgV9sykYiYnpEVCKiMmLEiIYGaGZmb9a0xBERayLixTR9CzBI0nBgKTAmt+joVNZU6zcEsxes4Iezn2D2ghWs3xDNDsnMrCma1uWIpP8BrIiIkDSRLIk9CzwPjJe0B1nCmAL8dbPiBA/2ZGaWV1rikHQNMAkYLmkJcC4wCCAiLgE+DpwmaR3wCjAlIgJYJ+kM4FagA5gREfPKirMe+cGeYOPBnty/lZkNNKUljoiY2kv9RcBFPdTdAtxSRlybotZgT04cZjbQNPuuqn7Bgz2Zmb3BiaMOHuzJzOwNHo+jDh7syczsDU4cdfJgT2ZmGTdVmZlZIU4cZmZWiBOHmZkV4sRhZmaFOHGYmVkhThxmZlaIE4eZmRXi5zgaZP2G4M7HVzJv2Rr29QOCZtbGnDgawN2um9lA4qaqBsh3ux5s3O26mVm7ceJogFrdrpuZtRsnjgZwt+tmNpA4cTSAu103s4GkzKFjZwAfBVZGxH7d1J8AfBUQsBY4LSIeSnVPp7L1wLqIqJQVZyO423UzG0jKvKvqcrKhYa/sof4p4NCIeE7SkcB04KBc/Qci4pkS42sod7tuZgNFmWOO3yVpXI36/8rN3gOMLisWMzNrnFa5xnEq8OvcfAC3SZojaVqtFSVNk9QpqXPVqlWlBmlmZi3wAKCkD5AljkNyxYdExFJJuwCzJD0WEXd1t35ETCdr5qJSqUTpAZuZDXBNPeOQtD9wKXBMRDzbVR4RS9PPlcDNwMTmRGhmZtWaljgkjQVuAj4dEX/IlW8naWjXNHAE8GhzojQzs2pl3o57DTAJGC5pCXAuMAggIi4BvgHsDPxIErxx2+2uwM2pbEvg6oj4TVlxmplZMWXeVTW1l/rPAp/tpnwRcEBZcTWLe881s3bR9IvjA4F7zzWzdtIqt+O2Nfeea2btxImjD7j3XDNrJ04cfcC955pZO3Hi6APuPdfM2okvjvcB955rZu3EiaOPuPdcM2sXNROHpLVkHQ5CNm4GaV5ARIQb6c3MBpiaiSMihvZVIGZm1j/UfXFc0iGSTknTwyXtUV5YZmbWqupKHJLOJRvm9ZxUNBj4WVlBmZlZ66r34vhxwIHAAwARsayrB1trHPdnZWb9Qb2J47WICEkBr3d3bg3k/qzMrL+o9xrH9ZJ+AgyT9Dngt8BPywtr4HF/VmbWX9SVOCLin4AbgBuBvYBvRMSFZQY20Lg/KzPrL+pqqpL0ZeC6iJhVcjwDVld/Vi/nkof7szKzVlRvU9VQ4DZJd0s6Q5Iff24w92dlZv2FIqL3pboWlvYHjgf+ClgSER/qZfkZwEeBlRGxXzf1Av4VOAp4GTg5Ih5IdScBX0+LfisirugtvkqlEp2dnXW/n1bTdVeV+7Mys74iaU4atrtuRfuqWgn8GXgWqOer8OXARcCVPdQfCYxPr4OAHwMHSdqJbIzyClkXJ3MkzYyI5wrG26+4Pysz6w/qfQDwC5LuBGYDOwOfi4j9e1svIu4CVtdY5BjgysjcQ3bX1m7Ah4FZEbE6JYtZwOR6YjUzs3LVe8YxBjgzIuY2eP+jgMW5+SWprKfyN5E0DZgGMHbs2AaHZ2Zm1eq9HfccYEiur6oRrdJXVURMj4hKRFRGjBjR7HBKtX5DMHvBCn44+wlmL1jB+g31X58yM2uUem/H7bresBfwb8Agsr6qDt7M/S8lO5vpMjqVLQUmVZXfuZn76tf8ZLmZtYp6b8c9DjgaeAmyvqrIbtHdXDOBE5V5N/BCRCwHbgWOkLSjpB2BI1LZgOUny82sVZTaV5Wka8jOHIZLWkJ2p9QggIi4BLiF7FbchWS3456S6lZL+iZwf9rU+RFR6yJ726v1ZLnvwjKzvlRv4qjuq+oz1NFXVURM7aU+gNN7qJsBzKgzvrbnJ8vNrFXUlTgi4p8kHQ6s4Y2+qtz9SB/qerK8+hqHnyw3s75W9wOAKVE4WTRJxxbiqlMP8pPlZtZ0NROHpLVkT26/qYqspcntJH3IT5abWSuomTgiwqP8mZnZRuq9HdfMzAxw4jAzs4KK9o5rLa6ra/Z5y9awry+gm1kJnDjaiLslMbO+4KaqNuJuScysLzhxtJFa3ZKYmTWKE0cb6eqWJM/dkphZozlxtJGubkm2HdyBgG3dLYmZlcAXx9uIuyUxs77gxNFm3C2JmZXNTVVmZlaIzzgGGD8gaGaby4ljAPEDgmbWCKU2VUmaLOlxSQslnd1N/QWS5qbXHyQ9n6tbn6ubWWacA4UfEDSzRijtjENSB3AxcDiwBLhf0syImN+1TESclVv+i8CBuU28EhETyopvIPK45WbWCGWecUwEFkbEooh4DbgWOKbG8lOBa0qMZ8DzA4Jm1ghlJo5RwOLc/JJU9iaSdgf2AG7PFW8tqVPSPZKO7Wknkqal5TpXrVrViLjblh8QNLNGaJWL41OAGyIi346ye0QslbQncLukRyLiyeoVI2I6MB2gUql0N8ytJX5A0MwaoczEsRQYk5sfncq6MwU4PV8QEUvTz0WS7iS7/vGmxGHF+AFBM9tcZTZV3Q+Ml7SHpMFkyeFNd0dJehuwI/D7XNmOkrZK08OBg4H51euamVnfK+2MIyLWSToDuBXoAGZExDxJ5wOdEdGVRKYA10ZEvplpb+AnkjaQJbfv5u/GMjOz5tHGn9f9W6VSic7OzmaHYWbWb0iaExGVIuu4ryozMyvEicPMzApx4jAzs0KcOMzMrBAnDjMzK8SJw8zMCnHiMDOzQpw4zMysECcOMzMrxInDzMwKceIwM7NCnDjMzKwQJw4zMyvEicPMzApx4jAzs0KcOMzMrBAnDjMzK6TUxCFpsqTHJS2UdHY39SdLWiVpbnp9Nld3kqQn0uukMuM0M7P6lTbmuKQO4GLgcGAJcL+kmd2MHX5dRJxRte5OwLlABQhgTlr3ubLiNTOz+pR5xjERWBgRiyLiNeBa4Jg61/0wMCsiVqdkMQuYXFKcZmZWQJmJYxSwODe/JJVV+ytJD0u6QdKYgusiaZqkTkmdq1atakTcZmZWQ7Mvjv8SGBcR+5OdVVxRdAMRMT0iKhFRGTFiRMMDNDOzjZWZOJYCY3Lzo1PZ6yLi2Yh4Nc1eCryz3nXNzKw5ykwc9wPjJe0haTAwBZiZX0DSbrnZo4EFafpW4AhJO0raETgilZmZWZOVdldVRKyTdAbZB34HMCMi5kk6H+iMiJnA30o6GlgHrAZOTuuulvRNsuQDcH5ErC4rVjMzq58iotkxNEylUonOzs5mh2Fm1m9ImhMRlSLrNPviuJmZ9TNOHGZmVogTh5mZFeLEYWZmhThxmJlZIU4cZmZWiBOHmZkV4sRhZmaFOHGYmVkhThxmZlaIE4eZmRXixGFmZoU4cZiZWSFOHGZmVogTh5mZFeLEYWZmhThxmJlZIaUmDkmTJT0uaaGks7up/7Kk+ZIeljRb0u65uvWS5qbXzOp1zcysOUobc1xSB3AxcDiwBLhf0syImJ9b7EGgEhEvSzoN+B5wfKp7JSImlBWfmZltmjLPOCYCCyNiUUS8BlwLHJNfICLuiIiX0+w9wOgS4zEzswYoM3GMAhbn5peksp6cCvw6N7+1pE5J90g6tqeVJE1Ly3WuWrVq8yI2M7NeldZUVYSkTwEV4NBc8e4RsVTSnsDtkh6JiCer142I6cB0gEqlEn0SsJnZAFbmGcdSYExufnQq24ikDwFfA46OiFe7yiNiafq5CLgTOLDEWM3MrE5lJo77gfGS9pA0GJgCbHR3lKQDgZ+QJY2VufIdJW2VpocDBwP5i+pmZtYkpTVVRcQ6SWcAtwIdwIyImCfpfKAzImYC3weGAD+XBPCniDga2Bv4iaQNZMntu1V3Y5mZWZMoon0uC1Qqlejs7Gx2GGZm/YakORFRKbKOnxw3M7NCnDjMzKwQJw4zMyvEicPMzApx4jAzs0KcOMzMrBAnDjMzK8SJw8zMCnHiMDOzQpw4zMysECcOMzMrxInDzMwKceIwM7NCnDjMzKwQJw4zMyvEicPMzApx4jAzs0JKTRySJkt6XNJCSWd3U7+VpOtS/b2SxuXqzknlj0v6cJlxmplZ/UpLHJI6gIuBI4F9gKmS9qla7FTguYh4K3AB8I9p3X2AKcC+wGTgR2l7ZmbWZGWecUwEFkbEooh4DbgWOKZqmWOAK9L0DcAHJSmVXxsRr0bEU8DCtD0zM2uyLUvc9ihgcW5+CXBQT8tExDpJLwA7p/J7qtYd1d1OJE0DpqXZVyU9uvmhl2o48Eyzg6iD42wsx9lYjrNx9iq6QpmJo09ExHRgOoCkzoioNDmkmvpDjOA4G81xNpbjbBxJnUXXKbOpaikwJjc/OpV1u4ykLYEdgGfrXNfMzJqgzMRxPzBe0h6SBpNd7J5ZtcxM4KQ0/XHg9oiIVD4l3XW1BzAeuK/EWM3MrE6lNVWlaxZnALcCHcCMiJgn6XygMyJmApcBV0laCKwmSy6k5a4H5gPrgNMjYn0du51exntpsP4QIzjORnOcjeU4G6dwjMq+4JuZmdXHT46bmVkhThxmZlZIWySO3ro2aRWSnpb0iKS5m3ILXFkkzZC0Mv8MjKSdJM2S9ET6uWMzY0wxdRfneZKWpmM6V9JRTY5xjKQ7JM2XNE/Sl1J5Sx3PGnG22vHcWtJ9kh5Kcf5DKt8jdVO0MHVbNLhF47xc0lO54zmhmXF2kdQh6UFJv0rzxY5nRPTrF9mF9yeBPYHBwEPAPs2Oq4dYnwaGNzuObuJ6P/AO4NFc2feAs9P02cA/tmic5wFfaXZsuXh2A96RpocCfyDrcqeljmeNOFvteAoYkqYHAfcC7wauB6ak8kuA01o0zsuBjzf7OHYT75eBq4FfpflCx7Mdzjjq6drEaoiIu8juasvLdwdzBXBsnwbVjR7ibCkRsTwiHkjTa4EFZL0etNTxrBFnS4nMi2l2UHoFcBhZN0XQGsezpzhbjqTRwEeAS9O8KHg82yFxdNe1Scv9AyQB3CZpTuoqpZXtGhHL0/SfgV2bGUwvzpD0cGrKanqTWpfU2/OBZN8+W/Z4VsUJLXY8U7PKXGAlMIusheH5iFiXFmmJ//nqOCOi63h+Ox3PCyRt1cQQu/wL8HfAhjS/MwWPZzskjv7kkIh4B1mPwadLen+zA6pHZOevLfntCfgx8BZgArAc+EFzw8lIGgLcCJwZEWvyda10PLuJs+WOZ0Ssj4gJZD1ITATe1uSQulUdp6T9gHPI4n0XsBPw1SaGiKSPAisjYs7mbKcdEke/6Z4kIpamnyuBm2ntHn9XSNoNIP1c2eR4uhURK9I/7Abgp7TAMZU0iOzD+N8j4qZU3HLHs7s4W/F4domI54E7gPcAw1I3RdBi//O5OCenJsGIiFeBf6P5x/Ng4GhJT5M16x8G/CsFj2c7JI56ujZpOknbSRraNQ0cAbRyT7757mBOAv6jibH0qOvDODmOJh/T1F58GbAgIv45V9VSx7OnOFvweI6QNCxNbwMcTnY95g6yboqgNY5nd3E+lvuyILLrBk09nhFxTkSMjohxZJ+Vt0fECRQ9ns2+ut+gOwSOIrsr5Enga82Op4cY9yS74+shYF4rxQlcQ9Ys8d9k7ZunkrV7zgaeAH4L7NSicV4FPAI8TPbhvFuTYzyErBnqYWBueh3VasezRpytdjz3Bx5M8TwKfCOV70nWf91C4OfAVi0a5+3peD4K/Ix051UrvIBJvHFXVaHj6S5HzMyskHZoqjIzsz7kxGFmZoU4cZiZWSFOHGZmVogTh5mZFeLEYW1H0jBJX8jNj5R0Q611NmNfgyQ9UMa2N4ekcflehM0ayYnD2tEw4PXEERHLIuLjNZbfHIcAvytp22YtyYnD2tF3gbek8Q++n//2LelkSb9IY2I8LekMSV9OYxPcI2mntNxbJP0mdUh5t6Se+keaDPw6X5A6u7tc0qPKxl85q9Y2Je0q6eY0lsNDkt6byr+ctvGopDNT2ThJCyT9NI37cFt6UhlJ7+zaBnB6Lp5901gRc1Nne+MbebBtAGr204t++dXoFzCOjcfseH0eOJns6dihwAjgBeDzqe4Css7+IHvKe3yaPoisa4bu9nUfsG1V2TvJekftmh9Wa5vAdbn9dgA7pG08AmwHDCHrbeDA9F7WARPS8tcDn0rTDwPvT9Pfz73nC4ET0vRgYJtm/4786t+vrk6tzAaSOyIbg2KtpBeAX6byR4D9U4+x7wV+nnUxBMCbusOWNApYHREvV1UtAvaUdCHw/8i60q+1zcOAEyHrYRV4QdIhwM0R8VLa103A+8i6AXkqIuamdecA41I/ScMiG7MEsq5DjkzTvwe+lsZhuCkinqj3QJl1x4nDBqJXc9MbcvMbyP4ntiAbn6C3YT4nA7dWF0bEc5IOAD4MfB74JHBmndusRz7+9cA2tRaOiKsl3Us2eM8tkv4mIm5vQBw2QPkah7WjtWRNUZsksnEpnpL0Cch6Nk2JoNqbrm+k5YcDW0TEjcDXyYZorbXN2cBpqbxD0g7A3cCxkrZNvSkfl8p6ivl54Pl0pgJwQi6ePYFFEfFDsl5P96/3WJh1x4nD2k5EPAv8Ll1U/v4mbuYE4NR0oXkeVcMRS+oA3hoRj841TyIAAACASURBVHWz7ijgTmWjwf2MbDCfWtv8EvABSY+QNT3tE9mwrpeTXUO5F7g0Ih7sJeZTgIvTfpUr/yTwaCrfD7iytzdvVot7xzXbBOmb/aci4vPNjsWsrzlxmJlZIW6qMjOzQpw4zMysECcOMzMrxInDzMwKceIwM7NCnDjMzKyQ/w+5mQfGQOrCkAAAAABJRU5ErkJggg==\n",
            "text/plain": [
              "<Figure size 432x288 with 1 Axes>"
            ]
          },
          "metadata": {},
          "output_type": "display_data"
        }
      ]
    },
    {
      "cell_type": "code",
      "metadata": {
        "nbpages": {
          "level": 2,
          "link": "[3.2.3 Version 1](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.3-Version-1)",
          "section": "3.2.3 Version 1"
        },
        "id": "dHttQfq3gCzj"
      },
      "source": [
        ""
      ],
      "execution_count": null,
      "outputs": []
    },
    {
      "cell_type": "code",
      "metadata": {
        "nbpages": {
          "level": 2,
          "link": "[3.2.3 Version 1](https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.html#3.2.3-Version-1)",
          "section": "3.2.3 Version 1"
        },
        "id": "1OsRMV42gCzk"
      },
      "source": [
        ""
      ],
      "execution_count": null,
      "outputs": []
    },
    {
      "cell_type": "markdown",
      "metadata": {
        "id": "1a0fbff9"
      },
      "source": [
        "<!--NAVIGATION-->\n",
        "< [3.1 Publishing an Experiment via MQTT](https://jckantor.github.io/cbe61622/03.01-Publishing_an_Experiment_via_MQTT.html) | [Contents](toc.html) | [3.3 Accessing MQTT Devices](https://jckantor.github.io/cbe61622/03.03-Miscellaneous_Notes.html) ><p><a href=\"https://colab.research.google.com/github/jckantor/cbe61622/blob/master/docs/03.02-Accessing_a_Remote_Experiment_via_MQTT.ipynb\"> <img align=\"left\" src=\"https://colab.research.google.com/assets/colab-badge.svg\" alt=\"Open in Colab\" title=\"Open in Google Colaboratory\"></a><p><a href=\"https://jckantor.github.io/cbe61622/03.02-Accessing_a_Remote_Experiment_via_MQTT.ipynb\"> <img align=\"left\" src=\"https://img.shields.io/badge/Github-Download-blue.svg\" alt=\"Download\" title=\"Download Notebook\"></a>"
      ]
    }
  ]
}