Skip to content

Instantly share code, notes, and snippets.

@domadev812
Forked from stephenlb/1.py
Last active November 15, 2017 21:06
Show Gist options
  • Select an option

  • Save domadev812/b8903ffdfcd31de650b916b9e1b7334d to your computer and use it in GitHub Desktop.

Select an option

Save domadev812/b8903ffdfcd31de650b916b9e1b7334d to your computer and use it in GitHub Desktop.
topic = "user/path/topic"
from pubnub.pnconfiguration import PNConfiguration
from pubnub.pubnub import PubNub
from pubnub.callbacks import SubscribeCallback
pnconfig = PNConfiguration()
pnconfig.subscribe_key = "my_subkey"
pnconfig.publish_key = "my_pubkey"
pnconfig.ssl = False
pubnub = PubNub(pnconfig)
class MySubscribeCallback(SubscribeCallback):
def presence(self, pubnub, presence):
pass # handle incoming presence data
def status(self, pubnub, status):
def message(self, pubnub, message):
print(message)
pubnub.add_listener(MySubscribeCallback())
pubnub.subscribe().channels('my_channel')async(callback).execute()
import paho.mqtt.client as mqtt
def on_message(client, userdata, message):
print(msg.topic, str(msg.payload))
def on_connect(client, userdata, flags, rc):
client.subscribe('my_topic')
client = mqtt.Client()
client.on_message = on_message
client.on_connect = on_connect
client.connect('mqtt.pubnub.com', 1883)
client.loop_forever()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment