amazon-dynamodb-streams

2熱

1答えて

実際に、項目フィールドのルールが破損した場合にレコードの挿入/更新を防止する必要があるAWS DynamoDBテーブルアイテムの検証を実装したいと考えています。可能ですか？または、挿入/更新の前にトリガする、dynamoDBテーブル用のトリガラムダを作成できますか？検証ルールをチェックしてこれを処理できるように

0熱

1答えて

getApproximateCreationDateTime（）APIがDynamoDB StreamRecordオブジェクトで使用できません

私はのDynamoDBストリームの周辺のPOCで作業しており、これに続いてdocumentationでした。私はRecord.getDynamodb()メソッドを呼び出してから取得 StreamRecordオブジェクトは、ここでjavadocsで述べたように、ApproximateCreationDateTime属性を持っていないようです。私は、このフィールドが廃止され、ドキュメントが更新されて

1熱

1答えて

Apache FlinkでDynamoDBストリームを使用する

Apache Flinkで誰かがDynamoDBストリームを消費しようとしましたか？ Flinkにはキネシス消費者があります。しかし、私はDynamoストリームを直接消費する方法を探しています。 DataStream<String> kinesis = env.addSource(new FlinkKinesisConsumer<>( "kinesis_stream_name", new

1熱

1答えて

AWS入手方法Java SDKを使用して各Dynamodbテーブルでトリガーの一覧を表示

トリガータブにトリガーを持つdynamodbテーブルがあります。特定の表に対してAWS Java SDKを使用してこれらのトリガーのリストを取得する方法。私はJAVA SDKを使いましたが、これまでにリストを取得するAPIを見つけることができませんでした。

0熱

1答えて

aws sdk javascriptを使用してdynamodbストリームを無効にする

aws sdk javascriptを使用してDynamodbストリームを無効にする方法はありますか？他のサービスのメンテナンス中にラムダ関数にデータをストリーミングすることを停止する必要があります。

0熱

1答えて

すべてのレコードに対してDynamoDBストリームトリガーを呼び出す

DynamoDBテーブルからElasticSearchインポートプロセスを設定しようとしています。私はすでにAWS Lambdaを作成し、追加/更新されたすべてのレコードに対して自分のラムダを呼び出すトリガーを使用してDynamoDBストリームを有効にしました。今度は、初期のシード操作を実行したいと思います（現在、自分のDynamoDBテーブルにあるすべてのレコードをElasticSearchにイ

0熱

1答えて

DynamoDBストリームから別のテーブルにアイテムをコピーする最も簡単な方法は何ですか？

私は2つのdynamoDBテーブルtable1とtable2を持っていて、ストリームはtable1で有効になっています。どちらも "id"という文字列キーを持っています。私はまた、ストリームからtable1への挿入を読み取り、それらが特定の基準を満たす場合にはtable2にミラーリングするラムダ関数を持っています。ここではかなりのない仕事をして、私のJSコード（ES6構文は）です： const d

1熱

1答えて

テーブルには、mobileNumberカラムがほんのわずかのレコードにある複数のレコードがあります。これらのレコードのみを取得する必要があります

テーブルには、mobileNumber列がほんのわずかのレコードにある複数のレコードがあります。私はそれらのレコードだけを取得する必要があります。このクエリでは、すべてのレコードを取得しています。 $request = [ 'TableName' => 'tbl_camp', 'ExpressionAttributeNames' => [ '#mobileNumb

0熱

1答えて

実際の値が認識されないKinesis FirehoseからelasticsearchへのJSONデータの送信

次の行で説明されているフィールドvalueのKibanaに問題があります。私はその状況を説明しようとします。私はdynamoDBストリームをラムダに送ってからKenesis Firehouseに送り、最後にFirehoseからElasticsearchに送ります。私はキバナを使ってデータを視覚化しています。ここで問題がどこにあるのですか？私はDynamoDBのにこのJSONを送ってると言うこと