Asyncio Pusher Channels Client
Project description
PysherAsync
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.
Installation
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
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()
Performance
PysherAsync relies on websockets which is one of the most efficient implementations on python.
Thanks
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.
Copyright
MTI License - See LICENSE for details.
Changelog
Version 0.2
Fix
- Bug fix for disconnect, added missing await
Version 0.1
New
- First Working Version
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size pysherasync-0.2-py3-none-any.whl (5.1 kB) | File type Wheel | Python version py3 | Upload date | Hashes View |
Filename, size pysherasync-0.2.tar.gz (4.8 kB) | File type Source | Python version None | Upload date | Hashes View |
Hashes for pysherasync-0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7580a739f470b496ad6442118844ecd3e63db920d6f5bfef4b24c73bfabdaead |
|
MD5 | 369a69202749210c2492f671f52a988c |
|
BLAKE2-256 | ba8d7fbc7a565d36730f3a00fe0296e4a365c043d639f6b3ee95a3e37de2d1f0 |