amazon-dynamodb-streams

0熱

1答えて

class Thread(Model): class Meta: read_capacity_units = 1 write_capacity_units = 1 table_name = "Thread" region = 'us-west-1' host = "http://localhost:8888" for

1熱

1答えて

AWS DynamoDBストリームのフック

AWS DynamoDBは、テーブルアクティビティの取得に役立つstreamsを提供します。私の理解では、夢の中の変化を捕らえる流れはStream ARN -> Shards -> shardIterator -> Recordsです。アプリケーションがDynamoテーブルの変更を監視するためには、上記のサイクルを実行し続ける必要があります。私は、このフローが、アプリケーションが聞くことができる変

1熱

1答えて

DynamoDBラムダトリガ/ストリームを一時的に無効にする

DynamoDBでラムダトリガを一時的に無効にする方法を探しています。ラムダコードがトリガーされていない状態で、テーブル（たとえば、S3バックアップからデータをインポートするなど）にマニュアルアップデートを適用できるようにしたいと考えています。私は、ラムダ関数 "Trigger"タブのトリガーの隣にある無効化ボタンを試しました。私はまた、テーブル全体のストリームを無効にしようとしました。どちらの場

6熱

1答えて

S3へのDynamoDBストリーム

私はDynamoDBの毎日のバックアップにData Pipeline（DP）を使用していますが、DPの実行では見逃しているデータの増分バックアップを実行したいと思います。これを達成するために、DynamoDB Streams + Lambda + S3を使用してリアルタイムのDynamoDBアップデートをS3に提供したいと思います。私はDynamoDBストリームの仕組みを理解していますが、私はS3

0熱

1答えて

DynamoDBへのKafkaエントリー

カフカトピックに入ってくるすべてのレコードをDynamoDBに挿入します。同じことができるオープンソースのプラグインがありますか？それとも、DynamoDB自体の中で私がそれをやり遂げることができる他の良い方法がありますか？ Plsのは、提案DynamoDBのでカフカのメッセージを格納ロークシュナラヤン

0熱

2答えて

AWS Lambda経由でAmazon ElasticsearchサービスでDynamodbストリームデータをインデックスする方法は？

私はステップバイステップthis tutorialを続けましたが、「結果をテストする」ステップに到着すると、この例では「すべての製品」が表示されているため、インデックス時間にテーブル名が表示されません。これは、私のdynamodbテーブルがAmazon ESドメインでインデックスに登録されていないことを意味します。すべての権限と設定されたラムダを例のように設定しました。今、AWS ESでダイ

2熱

1答えて

どのストリームシャードにDynamoDB突然変異が配置されますか？

私は、ElasticSearch（ES）にDynamoDBを複製しようとしています。私たちは、この目的のためにlogstash input pluginを評価したが、以下のような欠点を発見した：プルモードで logstashはHA /フェイルオーバー機能を持っていません。複製用のSPOF ESインデックスでアプリケーションレベルの結合を行いたくないので、複数のテーブルを1つのESドキュメントにマー