Add API clearrediskeys
This commit is contained in:
12
main.py
12
main.py
@@ -2486,11 +2486,19 @@ async def fastapi_query_all_scheme_all_records_property(schemetype: str, schemen
|
||||
|
||||
return results
|
||||
|
||||
@app.post("/clearredis/")
|
||||
async def fastapi_clear_redis(key: str):
|
||||
@app.post("/clearrediskey/")
|
||||
async def fastapi_clear_redis_key(key: str):
|
||||
redis_client.delete(key)
|
||||
return True
|
||||
|
||||
@app.post("/clearrediskeys/")
|
||||
async def fastapi_clear_redis_keys(keys: str):
|
||||
# delete keys contains the key
|
||||
matched_keys = redis_client.keys(f"*{keys}*")
|
||||
redis_client.delete(*matched_keys)
|
||||
|
||||
return True
|
||||
|
||||
@app.post("/clearallredis/")
|
||||
async def fastapi_clear_all_redis():
|
||||
redis_client.flushdb()
|
||||
|
||||
Reference in New Issue
Block a user