Schritt 5: Kopieren von Daten nach DynamoDB

Öffnen Sie die DynamoDB-Konsole unter. https://console.aws.amazon.com/dynamodb/

Wählen Sie Create Table (Tabelle erstellen) aus.

Führen Sie auf der Seite Create DynamoDB table die folgenden Schritte aus:

1. In der Tabelle, tippen Sie Features ein.

2. Geben Sie für Primärer Schlüssel im Feld Partitionsschlüssel, Id ein. Legen Sie den Datentyp auf Number fest.

   Deaktivieren Sie Standardeinstellungen verwenden. Geben Sie für Provisioned Capacity Folgendes ein:

   • Lesekapazitätseinheiten—10

   • Schreibkapazitätseinheiten—10

Wählen Sie Create (Erstellen) aus.

Geben Sie an der Hive-Eingabeaufforderung die folgende HiveQL-Anweisung ein:

CREATE EXTERNAL TABLE ddb_features
    (feature_id   BIGINT,
    feature_name  STRING,
    feature_class STRING,
    state_alpha   STRING,
    prim_lat_dec  DOUBLE,
    prim_long_dec DOUBLE,
    elev_in_ft    BIGINT)
STORED BY 'org.apache.hadoop.hive.dynamodb.DynamoDBStorageHandler'
TBLPROPERTIES(
    "dynamodb.table.name" = "Features",
    "dynamodb.column.mapping"="feature_id:Id,feature_name:Name,feature_class:Class,state_alpha:State,prim_lat_dec:Latitude,prim_long_dec:Longitude,elev_in_ft:Elevation"
);

Sie haben jetzt ein Mapping zwischen Hive und der Tabelle „Funktionen“ in DynamoDB hergestellt.

Geben Sie die folgende HiveQL-Anweisung ein, um Daten in DynamoDB zu importieren:

INSERT OVERWRITE TABLE ddb_features
SELECT
    feature_id,
    feature_name,
    feature_class,
    state_alpha,
    prim_lat_dec,
    prim_long_dec,
    elev_in_ft
FROM hive_features;

Hive reicht einen MapReduce Job ein, der von Ihrem Amazon EMR-Cluster bearbeitet wird. Die Verarbeitung des Auftrags kann einige Minuten dauern.

Überprüfen Sie, ob die Daten in DynamoDB geladen wurden:

1. Wählen Sie im Navigationsbereich der DynamoDB-Konsole Tabellen aus.

2. Wählen Sie die Tabelle „Features” und anschließend die Registerkarte Items aus, um die Daten anzuzeigen.