Über diesen Artikel

Neulich habe ich Code geschrieben, um Dynamo DB unter AWS mit Python zu betreiben. Zur Erinnerung werde ich das damalige Basisskript und die Idee zusammenfassen, die Dynamo DB eigen ist. Es ist nicht erschöpfend, aber ich werde das Minimum plus Alpha erwähnen. Ich hoffe es hilft Fremden.

Informationen zu Dynamo DB

Keine von AWS bereitgestellte SQL-Datenbank.
Amazon DynamoDB (verwaltete NoSQL-Datenbank) | AWS
Schnell in Form von Schlüsselwert. --JSON kann auch als Wert gespeichert werden, ist jedoch kein Objekttyp DB.
Aus Gründen der Konsistenz der Ergebnisse ist der aktualisierte Inhalt möglicherweise nicht rechtzeitig, wenn er unmittelbar nach dem Update gelesen wird (Achtung!)

Aufbau einer Python-Umgebung

Verwenden Sie wie gewohnt Boto3, das SDK von AWS für Python.
- AWS SDK for Python (Boto3)
Bei der Entwicklung auf einem lokalen Computer muss der AWS-Zugriffsschlüssel abgerufen und die Anmeldeinformationen in der AWS-CLI im Voraus festgelegt werden.
Einrichtung von DynamoDB (Webdienst) - Amazon DynamoDB
Bei Verwendung von Cloud9 müssen auch die Authentifizierungsinformationen festgelegt werden. Beachten Sie, dass Sie später Probleme bekommen, wenn Sie die temporären Anmeldeinformationen in Ihren Einstellungen nicht deaktivieren. (Ich werde einen Artikel schreiben, wenn ich eine Chance habe.)

Mit welcher Klasse soll ich Dynamo DB betreiben?

DynamoDB — Boto3 Docs documentation

Zunaechst...

