Skip to main content

Async library for building Ruby on Rails Action Cable clients, built on top of websockets.

Project description

aioactioncable: async Action Cable client library

PyPI license PyPI version shields.io PyPI pyversions

aioactioncable is a python library for building Ruby on Rails Action Cable clients.

The library is based on websockets and asyncio.

aioactioncable is thus an async Rails Action Cable client library.

Installation

$ python3 -m pip install aioactioncable

aioactioncable requires Python 3 and therefore needs to be installed using the Python 3 version of pip.

Requirements

Usage

In addition to managing websockets connections, Action Cable servers manage multiple channels, that clients can subscribe to.

Here is a code example to connect to an Action Cable server, subscribe to a channel and receive messages on that channel:

#!/usr/bin/env python3

import aioactioncable
import asyncio
import json

def process(msg, identifier)
  msg_json = json.loads(msg)
  print(f'Message received on {json.dumps(identifier)}')
  ...

async def ac_recv(uri, identifier):
  async with aioactioncable.connect(uri) as acconnect:
    subscription = await acconnect.subscribe(identifier)
    async for msg in subscription:
      process(msg, identifier)

asyncio.run(ac_recv('wss://example.app', {'channel': 'ChatChannel'}))

All the code examples below must be run in an asyncio event loop. Examples are built "chronologically", object created in Connect section is reused in Subscribe section, and so on.

Connect to an Action Cable server

import aioactioncable

acconnect = aioactioncable.connect(uri)

aioactioncable Connect object is an async context manager, you can thus use it in an async with statement:

import aioactioncable
import asyncio

async with aioactioncable.connect('wss://example.app') as acconnect:
  ...

Subscribe to an Action Cable channel

subscription = await acconnect.subscribe({'channel': 'ChatChannel'})

Recv messages on an Action Cable channel

Receive next message on subscription channel:

msg = await subscription.recv()

Subscription object is an iterable, you can thus iterate over to recv messages in an async for loop:

async for msg in subscription:
  ...

Send messages on an Action Cable channel

await subscription.send({'action': 'create', 'chatRoom': 'climbing'})

Unsubscribe from an Action Cable channel

await subscription.unsubscribe()

Close an Action Cable server connection

Explicit close of the connection is not needed if it is done in an async with statement.

Otherwise:

await acconnect.close()

License

aioactioncable is distributed under the MIT license.

Contributions

Contributions are very welcome!

Feel free to open an issue for any bug report.

Feel free to propose bug fixes or features via a Pull Request.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

aioactioncable-0.8.1.tar.gz (6.8 kB view details)

Uploaded Source

Built Distribution

aioactioncable-0.8.1-py3-none-any.whl (6.7 kB view details)

Uploaded Python 3

File details

Details for the file aioactioncable-0.8.1.tar.gz.

File metadata

  • Download URL: aioactioncable-0.8.1.tar.gz
  • Upload date:
  • Size: 6.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: python-requests/2.23.0

File hashes

Hashes for aioactioncable-0.8.1.tar.gz
Algorithm Hash digest
SHA256 3d38ecb571bd6d0f33bba0cddbba27125503d07136bf20950fa613067603b82e
MD5 24b5daf8e2c4c6ca7999e2f5bd3c53d3
BLAKE2b-256 1197e6ba82dc20be5d170b4126882641d226cf9307a5b697eecf049557e592a8

See more details on using hashes here.

File details

Details for the file aioactioncable-0.8.1-py3-none-any.whl.

File metadata

File hashes

Hashes for aioactioncable-0.8.1-py3-none-any.whl
Algorithm Hash digest
SHA256 f0727a25c3df5ef13f187f7e4df548c5f88598c3cf5504814945ea2471b4c173
MD5 355b2e0978532b5e1e184ac2b7dc98b2
BLAKE2b-256 4ea392fcac12232a0eafd7c747d3265c83f08c1641f819b7f3cb9bf592f95643

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page