add aio cellular test

Author: brentru

examples/minimqtt_adafruitio_cellular.py

@@ -0,0 +1,101 @@
+import time
+import board
+import busio
+import digitalio
+from adafruit_fona.adafruit_fona import FONA
+import adafruit_fona.adafruit_fona_socket as socket
+
+import adafruit_minimqtt as MQTT
+
+# Get Adafruit IO details and more from a secrets.py file
+try:
+    from secrets import secrets
+except ImportError:
+    print("GPRS secrets are kept in secrets.py, please add them there!")
+    raise
+
+### Cellular ###
+
+# Create a serial connection for the FONA connection using 4800 baud.
+# These are the defaults you should use for the FONA Shield.
+# For other boards set RX = GPS module TX, and TX = GPS module RX pins.
+uart = busio.UART(board.TX, board.RX, baudrate=4800)
+rst = digitalio.DigitalInOut(board.D4)
+
+### Feeds ###
+
+# Setup a feed named 'photocell' for publishing to a feed
+photocell_feed = secrets["aio_username"] + "/feeds/photocell"
+
+# Setup a feed named 'onoff' for subscribing to changes
+onoff_feed = secrets["aio_username"] + "/feeds/onoff"
+
+### Code ###
+
+# Define callback methods which are called when events occur
+# pylint: disable=unused-argument, redefined-outer-name
+def connected(client, userdata, flags, rc):
+    # This function will be called when the client is connected
+    # successfully to the broker.
+    print("Connected to Adafruit IO! Listening for topic changes on %s" % onoff_feed)
+    # Subscribe to all changes on the onoff_feed.
+    client.subscribe(onoff_feed)
+
+
+def disconnected(client, userdata, rc):
+    # This method is called when the client is disconnected
+    print("Disconnected from Adafruit IO!")
+
+
+def message(client, topic, message):
+    # This method is called when a topic the client is subscribed to
+    # has a new message.
+    print("New message on topic {0}: {1}".format(topic, message))
+
+
+# Connect to Cellular Network
+print("Initializing FONA (this may take a few seconds)")
+fona = FONA(uart, rst, debug=True)
+
+# Enable GPS
+fona.gps = True
+
+# Bring up cellular connection
+fona.configure_gprs((secrets["apn"], secrets["apn_username"], secrets["apn_password"]))
+
+# Bring up GPRS
+fona.gprs = True
+print("FONA initialized")
+
+# Initialize MQTT interface with the cellular interface
+MQTT.set_socket(socket, fona)
+
+# Set up a MiniMQTT Client
+# NOTE: We'll need to connect insecurely for ethernet configurations.
+mqtt_client = MQTT.MQTT(
+    broker="http://io.adafruit.com",
+    username=secrets["aio_username"],
+    password=secrets["aio_key"],
+)
+
+# Setup the callback methods above
+mqtt_client.on_connect = connected
+mqtt_client.on_disconnect = disconnected
+mqtt_client.on_message = message
+
+
+# Connect the client to the MQTT broker.
+print("Connecting to Adafruit IO...")
+mqtt_client.connect()
+
+photocell_val = 0
+while True:
+    # Poll the message queue
+    mqtt_client.loop()
+
+    # Send a new message
+    print("Sending photocell value: %d..." % photocell_val)
+    mqtt_client.publish(photocell_feed, photocell_val)
+    print("Sent!")
+    photocell_val += 1
+    time.sleep(5)