elasticsearch - 将DynamoDB与ElasticSearch同步以获取旧数据

Question

我正在使用此函数https://github.com/bfansports/dynamodb-to-elasticsearch将我的DynamoDB表与ElasticSearch同步。不幸的是，尽管我选择了“新的和旧的图像-项目的新的和旧的图像，但是它仅处理新添加的数据和更新的数据，而不处理表中以前存在的行。
“管理流”部分。

如何解决？

Answer 1

好的，我最后更新了DynamoDB，并触发了Stream，因此可以完成ElasticSearch和DynamoDB之间的同步。
这是我使用的脚本:

import json
import boto3
import random


def lambda_handler(event, context):

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('image-library')

response = table.scan(
    ProjectionExpression='#k',
    ExpressionAttributeNames={
        '#k' : 'id', #partition key
    }
)

items = response['Items']

random_number = random.randint(0,1000)

for item in items:
    response = table.update_item(
        Key=item,
        UpdateExpression='SET #f = :f',
        ExpressionAttributeNames={
            '#f' :'force_update'
        },
        ExpressionAttributeValues={
            ':f' : random_number
        }

    )