amazon-dynamodb-streams

0熱

2答えて

私は、DynamoDBテーブルに書き込むアプリケーションを持っています。私は、Kinesisにアグリゲーションをさせて、集計したデータを別のDynamoDBテーブルに書き込もうとしています。 'use strict'; var AWS = require('aws-sdk'); var kinesis = new AWS.Kinesis(); exports.handler = (eve

0熱

2答えて

すべてのレコードを再処理する - DynamoDB Stream

Awsのラムダ関数+ Firehoseを使用してDynamoDBストリームを使用して、データをredshiftと同期させています。すべてのDynamoDBレコードを再処理目的でストリームに追加することが可能かどうかを知りたい。そうでない場合、正しいアプローチは何ですか？

1熱

1答えて

DynamodbStreamRecordのマップからJSONの文字列へ

AWSラムダ内にDynamodbStreamRecordがあるという状況があります。このストリーム・レコード（recordという名前の変数）からは、私はこの方法でマップを抽出し、Javaメソッドのチェーンを持っている： Map<String, AttributeValue> w1Data = record.getDynamodb(). getNewImage(). // obtain

1熱

1答えて

DynamoDBのストリーム同類を更新するために、私は私のバックエンド用のDynamoDBのを使用してい

コメントは、私はコメントを維持するために、SQLと別のテーブルのように別々のテーブルに好きで、コメントを維持するために必要とポストあたりのカウント数を好き合計3 { "ジョーのジョー" テキスト} テーブルのTableName - PostId、ユーザ名、 - - - コメントPostId、ユーザ名、ハッシュキー、RangeKeyは、同類を属性のカウント - PostId、 - 、{コメン

1熱

1答えて

eコマース注文テーブルのモデリング - DynamoDB + SNS + SQS

eコマースフロントエンドからの注文を格納するDynamoDBテーブルを作成します。ユーザーが注文すると、注文はDynamoDBテーブルに格納されます。このテーブルにはプライマリキー（order_id）とグローバルセカンダリインデックス（email、SSN）があります。注文ステータスでも照会したいと思います。私は特定の日付に特定のステータスのすべての注文を取得したいと思います。この行動をモデル化

0熱

2答えて

Spark Streaming Kinesisの統合：ワーカーでLeaseCoordinatorを初期化中にエラーが発生しました

kinesisアプリケーションでストリーム化された単純なバニラスパークをスケーラで実行する際に問題が発生しています。私はSnowplowとWordCountASLのようなチュートリアルの基本的なガイダンスに従ってきました。しかし、私はまだそれがあるため、このキネシスワーカーエラーで動作させることはできません。ここで 16/11/15 09:00:27 ERROR Worker: Caught e

2熱

1答えて

Lambda関数のDynamoDBのシャードIDを取得する方法は？

AWS DynamoDBトリガーを使用すると、DynamoDBテーブルのすべての変更を取得できます。 Lambdaは各ラムダ関数をa shard of DynamoDB Streamsに割り当てます。いくつかのデータ処理タスクに一貫性を持たせるために、Lambda関数のシャードIDを取得したいのですが、取得する方法がわかりません。誰もそれをすることができますか？

2熱

1答えて

DynamoDB：ConditionalCheckFailedException

私はConditionalCheckFailedExceptionを処理していますが、どの条件がチェックに失敗したのか正確にはわかりません。デバッガを開いて例外変数を調べると、有用な情報が見つかりません。以下はJava Dynamo Clientのコードです。テーブル内のクライアントの日付は、書き込みしようとしている現在のクライアントの日付より前になる（EPOCH時間として保存されている）エ

5熱

1答えて

DynamoDBストリームの伝搬遅延を測定するにはどうすればよいですか？

私はDynamoDB Streams + Kinesisクライアントライブラリ（KCL）を使用しています。イベントがストリーム内で作成されたときと、それがKCL側で処理されたときの間のレイテンシを測定するにはどうすればよいですか？私が知る限り、KCLのMillisBehindLatestメトリックは、Kinesis Streams（DynamoDBストリームではない）に固有です。 approx