.. image:: https://badge.fury.io/py/aiocometd.svg :target: https://badge.fury.io/py/aiocometd :alt: PyPI package
.. image:: https://readthedocs.org/projects/aiocometd/badge/?version=latest :target: http://aiocometd.readthedocs.io/en/latest/?badge=latest :alt: Documentation Status
.. image:: https://travis-ci.org/robertmrk/aiocometd.svg?branch=develop :target: https://travis-ci.org/robertmrk/aiocometd :alt: Build status
.. image:: https://coveralls.io/repos/github/robertmrk/aiocometd/badge.svg :target: https://coveralls.io/github/robertmrk/aiocometd :alt: Coverage
.. image:: https://img.shields.io/badge/License-MIT-yellow.svg :target: https://opensource.org/licenses/MIT :alt: MIT license
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.
long-pollingwebsocket.. code-block:: python
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())
For more detailed usage examples take a look at the
command line chat example <cli_example_>_ or for a more complex example with
a GUI check out the aiocometd-chat-demo_.
https://aiocometd.readthedocs.io/
.. _aiohttp: https://github.com/aio-libs/aiohttp/ .. _CometD: https://cometd.org/ .. _Comet: https://en.wikipedia.org/wiki/Comet_(programming) .. _asyncio: https://docs.python.org/3/library/asyncio.html .. _Bayeux: https://docs.cometd.org/current/reference/#_bayeux .. _ext: https://docs.cometd.org/current/reference/#_bayeux_ext .. _cli_example: https://github.com/robertmrk/aiocometd/blob/develop/examples/chat.py .. _aiocometd-chat-demo: https://github.com/robertmrk/aiocometd-chat-demo
long-pollingwebsocketFAQs
CometD client for asyncio
We found that aiocometd demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 1 open source maintainer collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
Fluent Assertions is facing backlash after dropping the Apache license for a commercial model, leaving users blindsided and questioning contributor rights.
Research
Security News
Socket researchers uncover the risks of a malicious Python package targeting Discord developers.
Security News
The UK is proposing a bold ban on ransomware payments by public entities to disrupt cybercrime, protect critical services, and lead global cybersecurity efforts.