Agora que você tem CategoryIndex, pode usá-lo para recuperar todos os livros com uma categoria específica. O processo de usar um índice secundário para consultar uma tabela é semelhante ao de usar a chamada de APIQuery. Agora, você adiciona o nome do índice à chamada de API.
Quando um índice secundário global é adicionado a uma tabela existente, o DynamoDB preenche assincronamente esse índice com os itens existentes na tabela. O índice estará disponível para consulta após o preenchimento de todos os itens. O tempo de preenchimento varia de acordo com o tamanho da tabela.
É possível usar o script query_with_index.py para consultar o novo índice. Execute o script com o seguinte comando no terminal.
$ python query_with_index.py
Esse comando executa o script a seguir para recuperar todos os livros em que Category é igual a 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)
Observe que há uma parte do script que aguarda até que o índice esteja disponível para consulta.
A seguinte saída será exibida no terminal:
$ 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'}
A consulta retorna três livros de dois autores diferentes. Esse é um padrão de consulta que teria sido difícil com o esquema de chaves principal da sua tabela, mas que é fácil de implementar com o poder dos índices secundários.
No próximo módulo, você aprenderá a atualizar os atributos de um item existente em uma tabela usando a API UpdateItem .