aiomas 2.0.1

aioma–一个用于多代理系统和基于异步的rpc的库

aiomas是一个易于使用的库，用于request-reply channels，remote 过程调用（rpc）和multi-agent systems（mas）。是用纯文字写的 Python在asyncio上面。

下面是三个简单的例子，展示了aioma的不同层次和 它们相互补充的内容：

request-reply通道的抽象级别最低（但已经 提供比普通异步更多的功能：

>>>importaiomas>>>>>>>>>asyncdefhandle_client(channel):..."""Handle a client connection."""...req=awaitchannel.recv()...print(req.content)...awaitreq.reply('cya')...awaitchannel.close()>>>>>>>>>asyncdefclient():..."""Client coroutine: Send a greeting to the server and wait for a
...     reply."""...channel=awaitaiomas.channel.open_connection(('localhost',5555))...rep=awaitchannel.send('ohai')...print(rep)...awaitchannel.close()>>>>>>>>>server=aiomas.run(aiomas.channel.start_server(('localhost',5555),handle_client))>>>aiomas.run(client())ohaicya>>>server.close()>>>aiomas.run(server.wait_closed())

rpc层在其上添加远程过程调用：

>>>importaiomas>>>>>>>>>classMathServer:...router=aiomas.rpc.Service()......@router.expose...defadd(self,a,b):...returna+b...>>>>>>asyncdefclient():..."""Client coroutine: Call the server's "add()" method."""...rpc_con=awaitaiomas.rpc.open_connection(('localhost',5555))...rep=awaitrpc_con.remote.add(3,4)...print('What’s 3 + 4?',rep)...awaitrpc_con.close()>>>>>>server=aiomas.run(aiomas.rpc.start_server(('localhost',5555),MathServer()))>>>aiomas.run(client())What’s3+4?7>>>server.close()>>>aiomas.run(server.wait_closed())

最后，agent层隐藏了设置所需的一些样板代码 套接字并允许代理实例轻松地相互通信：

>>>importaiomas>>>>>>classTestAgent(aiomas.Agent):...def__init__(self,container):...super().__init__(container)...print('Ohai, I am %s'%self)......asyncdefrun(self,addr):...remote_agent=awaitself.container.connect(addr)...ret=awaitremote_agent.service(42)...print('%s got %s from %s'%(self,ret,remote_agent))......@aiomas.expose...defservice(self,value):...returnvalue>>>>>>c=aiomas.Container.create(('localhost',5555))>>>agents=[TestAgent(c)foriinrange(2)]Ohai,IamTestAgent('tcp://localhost:5555/0')Ohai,IamTestAgent('tcp://localhost:5555/1')>>>aiomas.run(until=agents[0].run(agents[1].addr))TestAgent('tcp://localhost:5555/0')got42fromTestAgentProxy('tcp://localhost:5555/1')>>>c.shutdown()

aiomas根据mit许可证发布。它需要Python3.4及更高版本 在Linux、OS X和Windows上运行。

$ pip install aiomas

$ pip install aiomas[mp]# Enables the MsgPack codec
$ pip install aiomas[mpb]# Enables the MsgPack and MsgPackBlosc codecs

$ virtualenv -p `which python3` aiomas
$ pip install -r requirements-setup.txt

$ pytest
$ # or
$ tox

更改日志

作者

《爱奥玛》的原著作者是斯特凡·舍尔夫。

最初的开发得到了OFFIS的支持。