如何将Javascript Streams对象映射到DynamoDB对象？

const AWS = require('aws-sdk');
const fs = require('fs');
const { Transform } = require('stream');

// 配置AWS SDK
AWS.config.update({
  accessKeyId: 'YOUR_ACCESS_KEY',
  secretAccessKey: 'YOUR_SECRET_ACCESS_KEY',
  region: 'YOUR_REGION'
});

// 连接到DynamoDB服务
const dynamodb = new AWS.DynamoDB.DocumentClient();

// 创建可读流
const readableStream = fs.createReadStream('data.txt');

// 创建转换流
const transformStream = new Transform({
  transform(chunk, encoding, callback) {
    // 将数据转换为DynamoDB对象的格式
    const dynamoDBObject = {
      TableName: 'YOUR_TABLE_NAME',
      Item: {
        id: chunk.id,
        name: chunk.name,
        // 其他属性...
      }
    };

    // 将转换后的数据写入DynamoDB表
    dynamodb.put(dynamoDBObject, (err, data) => {
      if (err) {
        console.error(err);
      } else {
        console.log('Data written to DynamoDB:', data);
      }
    });

    callback();
  }
});

// 将可读流连接到转换流，并将转换流连接到DynamoDB
readableStream.pipe(transformStream);