pubnub_sub_example.py

import os
import sys
import logging
import time

from pubnub.callbacks import SubscribeCallback
from pubnub.pnconfiguration import PNConfiguration
from pubnub.pubnub import PubNub

d = os.path.dirname
PUBNUB_ROOT = d(d(os.path.dirname(os.path.abspath(__file__))))
sys.path.append(PUBNUB_ROOT)

import pubnub

pubnub.set_stream_logger('pubnub', logging.DEBUG, stream=sys.stdout)


class MyCallback(SubscribeCallback):
    def presence(self, pubnub, presence):
        pass

    def message(self, pubnub, message):
        print(message)

    def status(self, pubnub, status):
        pass


if __name__ == '__main__':
    pnconf = PNConfiguration()
    pnconf.subscribe_key = "demo"
    pnconf.publish_key = "demo"
    pubnub = PubNub(pnconf)

    pubnub.add_listener(MyCallback())

    pubnub.subscribe().channels("blah").execute()
    # You need to wait for any subscribe callback on you own, for ex:
    # time.sleep(1000)