adafruit-mirror/Adafruit_IO_Python
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

group sub example -> pub AND sub example

Browse source
This commit is contained in:
brentru 2018-09-05 13:03:06 -04:00
parent 54f8790ed4
commit 8fcc5a5698
1 changed files with 31 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
examples/mqtt/mqtt_group_subscribe.py → examples/mqtt/mqtt_groups_pusbsub.py
View file

@ -1,5 +1,7 @@
# Example of using the MQTT client class to subscribe to and publish feed values. # Example of subscribing to an Adafruit IO group
# Author: Tony DiCola # and publishing to the feeds within it
# Author: Brent Rubell for Adafruit Industries, 2018
# Import standard python modules. # Import standard python modules.
import random import random
@ -18,17 +20,21 @@ ADAFRUIT_IO_KEY = 'YOUR_AIO_KEY'
# (go to https://accounts.adafruit.com to find your username) # (go to https://accounts.adafruit.com to find your username)
ADAFRUIT_IO_USERNAME = 'YOUR_AIO_USERNAME' ADAFRUIT_IO_USERNAME = 'YOUR_AIO_USERNAME'
# name of the group to subscribe to changes on # Group Name
group_name = 'grouptest' group_name = 'grouptest'
# Feeds within the group
group_feed_one = 'one'
group_feed_two = 'two'
# Define callback functions which will be called when certain events happen. # Define callback functions which will be called when certain events happen.
def connected(client): def connected(client):
# Connected function will be called when the client is connected to Adafruit IO. # Connected function will be called when the client is connected to Adafruit IO.
# This is a good place to subscribe to feed changes. The client parameter # This is a good place to subscribe to topic changes. The client parameter
# passed to this function is the Adafruit IO MQTT client so you can make # passed to this function is the Adafruit IO MQTT client so you can make
# calls against it easily. # calls against it easily.
# Subscribe to changes on a group_id. print('Listening for changes on ', group_name)
print('Subscribing to ', group_name) # Subscribe to changes on a group, `group_name`
client.subscribe_group(group_name) client.subscribe_group(group_name)
def disconnected(client): def disconnected(client):
@ -40,7 +46,7 @@ def message(client, topic_id, payload):
# Message function will be called when a subscribed topic has a new value. # Message function will be called when a subscribed topic has a new value.
# The topic_id parameter identifies the topic, and the payload parameter has # The topic_id parameter identifies the topic, and the payload parameter has
# the new value. # the new value.
print('{0} received new value: {1}'.format(topic_id, payload)) print('Topic {0} received new value: {1}'.format(topic_id, payload))
# Create an MQTT client instance. # Create an MQTT client instance.
@ -54,5 +60,21 @@ client.on_message = message
# Connect to the Adafruit IO server. # Connect to the Adafruit IO server.
client.connect() client.connect()
# Run a message loop forever to listen # Now the program needs to use a client loop function to ensure messages are
client.loop_blocking() # sent and received. There are a few options for driving the message loop,
# depending on what your program needs to do.
# The first option is to run a thread in the background so you can continue
# doing things in your program.
client.loop_background()
# Now send new values every 5 seconds.
print('Publishing a new message every 5 seconds (press Ctrl-C to quit)...')
while True:
value = random.randint(0, 100)
print('Publishing {0} to {1}.{2}.'.format(value, group_name, group_feed_one))
client.publish('one', value, group_name)
value = random.randint(0,100)
print('Publishing {0} to {1}.{2}.'.format(value, group_name, group_feed_two))
client.publish('two', value, group_name)
time.sleep(5)