Index and query documents
Learn how to use Redis Search with JSON and hash documents.
This example shows how to create a
search index
for JSON documents and
run queries against the index. It then goes on to show the slight differences
in the equivalent code for hash
documents.
Note:
From
v6.0.0 onwards,
redis-py uses query dialect 2 by default.
Redis Search methods such as
ft().search()
will explicitly request this dialect, overriding the default set for the server.
See
Query dialects
for more information.
Initialize
Make sure that you have Redis Open Source
or another Redis server available. Also install the
redis-py client library if you
haven't already done so.
Add the following dependencies. All of them are applicable to both JSON and hash,
except for the Path class, which is specific to JSON (see
Path for a description of the
JSON path syntax).
Ctrl+Enter to run
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Create data
Create some test data to add to your database. The example data shown
below is compatible with both JSON and hash objects.
Ctrl+Enter to run
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Add the index
Connect to your Redis database. The code below shows the most
basic connection but see
Connect to the server
to learn more about the available connection options.
Ctrl+Enter to run
r = redis.Redis(decode_responses=True)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
The example uses an index called idx:users for JSON documents and adds
some JSON documents with the user: key prefix. To avoid errors, first
delete any existing index or documents whose names that might
conflict with the example:
Ctrl+Enter to run
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Create an index for the JSON data. The code below specifies that only JSON documents with
the key prefix user: are indexed. For more information, see
Query syntax.
Ctrl+Enter to run
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Add the data
Add the three sets of user data to the database as
JSON objects.
If you use keys with the user: prefix then Redis will index the
objects automatically as you add them:
Ctrl+Enter to run
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Query the data
You can now use the index to search the JSON objects. The
query
below searches for objects that have the text "Paul" in any field
and have an age value in the range 30 to 40:
Ctrl+Enter to run
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Specify query options to return only the city field:
Ctrl+Enter to run
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Use an
aggregation query
to count all users in each city.
Ctrl+Enter to run
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Differences with hash documents
Indexing for hash documents is very similar to JSON indexing but you
need to specify some slightly different options.
When you create the schema for a hash index, you don't need to
add aliases for the fields, since you use the basic names to access
the fields anyway. Also, you must use HASH for the IndexType
when you create the index.
First delete any existing index or documents
whose names might conflict with the hash example:
Ctrl+Enter to run
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
Create a new index called hash-idx:users, which is otherwise the same as
the idx:users index used for JSON documents in the previous examples:
Ctrl+Enter to run
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
You use hset() to add the hash
documents instead of json().set(),
but the same flat userX dictionaries work equally well with either
hash or JSON:
Ctrl+Enter to run
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
The query commands work the same here for hash as they do for JSON (but
the name of the hash index is different). The format of the result is
almost the same except that the fields are returned directly in the
result Document object instead of in an enclosing json dictionary:
Ctrl+Enter to run
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
"""
JSON examples from redis-py "home" page"
https://redis.io/docs/latest/develop/connect/clients/python/redis-py/#example-indexing-and-querying-json-documents
"""
import redis
from redis.commands.json.path import Path
import redis.commands.search.aggregation as aggregations
import redis.commands.search.reducers as reducers
from redis.commands.search.field import TextField, NumericField, TagField
from redis.commands.search.index_definition import IndexDefinition, IndexType
from redis.commands.search.query import Query
import redis.exceptions
user1 = {
"name": "Paul John",
"email": "[email protected]",
"age": 42,
"city": "London"
}
user2 = {
"name": "Eden Zamir",
"email": "[email protected]",
"age": 29,
"city": "Tel Aviv"
}
user3 = {
"name": "Paul Zamir",
"email": "[email protected]",
"age": 35,
"city": "Tel Aviv"
}
r = redis.Redis(decode_responses=True)
try:
r.ft("idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("user:1", "user:2", "user:3")
schema = (
TextField("$.name", as_name="name"),
TagField("$.city", as_name="city"),
NumericField("$.age", as_name="age")
)
indexCreated = r.ft("idx:users").create_index(
schema,
definition=IndexDefinition(
prefix=["user:"], index_type=IndexType.JSON
)
)
user1Set = r.json().set("user:1", Path.root_path(), user1)
user2Set = r.json().set("user:2", Path.root_path(), user2)
user3Set = r.json().set("user:3", Path.root_path(), user3)
findPaulResult = r.ft("idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulResult)
citiesResult = r.ft("idx:users").search(
Query("Paul").return_field("$.city", as_field="city")
).docs
print(citiesResult)
req = aggregations.AggregateRequest("*").group_by(
'@city', reducers.count().alias('count')
)
aggResult = r.ft("idx:users").aggregate(req).rows
print(aggResult)
try:
r.ft("hash-idx:users").dropindex(True)
except redis.exceptions.ResponseError:
pass
r.delete("huser:1", "huser:2", "huser:3")
hashSchema = (
TextField("name"),
TagField("city"),
NumericField("age")
)
hashIndexCreated = r.ft("hash-idx:users").create_index(
hashSchema,
definition=IndexDefinition(
prefix=["huser:"], index_type=IndexType.HASH
)
)
huser1Set = r.hset("huser:1", mapping=user1)
huser2Set = r.hset("huser:2", mapping=user2)
huser3Set = r.hset("huser:3", mapping=user3)
findPaulHashResult = r.ft("hash-idx:users").search(
Query("Paul @age:[30 40]")
)
print(findPaulHashResult)
See the Redis Search docs
for a full description of all query features with examples.