Ora che hai l'indice CategoryIndex, puoi utilizzarlo per recuperare tutti i libri di una categoria specifica. L'uso di un indice secondario per eseguire una query di una tabella è simile all'uso della chiamata API Query. Devi ora aggiungere il nome dell'indice alla chiamata API.
Quando aggiungi un indice secondario globale a una tabella esistente, DynamoDB recupera le informazioni in modo asincrono dall'indice con gli elementi presenti nella tabella. Quando tutte le informazioni sono state recuperate, l'indice è disponibile per l'esecuzione della query. Il tempo per recuperare le informazioni varia in base alle dimensioni della tabella.
Puoi utilizzare lo script query_with_index.py per eseguire la query a fronte del nuovo indice. Esegui lo script nel tuo terminale con il comando seguente.
$ python query_with_index.py
Questo comando esegue lo script seguente per recuperare tutti i libri nel negozio con Categoria 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)
Va notato che una parte dello script attende fino a quando l'indice è disponibile per l'esecuzione di query.
Dovresti visualizzare l'output seguente nel terminale.
$ 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'}
La query restituisce tre libri di due autori diversi. Questo è un modello di query che sarebbe risultato difficile con lo schema chiave principale della tabella ma che è invece facile implementare con la potenza degli indici secondari.
Nel modulo successivo, scoprirai come aggiornare gli attributi di un elemento presente in una tabella utilizzando l'API UpdateItem.