Async Thrift server and client
Project description
Asyncio implementation for thrift protocol, which is heavily based on thriftpy2.
Documentation: https://aiothrift.readthedocs.org/
Installation
$ pip install aiothrift
Usage example
Thrift file
service PingPong { string ping(), i64 add(1:i32 a, 2:i64 b), }
Server
import asyncio import aiothrift pingpong_thrift = aiothrift.load('pingpong.thrift', module_name='pingpong_thrift') class Dispatcher: def ping(self): return "pong" async def add(self, a, b): await asyncio.sleep(1) return a + b async def main(): server = await aiothrift.create_server(pingpong_thrift.PingPong, Dispatcher())) async with server: await server.serve_forever() asyncio.run(main())
Client
import asyncio import aiothrift pingpong_thrift = aiothrift.load('pingpong.thrift', module_name='pingpong_thrift') async def go(): conn = await aiothrift.create_connection(pingpong_thrift.PingPong) print(await conn.ping()) print(await conn.add(5, 6)) conn.close() asyncio.run(go())
Or use ConnectionPool
import asyncio import aiothrift pingpong_thrift = aiothrift.load('pingpong.thrift', module_name='pingpong_thrift') async def go(): client = await aiothrift.create_pool(pingpong_thrift.PingPong) print(await client.ping()) print(await client.add(5, 6)) client.close() await client.wait_closed() asyncio.run(go())
It’s just that simple to begin with aiothrift, and you are not forced to use aiothrift on both server and client side. So if you already have a normal thrift server setup, feel free to create an async thrift client to communicate with that server.
Requirements
- Python >= 3.7.0
- async-timeout
- thriftpy2
LICENSE
aiothrift is offered under the MIT license.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aiothrift-0.2.7.tar.gz
(12.6 kB
view hashes)
Built Distribution
aiothrift-0.2.7-py3-none-any.whl
(14.0 kB
view hashes)
Close
Hashes for aiothrift-0.2.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c239ac54a0a3413df7487c17878c13477fcdc4080f11d24774411c193ce7917c |
|
MD5 | 0bf770079915babd8b85d0a02cbb1e52 |
|
BLAKE2-256 | 9215519131b4c067e331689f8bf7ea4452208191c8730460c41fe9c943b824e5 |