diff options
author | shacharPash <93581407+shacharPash@users.noreply.github.com> | 2023-05-16 13:52:09 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-05-16 13:52:09 +0300 |
commit | 2d9b5ac6fe03fdc572b8ca47f7134082bae2a5e2 (patch) | |
tree | a0780069a09c8ce427d9e3676a6f33d07b3d95aa /redis | |
parent | 35b7e09a57a1b7e2931d90e4b13858b68cee97cf (diff) | |
download | redis-py-master.tar.gz |
* 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')
-rw-r--r-- | redis/commands/json/__init__.py | 1 | ||||
-rw-r--r-- | redis/commands/json/commands.py | 22 |
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, |