现在您拥有了 CategoryIndex,可以用它来检索特定类别的所有图书。使用二级索引来查询表与使用 Query API 调用类似。现在,将索引名称添加到该 API 调用。
当您将某个全局二级索引添加到现有的表时,DynamoDB 会使用表中现有的项目异步回填该索引。所有项目回填完成后,该索引即可供查询。回填需要的时间取决于表的大小。
您可以使用 query_with_index.py 脚本来查询新的索引。在终端中使用以下命令运行脚本。
$ python query_with_index.py
该命令将运行以下脚本来检索店中 Category 的值为 Suspense 的所有图书。
import time
import boto3
from boto3.dynamodb.conditions import Key
# Boto3 is the AWS SDK library for Python.
# The "resources" interface allows for a higher-level abstraction than the low-level client interface.
# For more details, go to http://boto3.readthedocs.io/en/latest/guide/resources.html
dynamodb = boto3.resource('dynamodb', region_name='us-east-1')
table = dynamodb.Table('Books')
# When adding a global secondary index to an existing table, you cannot query the index until it has been backfilled.
# This portion of the script waits until the index is in the “ACTIVE” status, indicating it is ready to be queried.
while True:
if not table.global_secondary_indexes or table.global_secondary_indexes[0]['IndexStatus'] != 'ACTIVE':
print('Waiting for index to backfill...')
time.sleep(5)
table.reload()
else:
break
# When making a Query call, you use the KeyConditionExpression parameter to specify the hash key on which you want to query.
# If you want to use a specific index, you also need to pass the IndexName in our API call.
resp = table.query(
# Add the name of the index you want to use in your query.
IndexName="CategoryIndex",
KeyConditionExpression=Key('Category').eq('Suspense'),
)
print("The query returned the following items:")
for item in resp['Items']:
print(item)
请注意:脚本的一部分会等到索引可供查询时才会执行。
您应会在终端中看到以下输出。
$ python query_with_index.py
The query returned the following items:
{'Title': 'The Firm', 'Formats': {'Hardcover': 'Q7QWE3U2', 'Paperback': 'ZVZAYY4F', 'Audiobook': 'DJ9KS9NM'}, 'Author': 'John Grisham', 'Category': 'Suspense'}
{'Title': 'The Rainmaker', 'Formats': {'Hardcover': 'J4SUKVGU', 'Paperback': 'D7YF4FCX'}, 'Author': 'John Grisham', 'Category': 'Suspense'}
{'Title': 'Along Came a Spider', 'Formats': {'Hardcover': 'C9NR6RJ7', 'Paperback': '37JVGDZG', 'Audiobook': '6348WX3U'}, 'Author': 'James Patterson', 'Category': 'Suspense'}
查询将返回两名不同作者的三本图书。使用表的主键 schema 将难以实现这种查询模式,但使用二级索引则可轻松完成。
在下一模块中,您将学习如何使用 UpdateItem API 来更新表中现有项目的属性。