Fase 5: copia dei dati in DynamoDB

Apri la console DynamoDB all'indirizzo https://console.aws.amazon.com/dynamodb/.

Scegliere Create Table (Crea tabella).

Nello schermata Crea tabella DynamoDB, procedi nel seguente modo:

1. In Tabella, digitare Features.

2. Per Chiave primaria, nel campo Chiave di partizione, digitare Id. Impostare il tipo di dati su Number (Numero).

   Deseleziona l'opzione Utilizza impostazioni predefinite. In Capacità con provisioning, specificare:

   • Unità di capacità in lettura-10

   • Unità di capacità in scrittura-10

Scegli Crea.

Al prompt di Hive immettere la seguente istruzione HiveQL:

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"
);

A questo punto, è stata stabilita una mappatura tra Hive e la tabella Caratteristiche in DynamoDB.

Immettere la seguente istruzione HiveQL per importare i dati in DynamoDB:

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 invierà un MapReduce lavoro, che verrà elaborato dal tuo cluster Amazon EMR. Il completamento del processo può richiedere diversi minuti.

Verificare che i dati siano stati caricati in DynamoDB:

1. Nel pannello di navigazione della console DynamoDB, seleziona Tabelle.

2. Scegli la tabella Caratteristiche, quindi seleziona la scheda Elementi per visualizzare i dati.