Skip to main content

Library to work with RPC

Project description


Server Usage

from typing import Mapping
import asyncio
import logging

from kode_rpc.method import RPCMethod, method
from kode_rpc.server import RPCServer, RPCRequestInfo

async def some_rpc_method(param: str):
    return {'result': True}

async def rpc_logger(rpc_method: RPCMethod, result: Mapping, request_info: RPCRequestInfo):'rpc_log', extra={
        'rpc_result': result,
        'trace_id': request_info.trace_id,
        'master': request_info.master

async def rpc_exception_handler(rpc_method: RPCMethod, exc: BaseException, request_info: RPCRequestInfo) -> Mapping:
    if isinstance(exc, RuntimeError):
        return {
            'error': {
                'code': 'RuntimeError',
                'trace_id': request_info.trace_id
        return {
            'error': {
                'code': 'ServerError',
                'trace_id': request_info.trace_id

async def main():

    server = RPCServer('my_service', rabbitmq_host='localhost', rabbitmq_user='guest', rabbitmq_password='guest')

    await server.register_methods([some_rpc_method])
    await server.serve()

if __name__ == '__main__':

Client Usage

import asyncio

from kode_rpc.client import RPCClient

# To access rpc_client from anywhere it must be initialized at top level module
rpc_client = RPCClient('client_name')

async def main():
    # Connect to rpc broker once at startup
    await rpc_client.connect(rabbitmq_host='localhost', rabbitmq_user='guest', rabbitmq_password='guest')

    # ...
    # Somewhere in logic
    result = await
        payload={'param': 'any'}
    # => {'result': True}

    # When application is shutting down do not forget to disconnect from rpc broker
    await rpc_client.disconnect()

if __name__ == '__main__':

Project details

Download files

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

Files for kode-rpc, version 0.0.8
Filename, size File type Python version Upload date Hashes
Filename, size kode_rpc-0.0.8-py3-none-any.whl (6.9 kB) File type Wheel Python version py3 Upload date Hashes View
Filename, size kode_rpc-0.0.8.tar.gz (5.1 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page