本節(jié)如果你已經(jīng)從Dynamodb中導(dǎo)出過數(shù)據(jù)，而且導(dǎo)出的文件以及被存入S3。文件內(nèi)部結(jié)構(gòu)會在Verify Data Export File?中描寫敘述。

我們稱之前導(dǎo)出數(shù)據(jù)的原始表為source table，數(shù)據(jù)將要被導(dǎo)入的表為destination table。你能夠?qū)3中的導(dǎo)出文件導(dǎo)入到dynamodb的表中。可是要先確保滿足以下條件：

• The destination table 已經(jīng)存在。 (導(dǎo)入任務(wù)不會為你創(chuàng)建表)
• The destination table 與 source table 有同樣的名稱。
• The destination table 與 source table 有同樣的結(jié)構(gòu)。

Destination table不一定要是空的。然而，導(dǎo)入進程會替換掉表中有相同主鍵的數(shù)據(jù)。

比如，你有一個Customer?表，它的主鍵是CustomerId。而且僅僅有三個items (CustomerId?1, 2, and 3)。

假設(shè)要導(dǎo)入的文件里相同包括CustomerID?為1, 2, and 3的items。這些在destination table中的items將會被導(dǎo)入文件里的數(shù)據(jù)替換。假設(shè)文件里還包括CustomerId為4的item，那么這個item會被增加到

destination table中。 Destination table 能夠在不同的AWS region。比如。如果你有個一個?Customer?table在US West (Oregon) region，然后將它的數(shù)據(jù)導(dǎo)出到了Amazon S3中。你能夠?qū)⑺鼘?dǎo)入到在?EU (Ireland) region中有同樣表明，同樣主鍵的表中。這樣的做法被稱為 cross-region?導(dǎo)出和導(dǎo)入。

注意到AWS管理控制臺同意你一次導(dǎo)出多個表的數(shù)據(jù)。可是，不同的是，你一次僅僅能導(dǎo)入一個表。
從S3導(dǎo)入數(shù)據(jù)到DynamoDB

登陸AWS管理控制臺，然后打開dynamodb控制臺：?https://console.aws.amazon.com/dynamodb/.

(可選) 假設(shè)你想做塊區(qū)域?qū)搿｜c擊右上角的Select a Region?然后選擇要導(dǎo)入的表的區(qū)域。控制臺會顯示該區(qū)域下的全部表。

假設(shè)destination table不存在的話。你須要先創(chuàng)建它。

在?Amazon DynamoDB Tables?頁面, 點擊?Export/Import.

在?Export/Import?頁面，選擇一個你要導(dǎo)入的表，然后點擊?Import into DynamoDB.

在?Create Import Table Data Pipeline?頁面，按以下步驟操作：

S3 Input Folder?文本框中輸入導(dǎo)入文件相應(yīng)的 Amazon S3 URI。比如:?s3://mybucket/exports這個URI的規(guī)則應(yīng)該是這樣?s3://bucketname/folder :

• bucketname?是S3中bucket的名稱
• folder?表示存放要導(dǎo)入的文件的名稱

導(dǎo)入任務(wù)會通過指定的S3位置找到相應(yīng)的文件。文件內(nèi)部結(jié)構(gòu)會在Verify Data Export File?中描寫敘述。

在 S3 Log Folder?文本框中輸入一個S3 URI，導(dǎo)出過程的日志將被存儲在對應(yīng)的folder中。比如：s3://mybucket/logs/
S3 Log Folder?URI的格式和 S3 Output Folder的格式同樣。

在?Throughput Rate?文本框中可選擇一個百分比。

這個比率表示在導(dǎo)出過程中會消耗讀吞吐量的上限。比如，如果你要導(dǎo)出的表的讀吞吐量是20，同一時候你設(shè)置的百分比是40%。

那么導(dǎo)出時所消耗的吞吐量將不會超過8.
假設(shè)你在導(dǎo)出多個表。這個 Throughput Rate?將會被應(yīng)用到每一個表中。

Execution Timeout?文本框，輸入導(dǎo)出任務(wù)的超時時長。假設(shè)導(dǎo)出任務(wù)在這個時長內(nèi)還沒運行完畢，此任務(wù)會失敗。

Send notifications to?文本框，輸入一個email地址。在 pipeline被創(chuàng)建后。你將會收到一封email邀請訂閱Amazon SNS。假設(shè)你接受了此邀請，在每次運行導(dǎo)出操作時你都將會收到email通知。

Data Pipeline Role, 選擇?DataPipelineDefaultRole.

Resource Role, 選擇?DataPipelineDefaultResourceRole

確認好以上設(shè)置然后點擊 Create Export Pipeline.

你的 pipeline 如今將被創(chuàng)建；這個過程可能會花費幾分鐘完畢。

要查看當(dāng)前狀態(tài)。移步?Managing Export and Import Pipelines.

導(dǎo)入任務(wù)會在你的pipeline創(chuàng)建好后馬上運行。

轉(zhuǎn)載于:https://www.cnblogs.com/blfbuaa/p/6789950.html

總結(jié)

以上是生活随笔為你收集整理的从S3中导入数据到Dynamodb的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。