跟蹤方式插入/更新/刪除會將你的插入過程的3部分的過程。
步驟1:一個更新時間戳字段包含在您的目標表。
步驟2:在你輸入刷新數據,添加一個更新時間戳列並將其設置為當前時間戳。
更新數
步驟3:運行upsert工作隻有whenMatchedUpdate條款。當前的時間戳的行),則更新計數。
同時,得到一個提取與當前的時間戳的行——這些行你會在DyanmoDB更新
插入數
第五:表- RC1的行數。
第六段:運行upsert工作隻有whenNotMatchedInsert條款。插入- RC2後得到表的行數
插入數= RC2-RC1
得到一個與當前時間戳和提取的行執行left-anti加入更新df -這些行你會在DyanmoDB插入
刪除數
得到表的行數,沒有或正在穿衣RC1。
向運行upsert工作隻有whenNotMatchedDelete條款。插入- RC2後得到表的行數
刪除數= RC1-RC2
從你的源數據,會有一種方式來確定要刪除的記錄。抓住這些指數/主鍵刪除記錄。
