aiomsa 0.1.0a3

Asynchronous xApp framework

aiomsa

aiomsa is a Python 3.7+ framework built using asyncio. At its core, aiomsa provides a simple and standardized way to write xApps that can be deployed as microservices in Python.

Installation

aiomsa can be installed from PyPI.

pip install aiomsa

You can also get the latest code from GitHub.

poetry add git+https://github.com/facebookexternal/aiomsa

Getting Started

The follwing example shows how to use aiomsa to create a simple xApp for subscribing to the E2T service for a particular custom service model.

from aiomsa import init
from aiomsa.e2 import E2Client

from .models import MyModel


async def main():
   with E2Client(
      app_id="my_app", e2t_endpoint="e2t:5150", e2sub_endpoint="e2sub:5150"
   ) as e2:
      conns = await e2.list_nodes()
      subscription = await e2.subscribe(
         e2_node_id=conns[0],
         service_model_name="my_model",
         service_model_version="v1",
         trigger=bytes(MyModel(param="foo")),
      )

      async for msg in subscription:
         print(msg)


if __name__ == "__main__":
   init(lambda: main())