Langkah 5: Salin data ke DynamoDB

Pada langkah ini, Anda akan menyalin data dari tabel Hive (hive_features) ke tabel baru di DynamoDB.

1. Buka konsol DynamoDB di. https://console.aws.amazon.com/dynamodb/

2. Pilih Buat Tabel.

3. Di halaman Buat tabel DynamoDB, lakukan tindakan berikut:

   1. Di Tabel, masukkan Features.

   2. Untuk Kunci primer, di bidang Kunci partisi, masukkan Id. Atur jenis data ke Number.

      Kosongkan Gunakan Pengaturan Default. Untuk Kapasitas yang Disediakan, masukkan berikut ini:

      • Unit Kapasitas Baca—10

      • Unit Kapasitas Tulis—10

   Pilih Buat.

4. Di prompt Hive, masukkan pernyataan HiveQL berikut:

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

   Anda sekarang telah membuat pemetaan antara Hive dan tabel Fitur di DynamoDB.

5. Masukkan pernyataan HiveQL berikut untuk mengimpor data ke 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 akan mengirimkan MapReduce pekerjaan, yang akan diproses oleh EMR cluster Amazon Anda. Proses ini akan memakan waktu beberapa menit untuk menyelesaikan tugas.

6. Verifikasi bahwa data telah dimuat ke DynamoDB:

   1. Di panel navigasi konsol DynamoDB, pilih Tabel.

   2. Pilih tabel Fitur, lalu pilih tab Item untuk melihat data.

Langkah berikutnya

Langkah 6: Kueri data dalam tabel DynamoDB