summaryrefslogtreecommitdiff
path: root/redis/commands
diff options
context:
space:
mode:
authorshacharPash <93581407+shacharPash@users.noreply.github.com>2023-05-16 13:52:09 +0300
committerGitHub <noreply@github.com>2023-05-16 13:52:09 +0300
commit2d9b5ac6fe03fdc572b8ca47f7134082bae2a5e2 (patch)
treea0780069a09c8ce427d9e3676a6f33d07b3d95aa /redis/commands
parent35b7e09a57a1b7e2931d90e4b13858b68cee97cf (diff)
downloadredis-py-2d9b5ac6fe03fdc572b8ca47f7134082bae2a5e2.tar.gz
support JSON.MERGE Command (#2761)HEADmaster
* support JSON.MERGE Command * linters * try with abc instead person * change @skip_ifmodversion_lt to latest ReJSON 2.4.7 * change version * fix test * linters * add async test
Diffstat (limited to 'redis/commands')
-rw-r--r--redis/commands/json/__init__.py1
-rw-r--r--redis/commands/json/commands.py22
2 files changed, 23 insertions, 0 deletions
diff --git a/redis/commands/json/__init__.py b/redis/commands/json/__init__.py
index 7d55023..77fb21c 100644
--- a/redis/commands/json/__init__.py
+++ b/redis/commands/json/__init__.py
@@ -38,6 +38,7 @@ class JSON(JSONCommands):
"JSON.GET": self._decode,
"JSON.MGET": bulk_of_jsons(self._decode),
"JSON.SET": lambda r: r and nativestr(r) == "OK",
+ "JSON.MERGE": lambda r: r and nativestr(r) == "OK",
"JSON.NUMINCRBY": self._decode,
"JSON.NUMMULTBY": self._decode,
"JSON.TOGGLE": self._decode,
diff --git a/redis/commands/json/commands.py b/redis/commands/json/commands.py
index c02c47a..5da9245 100644
--- a/redis/commands/json/commands.py
+++ b/redis/commands/json/commands.py
@@ -253,6 +253,28 @@ class JSONCommands:
pieces.append("XX")
return self.execute_command("JSON.SET", *pieces)
+ def merge(
+ self,
+ name: str,
+ path: str,
+ obj: JsonType,
+ decode_keys: Optional[bool] = False,
+ ) -> Optional[str]:
+ """
+ Sets or updates the JSON value at a path..
+
+ ``decode_keys`` If set to True, the keys of ``obj`` will be decoded
+ with utf-8.
+
+ For more information see `JSON.MERGE <https://redis.io/commands/json.merge>`_.
+ """
+ if decode_keys:
+ obj = decode_dict_keys(obj)
+
+ pieces = [name, str(path), self._encode(obj)]
+
+ return self.execute_command("JSON.MERGE", *pieces)
+
def set_file(
self,
name: str,