Skip to main content

WAMP extension for nameko

Project description

Travis Python27 Python33 Python34 Python35 Python36

nameko wamp

Web Application Messaging Protocol (WAMP) for the nameko microservices framework

Nameko Wamp provides Extensions for WAMP PUB-SUB and RPC. Here is a (silly) example service implementing WAMP entrypoints.

from nameko_wamp.extensions.dependencies import Caller, Publisher
from nameko_wamp.extensions.entrypoints import consume, callee


class WeatherService:

    name = "weather_service"

    caller = Caller()
    publihser = Publisher()

    @callee
    def get_weather(self):
        # the weather is always sunny here!
        return "sunny"

    @consume
    def weather_updates(self, topic_data):
        # and do something with the new weather data here
        pass

One method is marked as a “callee”, which is a WAMP Role, and another is marked as a WAMP “caller” Role. The former is callable over RPC and is (almost) exactly the same as the nameko rpc Extension. The latter consumes from a WAMP Topic and appears exactly the same as the nameko event_handler Extension.

There is also the dependency injection caller. Yet another WAMP Role, this allows outgoing RPC calls from your service to other nameko services. Finally the WAMP Role publisher dependency which allows a service API to publish messages to WAMP Topics.

Wampy

Under the hood nameko wamp uses wampy as the Client Peer - and the Router Peer when running tests. The Router is Crossbar.io.

You can use a stand-alone wampy Client to interact with your nameko services too. See the wampy project for more details, but the standard pattern is:

with Client(router=router) as client:
    result = client.rpc.get_weather()
    assert result == "sunny"

    # and publish to a Topic
    client.publish(topic="foobar", message={...})

Note that when I call a remote procedure there is no reference to the service that provides it - and this is different to core nameko where a service name must be provided. This simpler behaviour is explained by the Router Peer which maintains all the registrations and subscriptions on behalf of WAMP clients implementing these Roles.

Run Tests

$ pip install --editable .[dev]
$ py.test ./test -vs

Project details


Download files

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

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distribution

nameko_wamp-0.1.1-py2.py3-none-any.whl (9.0 kB view details)

Uploaded Python 2Python 3

File details

Details for the file nameko_wamp-0.1.1-py2.py3-none-any.whl.

File metadata

File hashes

Hashes for nameko_wamp-0.1.1-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 dfc7dbb0941aeaad83a77cf0ef932e3899e2af91f04a5c14f4a4e0adcd1f7ff9
MD5 0977485496dd5a01b5608f4f6409bccc
BLAKE2b-256 dca26123fba71af420b460cdbf388f19a8ed4034e08f7aa80611baa4ffc9ddb0

See more details on using hashes here.

Supported by

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