Skip to main content

Web Messaging Protocol

Project description

almanet

Web Messaging Protocol is an open application level protocol that provides two messaging patterns:

  • Routed Remote Procedure Calls (RPC)
  • Produce & Consume

NSQ is a realtime distributed queue like message broker.

Almanet uses NSQ to exchange messages between different sessions.

Quick Start

Before install and run NSQD instance using this instruction.

Then install almanet PyPI package

pip install almanet

or

poetry add almanet

Create a new file and

import almanet

Create your own Microservice

Explanation of the code that defines and runs a simple microservice

Define your instance of microservice

example_service = almanet.new_service(
    "localhost:4150",
    prefix="net.example"
)

Arguments:

  • the TCP addresses of the NSQ instances
  • prefix for the service's procedures, helping in identifying and organizing them

Define your custom exception

class denied(almanet.rpc_error):
    """Custom RPC exception"""

This custom exception can be raised within procedures to signal specific error conditions to the caller.

Define your remote procedure to call

@example_service.procedure
async def greeting(
    session: almanet.Almanet,
    payload: str,
) -> str:
    """Procedure that returns greeting message"""
    if payload == "guest":
        raise denied()
    return f"Hello, {payload}!"

Decorator @example_service.procedure registers the greeting function as a remote procedure for the example_service.

Arguments:

  • payload is a data that was passed during invocation.
  • session is a joined service, instance of almanet.Almanet

It raises the custom denied exception, indicating that this payload is not allowed if payload is "guest". Otherwise, it returns a greeting message.

At the end of the file

if __name__ == "__main__":
    example_service.serve()

Starts the service, making it ready to handle incoming RPC requests.

Finally

Run your module using the python command

Call your Microservice

Explanation of the code for creating a new session, calling a remote procedure, and handling potential exceptions during the invocation.

Create a new session

session = almanet.new_session("localhost:4150")

Arguments:

  • the TCP addresses of the NSQ instances

Calling the Remote Procedure

async with session:
    result = await session.call("net.example.greeting", "Aidar")
    print(result.payload)

async with session ensures that the session is properly managed and closed after use. Calls the remote procedure net.example.greeting with the payload "Aidar". Raises TimeoutError if procedure not found or request timed out. result.payload contains the result of the procedure execution.

Catching remote procedure exceptions

async with session:
    try:
        await session.call("net.example.greeting", "guest")
    except almanet.rpc_error as e:
        print("during call net.example.greeting('guest'):", e)

The try block attempts to call the net.example.greeting procedure with the payload "guest". If an exception occurs during the call, specifically an almanet.rpc_error, it is caught by the except block.

Finally

Run your module using the python command


See the full examples in ./examples directory.

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

almanet-0.4.0.tar.gz (13.9 kB view details)

Uploaded Source

Built Distribution

almanet-0.4.0-py3-none-any.whl (16.6 kB view details)

Uploaded Python 3

File details

Details for the file almanet-0.4.0.tar.gz.

File metadata

  • Download URL: almanet-0.4.0.tar.gz
  • Upload date:
  • Size: 13.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.8.2 CPython/3.12.3 Darwin/22.6.0

File hashes

Hashes for almanet-0.4.0.tar.gz
Algorithm Hash digest
SHA256 38ef9fb334f51b93f6fd4ff802f494a4c5c56fdfcae696dc61742a086d810e7a
MD5 26eff5aefbd1e3302d6c2917ba18da97
BLAKE2b-256 4472be27c7fb5e590613bf33e4a31b424efce48c2c5cdb39702acca1581c80bf

See more details on using hashes here.

File details

Details for the file almanet-0.4.0-py3-none-any.whl.

File metadata

  • Download URL: almanet-0.4.0-py3-none-any.whl
  • Upload date:
  • Size: 16.6 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.8.2 CPython/3.12.3 Darwin/22.6.0

File hashes

Hashes for almanet-0.4.0-py3-none-any.whl
Algorithm Hash digest
SHA256 9c507ec85d3a0505aac615e9773c220e708bc629ba49d7974f4db47a854d981b
MD5 d9a1e237954ad645bb5c0aa0c33b71e4
BLAKE2b-256 7aca88301db052a52d6d0052de27f46e31bb7bc431bf68f093bfbdf1baa31985

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