ReductStore Client SDK for Python¶
This package provides an asynchronous HTTP client for interacting with the ReductStore service.
- Supports the ReductStore HTTP API v1.4
- Bucket management
- API Token management
- Write, read and query data
- Subscription on new data
To install this package, run the following command:
pip install reduct-py
Here is an example of how to use this package to create a bucket, write data to it, and read data from it:
import time import asyncio from reduct import Client, Bucket async def main(): # Create a client for interacting with a ReductStore service client = Client("http://localhost:80383") # Create a bucket and store a reference to it in the `bucket` variable bucket: Bucket = await client.create_bucket("my-bucket", exist_ok=True) # Write data to the bucket ts = time.time_ns() / 1000 await bucket.write("entry-1", b"Hey!!", ts) # Read data from the bucket async with bucket.read("entry-1", ts) as record: data = await record.read_all() print(data) # Run the main function loop = asyncio.get_event_loop() loop.run_until_complete(main())
For more examples, see the Quick Start.