thriftpy2

import asyncio import thriftpy2 from thriftpy2.rpc import make_aio_client import os # Define a simple Thrift service IDL in a temporary file THRIFT_FILE_PATH = "pingpong.thrift" with open(THRIFT_FILE_PATH, "w") as f: f.write("service PingPong {\n string ping(),\n}") # Load the thrift file dynamically pingpong_thrift = thriftpy2.load(THRIFT_FILE_PATH, module_name="pingpong_thrift") async def main(): print("Attempting to create ThriftPy2 async client...") client = None try: # For this quickstart, we'll demonstrate client instantiation and a call pattern. # Note: This client will attempt to connect to '127.0.0.1:6000'. # A running ThriftPy2 server on this address would be required for a successful RPC call. # This example focuses on demonstrating the client API, not a full RPC pair. client = await make_aio_client( pingpong_thrift.PingPong, '127.0.0.1', 6000, timeout=1000 # Milliseconds for connection/read timeout ) print("Client created. Attempting to call ping()... (This will likely fail without a running server)") # Example of calling a service method # result = await client.ping() # print(f"Ping result: {result}") except Exception as e: print(f"Error setting up client (expected if no server is running at 127.0.0.1:6000): {e}") finally: if client: client.close() # Clean up the dummy thrift file if os.path.exists(THRIFT_FILE_PATH): os.remove(THRIFT_FILE_PATH) if __name__ == '__main__': asyncio.run(main())