amazon-dynamodb-streams

2熱度

1回答

我有一個Lambda函數，多個DynamoDB流配置爲事件源，並且這是更大管道的一部分。在進行檢查時，我在其中一個下游組件中發現了一些缺失的數據。我想寫一個簡單的Lambda函數，它被配置爲前面提到的DynamoDB流之一的事件源。這會導致我的一個DynamoDB流擁有兩個讀取它的Lambda函數。我想知道這是好的嗎？ Lamdba的兩個函數都保證能夠接收放在流中的所有記錄，並且還有我需要注意的任

3熱度

1回答

DynanoDB在重新分區後的數據流行爲

我假設從DynaminesDB數據流中讀取使用Kinesis庫將使我總是有序地記錄具有相同分區鍵的事件序列。這是正確的嗎？如果發生重新分區，庫仍然會爲相同分區鍵的所有表活動提供有序記錄嗎？

0熱度

1回答

閱讀AWS Dynamodb流

我想使用DynamoDB Streams在S3上進行增量DynamoDB備份。我有一個lambda讀取dynamodb流並將文件寫入S3。爲了標記已經讀取的碎片，我將ExclusiveStartShardId登錄到配置文件中。我要做的就是：描述流（使用登錄ExclusiveStartShardId）獲取流的碎片對於那些CLOSED（具有EndingSequenceNumber）我做了以下的

1熱度

1回答

從DynamodbStreamRecord映射到JSON字符串

假設我有這種情況，我在AWS Lambda中獲得了DynamodbStreamRecord。從此流記錄（變量命名record），我的Java方法鏈提取這樣的地圖： Map<String, AttributeValue> w1Data = record.getDynamodb(). getNewImage(). // obtain the image get("DT"). /

0熱度

1回答

到DynamoDB的卡夫卡條目

我希望卡夫卡主題中的所有記錄都插入到DynamoDB中。有沒有可用的開源插件可以做到這一點。或者是否有其他更好的方法可以在DynamoDB內部完成。 PLS推薦 LOKESH納拉揚

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

0熱度

1回答

如何通知DynamoDB上正在更新的索引？

我有一張表（key=username，value=male or female）和一個值的索引。在向表中添加項目後，我想更新男性和女性的計數。但是，成功寫入後，由於索引是全局二級索引，所以計數查詢不一致。有沒有一種方法（發電機db Streams，Lambda，...）來監視索引何時更新？請注意，我沒有尋找涉及其他方面的解決方案（在Redis中保持增量的計數或...），我在這裏描述的是一個

1熱度

1回答

暫時禁用DynamoDB Lambda觸發器/流

我正在尋找一種方法來暫時禁用DynamoDB上的Lambda觸發器。我希望能夠在不將Lambda代碼作爲觸發器的情況下在表上應用手動更新（例如，從S3備份導入數據）。我嘗試了lambda函數「觸發器」選項卡中觸發器旁邊的禁用按鈕。我也嘗試禁用表的整個流。在這兩種情況下，當重新激活觸發器/流時，所有觸發事件（發生時，它們被禁用時）都會被執行。如何防止此代碼被觸發？非常感謝！