Configure a

synchronization

task to use the upsert operation.

The source for the mapping is a Twitter object that contains the tweet details. The Twitter object is a single source in the

synchronization

task. The Twitter object includes the

TweetId

,

UserName

, and

Tweet

source columns. Specify

Tweets

as the resource for the source object.

The target for the mapping is an Amazon DynamoDB table. The Amazon DynamoDB object includes the

UserName

and

AllTweets

target columns. Provide a name

test_twitter

for the target object and specify the connection type as Amazon DynamoDB.

Define a data filter for the Tweets source object. For example, you can filter by

NoneOfTheseWords Equals 'Watch'

.

Map the fields under

Tweets

source data to the fields in the

test_twitter

target object.

To consolidate the tweets based on user name, enter the following lookup expression:

concat((lookup( UserName=username ):test_twitter.tweets), Tweet

When you run the task, the

synchronization

application writes the mapped source data to the target Amazon DynamoDB table.