CategoryIndex ができましたので、これを使用して特定のカテゴリーのすべての本を取り出せます。セカンダリインデックスを使用してテーブルに対してクエリを実行するのは、Query API 呼び出しを使用するのと似ています。ここでは API 呼び出しにインデックス名を追加します。
グローバルセカンダリインデックスを既存のテーブルに追加する場合、DynamoDB では同期せずに、そのテーブルの既存の項目をインデックスに対してバックフィルします。すべての項目がバックフィルされたら、インデックスをクエリに使用することができます。バックフィルの時間はテーブルサイズよって異なります。
query_with_index.py スクリプトを使用して、新しいインデックスに対してクエリを実行できます。ターミナルで次のコマンドを使用してスクリプトを実行します。
$ python query_with_index.py
このコマンドでは次のスクリプトを実行して、サスペンスのカテゴリーに含まれるストアのすべての本を取り出します。
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'}
このクエリは 2 人の異なる著者の 3 冊の本を返します。これはテーブルの主なキースキーマでは難しかったと思われるクエリパターンですが、セカンダリインデックスの機能を利用すれば簡単に実行できます。
次のモジュールでは、UpdateItem API を使用してテーブルにすでにある項目の属性を更新する方法をご説明します。