scala - AWS : InvalidSignature exception while adding record

Question

尝试使用 Kinesis Producer library 添加用户记录时发生 InvalidSignatureException。AWS_JAVA_SDK_VERSION=1.10.26
AWS_KINESIS_PRODUCER_VERSION=0.10.1

错误:

PutRecords 失败:{"__type":"InvalidSignatureException","message":"我们计算的请求签名与您提供的签名不匹配。请检查您的 AWS secret 访问 key 和签名方法。

SCALA KINESIS 生产者代码

private val configuration: KinesisProducerConfiguration = new KinesisProducerConfiguration
  val credentialsProvider: AWSCredentialsProvider = AwsUtil.getAwsCredentials(config.awsAccessKey, config.awsSecretKey)
  configuration.setCredentialsProvider(credentialsProvider)
  configuration.setRecordMaxBufferedTime(config.timeLimit)
  configuration.setAggregationMaxCount(1)
  configuration.setRegion(config.streamRegion)
  configuration.setMetricsLevel("none")
  private val kinesisProducer = new KinesisProducer(configuration)
  kinesisProducer.addUserRecord(streamName, key, eventBytes)`

以上代码无效。但是我可以通过来自终端的 aws cli 和 KinesisClient 在下面指定的代码中将记录添加到运动流。

private def createKinesisClient = {
    val accessKey = config.awsAccessKey
    val secretKey = config.awsSecretKey
    val credentialsProvider: AWSCredentialsProvider = AwsUtil.getAwsCredentials(accessKey, secretKey)
    val client = new AmazonKinesisClient(credentialsProvider)

    client.setEndpoint(config.streamEndpoint)
    client
  }

Answer 1

发生这种情况是因为您的 VM/PC/服务器时钟可能有偏差。

如果您运行的是 ubuntu，请尝试更新您的系统时间:

sudo ntpdate ntp.ubuntu.com

如果你在 Mac 上使用 docker-machine，你可以用这个命令解决:

docker-machine ssh default 'sudo ntpclient -s -h pool.ntp.org'