py-unsserv: P2P out-of-the-box

https://badge.fury.io/py/unsserv.svg https://img.shields.io/badge/python-3.7-blue.svg https://travis-ci.com/aratz-lasa/py-unsserv.svg?branch=master https://img.shields.io/badge/code%20style-pep8-orange.svg https://img.shields.io/badge/code%20style-black-000000.svg http://www.mypy-lang.org/static/mypy_badge.svg

py-unsserv is high-level Python library, designed to offer out-of-the-box peer-to-peer (p2p) network, as well as a bunch of functionalities on top of it. These functionalities include:

  • Membership (or p2p network creation)
  • Clustering
  • Metrics aggregation
  • Nodes sampling
  • Dissemination (or broadcasting)
  • Data searching (key-value caching oriented)

Look how easy it is to setup a P2P network and broadcast some data:

import asyncio
from typing import Tuple

from unsserv import join_network, get_dissemination_service

Host = Tuple[str, int]


async def broadcaster(host: Host):
    # join p2p network
    membership = await join_network(host, "network.id")
    # initialize dissemination service
    dissemination = await get_dissemination_service(membership, "dissemination.id")
    # wait for receiver to join network
    await asyncio.sleep(1)
    # broadcast data
    for _ in range(10):
        await dissemination.broadcast(b"data.alert")
        await asyncio.sleep(1)


async def receiver(host: Host, broadcaster_host: Host):
    # wait for broadcaster to join network
    await asyncio.sleep(1)
    # join p2p network
    membership = await join_network(
        host, "network.id", bootstrap_nodes=[broadcaster_host]
    )
    # initialize dissemination service and add broadcast handler

    async def handler(data: bytes):
        print(data)

    await get_dissemination_service(
        membership, "dissemination.id", broadcast_handler=handler
    )
    # wait for broadcast
    await asyncio.sleep(10)


if __name__ == "__main__":
    broadcaster_host = ("127.0.0.1", 7771)
    receiver_host = ("127.0.0.1", 7772)

    loop = asyncio.new_event_loop()
    loop.create_task(broadcaster(broadcaster_host))
    loop.create_task(receiver(receiver_host, broadcaster_host=broadcaster_host))
    loop.run_forever()

Installation

To install py-unsserv, you just need to run the following command on your terminal:

$ pip install unsserv