小编mee*_*eza的帖子

使用Java中的DynamoDBMapper更新DynamoDB项

如何使用DynamoDBMapper更新DynamoDB项?

我有多个进程,使用DynamoDB表,因此,get + save会产生不一致.我找不到使用DynamoDBMapper更新项目的方法.

java distributed-computing amazon-dynamodb

9
推荐指数
1
解决办法
9798
查看次数

如何将 EMR(Spark) 日志发送到 AWS Cloudwatch

我正在将 Log4j 与附加程序一起用于"com.kdgregory.log4j.aws.CloudWatchAppender"我的应用程序日志。当我在 EC2 或 Lambda 中运行 AWS Cloudwatch 时,会在 AWS Cloudwatch 中接收日志。但是,如果我运行使用具有相同类的 Spark 构建的应用程序,这些日志都不会传递到 Cloudwatch。有谁知道如何从 Spark 应用程序将 Log4j 日志发送到 AWS Cloudwatch。

log4j amazon-web-services apache-spark amazon-cloudwatchlogs

5
推荐指数
0
解决办法
1254
查看次数

Kinesis Stream PutRecord失败:无法对JSON的请求进行编组

我正在将事务写入Kinesis Stream(使用AWS SDK,JAVA),但putRecord因"编组错误"而失败.我试图发送一个简单的字符串(而不是我的复杂对象),但仍然得到相同的错误.下面是stacktrace片段.

AWS开发工具包版本:1.11.76

com.amazonaws.SdkClientException: Unable to marshall request to JSON: com.fasterxml.jackson.dataformat.cbor.CBORGenerator.getOutputContext()Lcom/fasterxml/jackson/core/json/JsonWriteContext;
at com.amazonaws.services.kinesis.model.transform.PutRecordRequestMarshaller.marshall(PutRecordRequestMarshaller.java:85)
at com.amazonaws.services.kinesis.AmazonKinesisClient.putRecord(AmazonKinesisClient.java:1365)
Run Code Online (Sandbox Code Playgroud)

java amazon-kinesis aws-sdk

4
推荐指数
1
解决办法
3216
查看次数