pysher_pusher_channel_subscribe_and_event_handler.py

1import pysher
2import sys
3import time
4
5# Add a logging handler to see what's going on
6import logging
7root = logging.getLogger()
8root.setLevel(logging.INFO)
9ch = logging.StreamHandler(sys.stdout)
10root.addHandler(ch)
11
12pusher = pysher.Pusher("APP_KEY", "APP_CLUSTER")
13
14def print_usage_info(data):
15    print("Event received with data: %s" % data)
16
17def connect_handler(data):
18    channel = pusher.subscribe('test_channel')
19    channel.bind('test_event', print_usage_info)
20
21pusher.connection.bind('pusher:connection_established', connect_handler)
22pusher.connect()
23
24while True:
25    time.sleep(1)