0 purchases
redissdk 1.0.0
Khulnasoft Redis Python SDK
redis-sdk is a connectionless, HTTP-based Redis client for Python, designed to be used in serverless and serverful environments such as:
AWS Lambda
Vercel Serverless
Google Cloud Functions
and other environments where HTTP is preferred over TCP.
Inspired by other Redis clients like @khulnasoft/redis and redis-py,
the goal of this SDK is to provide a simple way to use Redis over the Khulnasoft REST API.
The SDK is currently compatible with Python 3.8 and above.
Khulnasoft Redis Python SDK
Quick Start
Install
PyPI
Usage
BITFIELD and BITFIELD_RO
Custom commands
Encoding
Retry mechanism
Contributing
Preparing the environment
Running tests
Quick Start
Install
PyPI
pip install redis-sdk
Usage
To be able to use redis-sdk, you need to create a database on Khulnasoft
and grab REDIS_SDK_REST_URL and REDIS_SDK_REST_TOKEN from the console.
# for sync client
from redis_sdk import Redis
redis = Redis(url="REDIS_SDK_REST_URL", token="REDIS_SDK_REST_TOKEN")
# for async client
from redis_sdk.asyncio import Redis
redis = Redis(url="REDIS_SDK_REST_URL", token="REDIS_SDK_REST_TOKEN")
Or, if you want to automatically load the credentials from the environment:
# for sync use
from redis_sdk import Redis
redis = Redis.from_env()
# for async use
from redis_sdk.asyncio import Redis
redis = Redis.from_env()
If you are in a serverless environment that allows it, it's recommended to initialise the client outside the request handler
to be reused while your function is still hot.
Running commands might look like this:
from redis_sdk import Redis
redis = Redis.from_env()
def main():
redis.set("a", "b")
print(redis.get("a"))
# or for async context:
from redis_sdk.asyncio import Redis
redis = Redis.from_env()
async def main():
await redis.set("a", "b")
print(await redis.get("a"))
BITFIELD and BITFIELD_RO
One particular case is represented by these two chained commands, which are available as functions that return an instance of
the BITFIELD and, respectively, BITFIELD_RO classes. Use the execute function to run the commands.
redis.bitfield("test_key") \
.incrby(encoding="i8", offset=100, increment=100) \
.overflow("SAT") \
.incrby(encoding="i8", offset=100, increment=100) \
.execute()
redis.bitfield_ro("test_key_2") \
.get(encoding="u8", offset=0) \
.get(encoding="u8", offset="#1") \
.execute()
Custom commands
If you want to run a command that hasn't been implemented, you can use the execute function of your client instance
and pass the command as a list.
redis.execute(command=["XLEN", "test_stream"])
Encoding
Although Redis can store invalid JSON data, there might be problems with the deserialization.
To avoid this, the Khulnasoft REST proxy is capable of encoding the data as base64 on the server and then sending it to the client to be
decoded.
For very large data, this can add a few milliseconds in latency. So, if you're sure that your data is valid JSON, you can set
rest_encoding to None.
Retry mechanism
redis-sdk has a fallback mechanism in case of network or API issues. By default, if a request fails it'll retry once, 3 seconds
after the error. If you want to customize that, set rest_retries and rest_retry_interval (in seconds).
Contributing
Preparing the environment
This project uses Poetry for packaging and dependency management. Make sure you are able to create the poetry shell with relevant dependencies.
You will also need a database on Khulnasoft.
Running tests
To run all the tests, make sure the poetry virtual environment activated with all
the necessary dependencies. Set the REDIS_SDK_REST_URL and REDIS_SDK_REST_TOKEN environment variables and run:
poetry run pytest
For personal and professional use. You cannot resell or redistribute these repositories in their original state.
There are no reviews.