PolarDB：效能測試報告

測試環境配置

基準測試載入器

• 工具：YCSB (Yahoo! Cloud Serving Benchmark)。

• 效能指標：OPS (Operations Per Second)，即資料庫每秒處理的運算元。

工作負載模型

通過配置YCSB的CoreWorkload來類比五種典型的業務情境。測試資料模型為單表usertable，主鍵類型HASH，欄位包含10個100 位元組的隨機字串（每個記錄約1 KB）。

其他壓測方式

8 核 32 GB 規格

32 核 128 GB 規格

64 核 256 GB 規格

1. 配置YCSB

在運行測試前，需要對YCSB的DynamoDB用戶端進行配置。

1. 配置身份憑證

   編輯dynamodb/conf/AWSCredentials.properties檔案，填入您在PolarDB控制台建立的DynamoDB專用帳號資訊。

   # 帳號名即為AccessKey ID
   accessKey = <YOUR_ACCESS_KEY_ID>
   
   # 密鑰
   secretKey = <YOUR_SECRET_ACCESS_KEY>

2. 配置串連屬性

   編輯dynamodb/conf/dynamodb.properties檔案，指定要串連的PolarDB叢集串連資訊。

   # 認證檔案的絕對路徑
   dynamodb.awsCredentialsFile = /path/to/your/AWSCredentials.properties
   
   # 您需要提前在叢集中建立一個usertable表。此處建立僅有分區鍵的usertable表，分區鍵名為pk。
   dynamodb.primaryKey = pk
   
   # PolarDB的DynamoDB訪問地址，必須包含http://首碼
   dynamodb.endpoint = http://<your-polardb-ddb-endpoint>:<port>
   
   # region參數必須設定為空白
   dynamodb.region = 
   
   # 測試所用的表主鍵名和類型，需與測試表保持一致
   dynamodb.primaryKey = HASH

2. 適配YCSB的Update操作

• 檔案路徑：dynamodb/src/main/java/site/ycsb/db/DynamoDBClient.java

• 修改方法：update()

修改前（原始代碼）

@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;
}

修改後（使用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;
}

3. 執行測試

測試分為load（載入初始資料）和run（運行工作負載）兩個階段。以1 GB資料量（100萬條記錄）、128並發線程、唯讀模型為例：

1. 載入資料（Load Phase）

   # 解釋:
   # -s: 顯示狀態更新
   # -P workloads/workload_read_only: 指定基礎workload檔案
   # -P /path/to/dynamodb.properties: 指定資料庫連接設定檔
   # -p recordcount=1000000: 定義總記錄數
   # -p operationcount=1000000: 定義本次運行要執行的操作總數
   # -threads 128: 指定並發線程數
   
   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. 運行測試（Run Phase）

   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 &