批量向tablestore插入数据的方法

有两种方法可以批量向tablestore插入数据：

使用BatchWriteRow接口

BatchWriteRow接口是tablestore提供的批量写入数据的接口。可以将多个PutRow或UpdateRow请求打包成一次请求发送给tablestore，以提高写入性能。

示例代码：

BatchWriteRowRequest request = new BatchWriteRowRequest();
List<RowPutChange> rowPutChangeList = new ArrayList<>();
for (int i = 0; i < 100; i++) {
    RowPutChange rowPutChange = new RowPutChange(tableName);
    rowPutChange.addColumn(new Column("col1", ColumnValue.fromLong(i)));
    rowPutChange.addColumn(new Column("col2", ColumnValue.fromString("value" + i)));
    rowPutChangeList.add(rowPutChange);
}
request.addRowPutChange(rowPutChangeList);
BatchWriteRowResponse response = syncClient.batchWriteRow(request);

使用Datahub同步数据

Datahub是阿里云提供的数据流服务，可以将数据实时同步到tablestore。可以将批量数据写入Datahub，然后通过Datahub同步到tablestore。

示例代码：

Producer<String, String> producer = new Producer<>(producerConfig);
RecordSchema schema = new RecordSchema();
schema.addField(new Field("col1", FieldType.BIGINT));
schema.addField(new Field("col2", FieldType.STRING));
RecordGenerator generator = new RecordGenerator(schema);
List<RecordEntry> recordEntries = new ArrayList<>();
for (int i = 0; i < 100; i++) {
    RecordEntry recordEntry = new RecordEntry();
    Record record = generator.generate();
    record.setField("col1", i);
    record.setField("col2", "value" + i);
    recordEntry.setRecord(record);
    recordEntries.add(recordEntry);
}
producer.send(new Tuple(topicName, recordEntries));

然后在Datahub中配置同步任务，将数据同步到tablestore。具体配置方法可以参考阿里云官方文档。