amazon-dynamodb-streams

3热度

1回答

我假设从DynaminesDB数据流中读取使用Kinesis库将使我总是有序地记录具有相同分区键的事件序列。这是正确的吗？如果发生重新分区，库仍然会为相同分区键的所有表活动提供有序记录吗？

0热度

1回答

我想使用DynamoDB Streams在S3上进行增量DynamoDB备份。我有一个lambda读取dynamodb流并将文件写入S3。为了标记已经读取的碎片，我将ExclusiveStartShardId登录到配置文件中。我要做的就是：描述流（使用登录ExclusiveStartShardId）获取流的碎片对于那些CLOSED（具有EndingSequenceNumber）我做了以下的

6热度

1回答

DynamoDB Streams to S3

我正在使用Data Pipeline（DP）进行DynamoDB的每日备份，但是，我想对DP运行（DP运行之间的更新）错过的数据执行增量备份。为此，我想使用DynamoDB Streams + Lambda + S3将实时DynamoDB更新提供给S3。我了解DynamoDB流如何工作，但是，我正在努力创建一个写入S3的Lambda函数，并说每小时滚动一个文件。有人试过吗？

0热度

1回答

到DynamoDB的卡夫卡条目

我希望卡夫卡主题中的所有记录都插入到DynamoDB中。有没有可用的开源插件可以做到这一点。或者是否有其他更好的方法可以在DynamoDB内部完成。 PLS推荐 LOKESH纳拉扬

0热度

1回答

pynamodb亚马逊凭证例外

我的pynamodb文档以下 class Thread(Model): class Meta: read_capacity_units = 1 write_capacity_units = 1 table_name = "Thread" region = 'us-west-1' host = "http://localhost:

3热度

2回答

为什么我会在amazon-kinesis-client中获取JSONObject上的NoClassDefFoundError？

我已经纳入从DynamoDB的码流从AWS-dynamodb-例子适配器演示，到我的Maven项目，并且我得到一个运行时错误： Exception in thread "Thread-2" java.lang.NoClassDefFoundError: com/amazonaws/util/json/JSONObject at com.amazonaws.services.kinesis.lea

0热度

1回答

DynamoDB索引

我DynamboDB行项目如下：（这是给我） { "id":"123456", "date_time":"01062016 143212", "payload":{ "type":"A", "value":"temp value", } } 我添加的ID + DATE_TIME指标。如何在payload.type上添加索引？

2热度

1回答

DynamoDB突变获取到哪个流分片？

我正在研究将DynamoDB复制到ElasticSearch（ES）中。我们评估了logstash input plugin用于此目的，但发现以下缺点： logstash在拉模式下没有HA /故障切换功能。它成为复制的SPOF 由于我们不想在ES索引上进行应用程序级连接，因此我们想要将多个表合并到一个ES文档中。该插件不提供此用例的功能。因此，我们正在评估以下两种方法 Lambda表达式阅读Dy

1热度

1回答

AWS DynamoDB流的钩子

AWS DynamoDB提供了streams这有助于捕获表活动。据我了解，在梦境中捕捉变化的流程是Stream ARN -> Shards -> shardIterator -> Records。为了使应用程序监控Dynamo表上的更改，它必须继续执行上述周期。我想知道这个流是否可以通过钩子来简化，这些钩子可以监视这些变化并触发，这是我的应用程序可以听到的。我知道有一个可以执行上述周期和警报的AW

3热度

1回答

一个偶然的无限循环

我意外地部署一些Java代码进入AWS LAMBDA其中包含以下明显手推车吸气剂后AWS LAMBDA令人担忧的行为它由DynamoDB流触发。部署有问题的代码后，我在22h17左右修改了DynamoDB表，从而执行代码。我检查了日志，并且正如你可以从前面的函数期望的那样，我有一个经典的StackOverflowError和一个很长的堆栈跟踪。但是，我惊讶地发现，这并没有停止执行并报告多个堆栈溢出