从java API粘合模式注册表

Question

我试图从Scala的Glue Schema Registry中的特定模式名称中获取所有模式版本id，但是它抛出了一个错误:

val cred: AWSCredentialsProvider =new AWSStaticCredentialsProvider(new BasicSessionCredentials("***", "***", ""))
val schemas = AWSSchemasClient
  .builder()
  .withCredentials(cred)
  .build()
val request = new ListSchemasRequest()
request.setRegistryName("registry")
request.setSchemaNamePrefix("schema")
schemas.listSchemas(request).toString

错误：

com.amazonaws.protocol.json.JsonErrorShapeMetadata.withExceptionUnmarshaller(Lcom/amazonaws/transform/JsonErrorUnmarshaller;)Lcom/amazonaws/protocol/json/JsonErrorShapeMetadata;

依赖关系是

  "com.amazonaws" % "aws-java-sdk-core" % "1.12.93" % Compile,
  "com.amazonaws" % "aws-java-sdk" % "1.12.93" % Compile,

我如何修复这个错误？

Answer 1

最后，我解决了这个错误，首先使用aws java开发工具包v2：

  "software.amazon.awssdk" % "sdk-core" % "2.17.61" % Compile,
  "software.amazon.awssdk" % "aws-sdk-java" % "2.17.61" % Compile,
  "software.amazon.awssdk" % "aws-json-protocol" % "2.17.61" % Compile

然后通过这段代码，我得到了模式：

val cred: AwsCredentialsProvider = ProfileCredentialsProvider.builder().profileName("profile").build()
val glueClient = GlueClient.builder().credentialsProvider(cred).build()    

val schemaId = SchemaId.builder().registryName("registry").schemaName("schema").build()
    val schemaVersionsRequest = ListSchemaVersionsRequest.builder().schemaId(schemaId).build()
    val list = glueClient.listSchemaVersions(schemaVersionsRequest)
    list.schemas().forEach(v=> {
        val schemaVersionNumber=SchemaVersionNumber.builder().versionNumber($v).build()
    val getSchemaVersion= GetSchemaVersionRequest.builder().schemaVersionNumber(schemaVersionNumber).schemaId(schemaId).build()
    val schemaVer=glueClient.getSchemaVersion(getSchemaVersion)
    println(schemaVer.toString)
    })