CometD client for asyncio
Project description
aiocometd
aiocometd is a CometD client built using asyncio, implementing the Bayeux protocol.
CometD is a scalable WebSocket and HTTP based event and message routing bus. CometD makes use of WebSocket and HTTP push technologies known as Comet to provide low-latency data from the server to browsers and client applications.
Features
- Supported transports:
long-polling
websocket
Automatic reconnection after network failures
Extensions
Usage
import asyncio
from aiocometd import Client
async def chat():
nickname = "John"
# connect to the server
async with Client("http://example.com/cometd") as client:
# subscribe to channels to receive chat messages and
# notifications about new members
await client.subscribe("/chat/demo")
await client.subscribe("/members/demo")
# send initial message
await client.publish("/chat/demo", {
"user": nickname,
"membership": "join",
"chat": nickname + " has joined"
})
# add the user to the chat room's members
await client.publish("/service/members", {
"user": nickname,
"room": "/chat/demo"
})
# listen for incoming messages
async for message in client:
if message["channel"] == "/chat/demo":
data = message["data"]
print(f"{data['user']}: {data['chat']}")
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(chat())
Changelog
0.2.3 (2018-04-24)
Fix RST rendering issues
0.2.2 (2018-04-24)
Fix documentation typos
Improve examples
Reorganise documentation
0.2.1 (2018-04-21)
Add PyPI badge to README
0.2.0 (2018-04-21)
- Supported transports:
long-polling
websocket
Automatic reconnection after network failures
Extensions
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.
Source Distribution
aiocometd-0.2.3.tar.gz
(45.4 kB
view hashes)
Built Distribution
aiocometd-0.2.3-py3-none-any.whl
(22.7 kB
view hashes)
Close
Hashes for aiocometd-0.2.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | d136c2a39a7e4fe3c22971625d7616187b822fc55651bf2dbcc6341d34cec062 |
|
MD5 | 6727342e3ef23ffc0fd5828f6e0c9d22 |
|
BLAKE2b-256 | 12189d91e2cb5656ee79700e540355459029573820a7b8c675de3197ab738e6e |