Asyncio Pusher Channels Client
pysherasync is a python module for handling Pusher Channels. It is based on @ekulyk's
PythonPusherClient and @nlsdfnbch
Pysher. This is a re-implementation of the project
to use more efficient asynchronous logic and more efficient websockets. A key difference is the dropped support for pre-3.5 Python versions.
This is also currently a very minimalistic implementation and may be missing some components, please submit an issue and let me know if you run into any problems.
Simply clone the project and run
python setup.py install - or install via pip
pip install pysherasync.
This module depends on websockets module available from: https://github.com/aaugustin/websockets
Example of using this pusher client to consume websockets:
import pysherasync async def bitstamp_ob_subscription(loop): global loop # This is your app key, currently set to https://www.bitstamp.net/websocket/ appkey = "de504dc5763aeef9ff52" # Create an instance of PusherAsyncClient and pass it the appkey pusherclient = pysherasync.PusherAsyncClient(appkey) # Connect to websocket pushersocket = await pusherclient.connect() # Subscribe to channel status = await pusherclient.subscribe(channel_name='order_book') print("Subscription Status: %s"%(status)) while True: ## This is because re-connection logic is not implemented yet if not pushersocket.open: # on disconnections, reconnect print("Connection reconnecting") # re-connect pushersocket = await pusherclient.connect() # re-subscribe status = await pusherclient.subscribe(channel_name='order_book') print("Subscription Status: %s"%(status)) try: # wait for msg msg = await asyncio.wait_for(pushersocket.recv(), 5) # parse to json msg = json.loads(msg) # print the msg if msg: print(msg) except asyncio.TimeoutError: print("asyncio timeout while waiting for ws msg") except Exception as e: print(e) if __name__ == "__main__": loop = asyncio.new_event_loop() asyncio.set_event_loop(loop) loop.run_until_complete(bitstamp_ob_subscription(loop)) loop.close()
PysherAsync relies on websockets which is one of the most efficient implementations on python.
A big thanks to @ekulyk for developing the PythonPusherClient library.
A big thanks to @nlsdfnbch for developing the Pysher library.
A big thanks to @aaugustin for developing the WebSockets library.
MTI License - See LICENSE for details.
- First Working Version
Release history Release notifications | RSS feed
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Hashes for pysherasync-0.1-py3-none-any.whl