listen.py

# subscribe to your PubNub channel using this code
# SwitchDoc Labs May, 2017
# updated for PubNub 4.02 code

import pubnub
import logging; 
logging.basicConfig(level=logging.INFO) 


from pubnub.pnconfiguration import PNConfiguration
from pubnub.pubnub import PubNub, SubscribeListener, SubscribeCallback, PNOperationType, PNStatusCategory


# Check for user imports
try:
            import conflocal as config
except ImportError:
            import config


# configuration
Pubnub_Publish_Key = config.Pubnub_Publish_Key
Pubnub_Subscribe_Key = config.Pubnub_Subscribe_Key 

pnconf = PNConfiguration()

pnconf.subscribe_key = Pubnub_Subscribe_Key
pnconf.publish_key = Pubnub_Publish_Key

pubnub = PubNub(pnconf)

class MySubscribeCallback(SubscribeCallback):
    def status(self, pubnub, status):
        pass
        # The status object returned is always related to subscribe but could contain
        # information about subscribe, heartbeat, or errors
        # use the operationType to switch on different options
        if status.operation == PNOperationType.PNSubscribeOperation or status.operation == PNOperationType.PNUnsubscribeOperation:
            if status.category == PNStatusCategory.PNConnectedCategory:
                                pass
                # This is expected for a subscribe, this means there is no error or issue whatsoever
            elif status.category == PNStatusCategory.PNReconnectedCategory:
                                pass
                # This usually occurs if subscribe temporarily fails but reconnects. This means
                # there was an error but there is no longer any issue
            elif status.category == PNStatusCategory.PNDisconnectedCategory:
                                pass
                # This is the expected category for an unsubscribe. This means there
                # was no error in unsubscribing from everything
            elif status.category == PNStatusCategory.PNUnexpectedDisconnectCategory:
                                pass
                # This is usually an issue with the internet connection, this is an error, handle
                # appropriately retry will be called automatically
            elif status.category == PNStatusCategory.PNAccessDeniedCategory:
                                pass
                # This means that PAM does allow this client to subscribe to this
                # channel and channel group configuration. This is another explicit error
            else:
                                pass
                # This is usually an issue with the internet connection, this is an error, handle appropriately
                # retry will be called automatically
        elif status.operation == PNOperationType.PNSubscribeOperation:
                        # Heartbeat operations can in fact have errors, so it is important to check first for an error.
            # For more information on how to configure heartbeat notifications through the status
            # PNObjectEventListener callback, consult <link to the PNCONFIGURATION heartbeart config>
            if status.is_error():
                                pass
                # There was an error with the heartbeat operation, handle here
            else:
                                pass
                # Heartbeat operation was successful
        else:
                        pass
            # Encountered unknown status type
 
    def presence(self, pubnub, presence):
                pass  # handle incoming presence data
 
    def message(self, pubnub, message):
                print "incoming message", message.message  # handle incoming messages



channel = "SmartPlantPi_Data"

def callback(message, channel):
    print('[' + channel + ']: ' + str(message))

pubnub.add_listener(MySubscribeCallback())
pubnub.subscribe().channels(channel).execute()