Теперь, когда у вас есть индекс CategoryIndex, вы можете использовать его для получения всех книг определенной категории. Использование вторичного индекса для совершения запросов к таблице аналогично использованию вызова API Query. Теперь добавим имя индекса в вызов 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'}
Запрос возвращает три книги двух разных авторов. Этот запрос трудно выполнить при использовании схемы основного ключа таблицы и легко – с помощью вторичных индексов.
В следующем модуле вы узнаете, как обновить атрибуты существующего в таблице элемента с помощью API UpdateItem.