Für Boto3 hauptsächlich Ressourcenklasse und [Client] für die Arbeit mit Dynamo DB Es gibt zwei Klassen](https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb.html#client), je nachdem, welche Klasse Sie zum Hinzufügen von Elementen zur Tabelle verwenden. Und Suche ist möglich. ――Ich kann nicht viel sagen, weil ich damit nicht vertraut bin, aber wenn ich auf die folgende Site verweise, heißt es, dass "Client-Klasse weniger abstrakt ist".
[Geschichte, als AWS Chalice die erforderliche IAM-Richtlinie nicht korrekt erstellt hat](https://michimani.net/post/aws-about-auto-generate-iam-policy-in-chalice/#awc-chalice -% e3% 81% ae% e3% 82% bd% e3% 83% bc% e3% 82% b9% e3% 82% b3% e3% 83% bc% e3% 83% 89% e8% a7% a3% e6% 9e% 90% e3% 81% af-client-class-% e3% 81% a7% e3% 81% ae% e5% ae% 9f% e8% a3% 85% e6% 99% 82% e3% 81 % ae% e3% 81% bf% e6% 9c% 89% e5% 8a% b9)
Um einen Punkt hinzuzufügen, heißt es auf der obigen Site, dass Chalice (* AWS Serverless Framework für Python) beim Schreiben von Code in der Client-Klasse automatisch die erforderliche IAM-Richtlinie generieren kann, in meiner Umgebung jedoch die Client-Klasse Es wurde aber nicht automatisch generiert. (* Dies ist eine Geschichte nur bei Verwendung von Kelch.)

So erstellen Sie eine Instanz in der Ressourcenklasse

Eindruck, dass Ressourcenklasse einfacher zu implementieren ist.

import boto3

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('name')

So erstellen Sie eine Instanz in der Client-Klasse

Die Client-Klasse deckt die meisten APIs für jeden Dienst ab und ist "grundlegend". Eindruck

import boto3

client = boto3.client('dynamodb')
#Der Tabellenname wird beim Betrieb der Tabelle angegeben.

Skript-Memo

―― Da es sich zum Zeitpunkt der persönlichen Überprüfung um ein Memo handelt, wie weit wird es für Ihre Referenz sein ...

Tabellendefinition / Inhalt

Enthält Stationsinformationen (Präfektur- und Koordinateninformationen).
Setzen Sie die Präfektur als Partitionsschlüssel und die ID als Sortierschlüssel als Primärschlüssel.
Der Primärschlüssel (Hinweis: Partitionsschlüssel und Sortierschlüssel) und die Attribute sind alle Zeichentypen.
"Hinweis! 》 In diesem Artikel werden japanische Zeichenfolgen für den Partitionsschlüssel verwendet. Dies dient jedoch nur der Erläuterung. ――Ich denke, es ist üblich, alphanumerische Zeichenfolgen und Zahlenzeichenfolgen zu verwenden.

Allgemeiner Teilecode (unter Verwendung der Ressourcenklasse)

import boto3
from boto3.dynamodb.conditions import Key, Attr

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('table_name')

put_item

Beschreiben Sie das Element, das Sie in Element im Wörterbuchtyp hinzufügen möchten.
Der Inhalt des Primärschlüssels ist erforderlich. Attribut ist beliebig
Das heißt, wenn sowohl der Partitionsschlüssel als auch der Sortierschlüssel als Primärschlüssel festgelegt sind, müssen sowohl der Partitionsschlüssel als auch der Sortierschlüssel unter Element beschrieben werden. Wenn nur eine beschrieben wird, tritt ein Fehler auf. --Key --Werttyp DB, sodass keine Attribute an anderen Elementen ausgerichtet werden müssen.
Im folgenden Beispiel gibt es kein Problem, obwohl die Koordinateninformationen usw. nicht in Artikel beschrieben sind. Es ist nicht als null registriert.

response = table.put_item(
    Item = {
        'prefecture':'Iwate',
        'id':'5',
        'stationName':'Morioka'
    }
)

print(response)
# {'ResponseMetadata': {'RequestId': 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789ABCDEFGHIJKLMNO', 'HTTPStatusCode': 200, 'HTTPHeaders': {'server': 'Server', 'date': 'Mon, 28 Sep 2020 14:24:47 GMT', 'content-type': 'application/x-amz-json-1.0', 'content-length': '2', 'connection': 'keep-alive', 'x-amzn-requestid': 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789ABCDEFGHIJKLMNO', 'x-amz-crc32': '2745614147'}, 'RetryAttempts': 0}}

Artikelaktualisierung mit put_item

Wenn in der Tabelle bereits ein Element mit demselben Primärschlüssel vorhanden ist, wird das Element aktualisiert.
Zu diesem Zeitpunkt werden alle Attribute überschrieben.

response = table.put_item(
    Item = {
        'prefecture':'Hokkaido',
        'id':'13',
        'stationName':'Himekawa (aktualisiert)',
        'hoge': 'fuga'
    }
)

print(response)
# {'ResponseMetadata': {'RequestId': 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789ABCDEFGHIJKLMNO', 'HTTPStatusCode': 200, 'HTTPHeaders': {'server': 'Server', 'date': 'Mon, 28 Sep 2020 15:02:47 GMT', 'content-type': 'application/x-amz-json-1.0', 'content-length': '2', 'connection': 'keep-alive', 'x-amzn-requestid': 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789ABCDEFGHIJKLMNO', 'x-amz-crc32': '2745614147'}, 'RetryAttempts': 0}}

get_item

Wenn Sie nur den Partitionsschlüssel als Primärschlüssel festgelegt haben, setzen Sie den Partitionsschlüssel auf Schlüssel.
Wenn Sie sowohl den Partitionsschlüssel als auch den Sortierschlüssel als Primärschlüssel festgelegt haben, setzen Sie sowohl den Partitionsschlüssel als auch den Sortierschlüssel auf Schlüssel. (Beispielcode ist dieses Muster)
In diesem Fall können Sie nicht nur nach dem Partitionsschlüssel suchen.
Wenn Sie nur nach dem Partitionsschlüssel suchen möchten, verwenden Sie die später beschriebene Abfragemethode.

response = table.get_item(
    Key={
        'prefecture':'Hokkaido',
        'id':'1'
    }
)

print(response['Item'])
# {'stationName': 'Hakodate', 'prefecture': 'Hokkaido', 'id': '1', 'latitude': '41.773709', 'stationId': '1110101', 'longitude': '140.726413'}

query

Anwendungsbeispiel ①

Selbst wenn sowohl der Partitionsschlüssel als auch der Sortierschlüssel als Grenzschlüssel festgelegt sind, kann die Abfragemethode verwendet werden, um nur mit dem Partitionsschlüssel zu suchen.

response = table.query(
    KeyConditionExpression = Key('prefecture').eq('Hokkaido')
)

print(response['Items'])
# [{'stationName': 'Hakodate', 'prefecture': 'Hokkaido', 'id': '1', 'latitude': '41.773709', 'stationId': '1110101', 'longitude': '140.726413'}, {'stationName': 'Akai Fluss', 'prefecture': 'Hokkaido', 'id': '10', 'latitude': '42.003267', 'stationId': '1110110', 'longitude': '140.642678'}, {'stationName': 'Komagatake', 'prefecture': 'Hokkaido', 'id': '11', 'latitude': '42.038809', 'stationId': '1110111', 'longitude': '140.610476'}, {'stationName': 'Higashiyama', 'prefecture': 'Hokkaido', 'id': '12', 'latitude': '42.06172', 'stationId': '1110112', 'longitude': '140.605222'}]

Anwendungsbeispiel ②

Sie können die Suchbedingungen für Partitionsschlüssel und Sortierschlüssel im Parameter KeyConditionExpression beschreiben.
Informationen zum Schreiben von KeyConditionExpression finden Sie in diesem Dokument ↓
- DynamoDB customization reference — Boto3 Docs documentation
Der ScanIndexForward-Parameter ist standardmäßig True. Wenn True, ist die Antwort in aufsteigender Reihenfolge. Bei der Einstellung False ist die Reihenfolge absteigend.
Durch die Verwendung mit dem Parameter Limit wird beispielsweise nur der neueste erfasst. Usw. (wenn die Zeit im Sortierschlüssel eingestellt ist)

response = table.query(
    KeyConditionExpression = Key('prefecture').eq('Hokkaido')&Key('id').begins_with('1'),
    ScanIndexForward = False,
    Limit = 2,
)

print(response['Items'])
# [{'stationName': 'Choshiguchi', 'prefecture': 'Hokkaido', 'id': '16', 'latitude': '42.015471', 'stationId': '1110116', 'longitude': '140.720656'}, {'stationName': 'Ryuyama Onsen', 'prefecture': 'Hokkaido', 'id': '15', 'latitude': '42.003483', 'stationId': '1110115', 'longitude': '140.716358'}]

Wenn Sie einen GSI (Global Secondary Index) haben

Mit --GSI (Global Secondary Index) können Sie zusätzlich zum Tabellenpartitionsschlüssel / Sortierschlüssel einen neuen Partitionsschlüssel / Sortierschlüssel festlegen.

Es gibt auch einen LSI (Local Secondary Index), aber der LSI setzt den Partitionsschlüssel so wie er ist und nur den Sortierschlüssel. ――Diese Seite ist leicht zu verstehen.
Ich habe den Schlüsselindex von DynamoDB - Qiita zusammengefasst
Klicken Sie hier, um zu erfahren, wie Sie GSI ↓ erstellen
Schritt 6: Globalen Sekundärindex erstellen - Amazon DynamoDB