将DynamoDB json sqs消息转换为普通的json java

import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.document.DynamoDB;
import com.amazonaws.services.dynamodbv2.document.Item;
import com.amazonaws.services.dynamodbv2.document.Table;
import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.SendMessageRequest;
import org.json.JSONObject;

public class DynamoDBToJSONConverter {
    public static void main(String[] args) {
        // 创建DynamoDB客户端
        AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().build();
        DynamoDB dynamoDB = new DynamoDB(client);

        // 获取DynamoDB表
        Table table = dynamoDB.getTable("YourTableName");

        // 查询或扫描DynamoDB表并获取JSON数据
        Item item = table.getItem("YourPrimaryKey", "YourPrimaryKeyValue");
        String dynamoDBJson = item.toJSON();

        // 将DynamoDB JSON转换为普通JSON
        JSONObject normalJson = new JSONObject(dynamoDBJson);

        // 创建SQS客户端
        AmazonSQS sqsClient = AmazonSQSClientBuilder.standard().build();

        // 将转换后的JSON消息发送到SQS队列
        SendMessageRequest sendMessageRequest = new SendMessageRequest()
                .withQueueUrl("YourQueueUrl")
                .withMessageBody(normalJson.toString());
        sqsClient.sendMessage(sendMessageRequest);
    }
}