Spaces:
Running
on
Zero
Running
on
Zero
File size: 1,130 Bytes
a42ebba |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
from .config import REDIS_URL
import redis
import json
class SaveToRedis:
@classmethod
def INPUT_TYPES(s):
return {
"required": {
"key": ("STRING", {"multiline": False}),
"data": ("JSON",)
},
}
RETURN_TYPES = ()
FUNCTION = "main"
OUTPUT_NODE = True
CATEGORY = "database_ops"
def main(self, key: str, data: dict):
connection = redis.Redis.from_url(REDIS_URL)
connection.set(key, json.dumps(data))
connection.close()
return ()
class FetchFromRedis:
@classmethod
def INPUT_TYPES(s):
return {
"required": {
"key": ("STRING", {"multiline": False})
},
}
RETURN_TYPES = ("JSON",)
FUNCTION = "main"
OUTPUT_NODE = True
CATEGORY = "database_ops"
def main(self, key: str):
connection = redis.Redis.from_url(REDIS_URL)
data = connection.get(key)
if data is None:
return {}
else:
data = json.loads(data)
return [data]
|