PolarDB:Laporan pengujian kinerja

Konfigurasi lingkungan

Tool benchmark

• Tool: YCSB (Yahoo! Cloud Serving Benchmark)

• Metrik: OPS (Operations Per Second) — jumlah operasi yang diproses database per detik.

Model workload

Semua workload menggunakan CoreWorkload YCSB. Model data pengujian terdiri atas satu tabel usertable dengan kunci primary HASH, dan setiap record berisi 10 field berupa string acak sepanjang 100 byte (sekitar 1 KB per record).

Metode uji stres lainnya

Spesifikasi 8-core 32 GB

Spesifikasi 32-core 128 GB

Spesifikasi 64-core 256 GB

Langkah 1: Konfigurasikan YCSB

Sebelum menjalankan pengujian, konfigurasikan client DynamoDB YCSB.

1. Konfigurasikan kredensial identitas

   Edit file dynamodb/conf/AWSCredentials.properties dan masukkan kredensial untuk PolarDB consoleakun DynamoDB khusus Anda.

   # Nama akun adalah ID AccessKey
   accessKey = <YOUR_ACCESS_KEY_ID>
   
   # Kunci rahasia
   secretKey = <YOUR_SECRET_ACCESS_KEY>

2. Konfigurasikan properti koneksi

   Edit file dynamodb/conf/dynamodb.properties dan tentukan informasi koneksi kluster PolarDB.

   # Jalur mutlak file autentikasi
   dynamodb.awsCredentialsFile = /path/to/your/AWSCredentials.properties
   
   # Buat tabel usertable di kluster terlebih dahulu.
   # Contoh ini membuat tabel usertable hanya dengan kunci partisi bernama pk.
   dynamodb.primaryKey = pk
   
   # Titik akhir DynamoDB untuk PolarDB. Harus menyertakan awalan http://.
   dynamodb.endpoint = http://<your-polardb-ddb-endpoint>:<port>
   
   # Biarkan parameter region kosong.
   dynamodb.region =
   
   # Nama dan tipe kunci primary untuk tabel pengujian. Harus sesuai dengan tabel pengujian.
   dynamodb.primaryKey = HASH

Langkah 2: Patch operasi update YCSB

• Jalur file: dynamodb/src/main/java/site/ycsb/db/DynamoDBClient.java

• Metode yang perlu dimodifikasi: update()

Ganti implementasi aslinya:

@Override
public Status update(String table, String key, Map<String, ByteIterator> values) {
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug("updatekey: " + key + " from table: " + table);
  }

  Map<String, AttributeValueUpdate> attributes = new HashMap<>(values.size());
  for (Entry<String, ByteIterator> val : values.entrySet()) {
    AttributeValue v = new AttributeValue(val.getValue().toString());
    attributes.put(val.getKey(), new AttributeValueUpdate().withValue(v).withAction("PUT"));
  }

  UpdateItemRequest req = new UpdateItemRequest(table, createPrimaryKey(key), attributes);

  try {
    dynamoDB.updateItem(req);
  } catch (AmazonServiceException ex) {
    LOGGER.error(ex);
    return Status.ERROR;
  } catch (AmazonClientException ex) {
    LOGGER.error(ex);
    return CLIENT_ERROR;
  }
  return Status.OK;
}

Setelah perubahan (menggunakan UpdateExpression)

@Override
public Status update(String table, String key, Map<String, ByteIterator> values) {
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug("updatekey: " + key + " from table: " + table);
  }

  StringBuilder updateExp = new StringBuilder("SET ");
  Map<String, String> attrNames = new HashMap<>();
  Map<String, AttributeValue> attrValues = new HashMap<>();
  boolean first = true;
  for (Map.Entry<String, ByteIterator> entry : values.entrySet()) {
    String attr = entry.getKey();
    if (!first) {
      updateExp.append(", ");
    }
    String attrName = "#" + attr;
    String valueName = ":" + attr;
    updateExp.append(attrName).append(" = ").append(valueName);
    attrNames.put(attrName, attr);
    attrValues.put(valueName, new AttributeValue(entry.getValue().toString()));
    first = false;
  }

  UpdateItemRequest req = new UpdateItemRequest()
      .withTableName(table)
      .withKey(createPrimaryKey(key))
      .withUpdateExpression(updateExp.toString())
      .withExpressionAttributeNames(attrNames)
      .withExpressionAttributeValues(attrValues);

  try {
    dynamoDB.updateItem(req);
  } catch (AmazonServiceException ex) {
    LOGGER.error(ex);
    return Status.ERROR;
  } catch (AmazonClientException ex) {
    LOGGER.error(ex);
    return CLIENT_ERROR;
  }
  return Status.OK;
}

Langkah 3: Jalankan pengujian

Setiap sesi pengujian terdiri atas dua fase: load (mengisi data pengujian) dan run (menjalankan workload). Contoh berikut menggunakan set data 1 GB (1 juta record), 128 thread konkuren, dan workload read-only.

1. Muat data (Fase Load)

   # -s: Menampilkan pembaruan status selama pemuatan.
   # -P workloads/workload_read_only: Menentukan file workload.
   # -P /path/to/dynamodb.properties: Menentukan konfigurasi koneksi database.
   # -p recordcount=1000000: Jumlah total record yang dimuat (1 GB).
   # -p operationcount=1000000: Jumlah total operasi.
   # -threads 128: Jumlah thread konkuren.
   
   nohup ./bin/ycsb load dynamodb -s \
     -P workloads/workload_read_only \
     -P /path/to/dynamodb.properties \
     -p recordcount=1000000 \
     -p operationcount=1000000 \
     -threads 128 \
     > load.log 2>&1 &

2. Jalankan pengujian (Fase Run)

   nohup ./bin/ycsb run dynamodb -s \
     -P workloads/workload_read_only \
     -P /path/to/dynamodb.properties \
     -p recordcount=1000000 \
     -p operationcount=1000000 \
     -threads 128 \
     > run.log 2>&1 &