本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
TransactWriteItems
TransactWriteItems
請求物件可讓您告訴 AWS AppSync DynamoDB 函數向 DynamoDB 提出寫入多個項目的TransactWriteItems
請求,可能寫入多個資料表。對於此請求物件,您必須指定下列項目:
-
每個請求項目的目標資料表名稱
-
每個請求項目要執行的操作。支援四種類型的操作:PutItem、DeleteItem、 UpdateItem和 ConditionCheck
-
每個要寫入之請求項目的索引鍵
套用 DynamoDB TransactWriteItems
限制。
TransactWriteItems
請求物件具有下列結構:
type DynamoDBTransactWriteItemsRequest = { operation: 'TransactWriteItems'; transactItems: TransactItem[]; }; type TransactItem = | TransactWritePutItem | TransactWriteUpdateItem | TransactWriteDeleteItem | TransactWriteConditionCheckItem; type TransactWritePutItem = { table: string; operation: 'PutItem'; key: { [key: string]: any }; attributeValues: { [key: string]: string}; condition?: TransactConditionCheckExpression; }; type TransactWriteUpdateItem = { table: string; operation: 'UpdateItem'; key: { [key: string]: any }; update: DynamoDBExpression; condition?: TransactConditionCheckExpression; }; type TransactWriteDeleteItem = { table: string; operation: 'DeleteItem'; key: { [key: string]: any }; condition?: TransactConditionCheckExpression; }; type TransactWriteConditionCheckItem = { table: string; operation: 'ConditionCheck'; key: { [key: string]: any }; condition?: TransactConditionCheckExpression; }; type TransactConditionCheckExpression = { expression: string; expressionNames?: { [key: string]: string}; expressionValues?: { [key: string]: any}; returnValuesOnConditionCheckFailure: boolean; };
TransactWriteItems 欄位
- 欄位定義如下:
-
-
operation
-
要執行的 DynamoDB 操作。若要執行
TransactWriteItems
DynamoDB 操作,這必須設為TransactWriteItems
。此值為必填。 -
transactItems
-
要包含的請求項目。此值是請求項目的陣列。必須提供至少一個請求項目。
transactItems
值為必填。對於
PutItem
,欄位定義如下:-
table
-
目的地 DynamoDB 資料表。此值是資料表名稱的字串。
table
值為必填。 -
operation
-
要執行的 DynamoDB 操作。若要執行
PutItem
DynamoDB 操作,這必須設為PutItem
。此值為必填。 -
key
-
DynamoDB 金鑰代表要放置的項目主金鑰。DynamoDB 項目可能具有單一雜湊金鑰,或雜湊金鑰和排序金鑰,具體取決於資料表結構。如需如何指定「輸入值」的詳細資訊,請參閱類型系統 (請求映射)。此值為必填。
-
attributeValues
-
將放入 DynamoDB 的項目其餘屬性。如需如何指定「輸入值」的詳細資訊,請參閱類型系統 (請求映射)。此欄位為選用欄位。
-
condition
-
決定要求是否成功的條件,可根據已存在於 DynamoDB 的物件狀態。如果沒有指定條件,
PutItem
要求會覆寫該項目的任何現有資料項目。您可以指定在條件檢查失敗時是否擷取現有項目。如需交易條件的詳細資訊,請參閱交易條件運算式 。此值是選用的。
對於
UpdateItem
,欄位定義如下:-
table
-
要更新的 DynamoDB 資料表。此值是資料表名稱的字串。
table
值為必填。 -
operation
-
要執行的 DynamoDB 操作。若要執行
UpdateItem
DynamoDB 操作,這必須設為UpdateItem
。此值為必填。 -
key
-
DynamoDB 金鑰代表要更新之項目的主要金鑰。DynamoDB 項目可能具有單一雜湊金鑰,或雜湊金鑰和排序金鑰,具體取決於資料表結構。如需如何指定「輸入值」的詳細資訊,請參閱類型系統 (請求映射)。此值為必填。
-
update
-
update
本節可讓您指定更新表達式,描述如何在 DynamoDB 中更新項目。如需如何寫入更新表達式的詳細資訊,請參閱 DynamoDB UpdateExpressions 文件 。此區段是必須的。 -
condition
-
決定要求是否成功的條件,可根據已存在於 DynamoDB 的物件狀態。如果沒有指定條件,
UpdateItem
要求會更新現有的資料項目,無論項目的目前狀態為何。您可以指定在條件檢查失敗時是否擷取現有項目。如需交易條件的詳細資訊,請參閱交易條件表達式 。此值是選用的。
對於
DeleteItem
,欄位定義如下:-
table
-
要在其中刪除項目的 DynamoDB 資料表。此值是資料表名稱的字串。
table
值為必填。 -
operation
-
要執行的 DynamoDB 操作。若要執行
DeleteItem
DynamoDB 操作,這必須設為DeleteItem
。此值為必填。 -
key
-
DynamoDB 金鑰代表要刪除項目的主要金鑰。DynamoDB 項目可能具有單一雜湊金鑰,或雜湊金鑰和排序金鑰,具體取決於資料表結構。如需如何指定「輸入值」的詳細資訊,請參閱類型系統 (請求映射)。此值為必填。
-
condition
-
決定要求是否成功的條件,可根據已存在於 DynamoDB 的物件狀態。如果沒有指定條件,
DeleteItem
要求會刪除項目,無論該項目的目前狀態為何。您可以指定在條件檢查失敗時是否擷取現有項目。如需交易條件的詳細資訊,請參閱交易條件表達式 。此值是選用的。
對於
ConditionCheck
,欄位定義如下:-
table
-
要檢查條件的 DynamoDB 資料表。此值是資料表名稱的字串。
table
值為必填。 -
operation
-
要執行的 DynamoDB 操作。若要執行
ConditionCheck
DynamoDB 操作,這必須設為ConditionCheck
。此值為必填。 -
key
-
DynamoDB 金鑰代表要進行條件檢查的項目主金鑰。DynamoDB 項目可能具有單一雜湊金鑰,或雜湊金鑰和排序金鑰,具體取決於資料表結構。如需如何指定「輸入值」的詳細資訊,請參閱類型系統 (請求映射)。此值為必填。
-
condition
-
決定要求是否成功的條件,可根據已存在於 DynamoDB 的物件狀態。您可以指定在條件檢查失敗時是否擷取現有項目。如需交易條件的詳細資訊,請參閱交易條件表達式 。此值為必填。
-
-
注意事項:
-
如果成功,只會在回應中傳回請求項目的索引鍵。索引鍵的順序將與請求項目的順序相同。
-
交易會以某種 all-or-nothing方式執行。如果任何請求項目造成錯誤,將不執行整個交易,而且將傳回錯誤詳細資料。
-
沒有兩個請求項目可以定位到相同項目。否則會導致TransactionCanceledException錯誤。
-
如果交易的錯誤為 TransactionCanceledException,則會填入
cancellationReasons
區塊。如果請求項目的條件檢查失敗,而且您未將returnValuesOnConditionCheckFailure
指定為false
,將擷取資料表中存在的項目,並存放在cancellationReasons
區塊之對應位置的item
中。 -
TransactWriteItems
限制為 100 個請求項目。 -
與衝突偵測搭配使用時,不支援此操作。同時使用兩者可能會導致錯誤。
對於下列範例函數請求處理常式:
import { util } from '@aws-appsync/utils'; export function request(ctx) { const { authorId, postId, title, description, oldTitle, authorName } = ctx.args; return { operation: 'TransactWriteItems', transactItems: [ { table: 'posts', operation: 'PutItem', key: util.dynamodb.toMapValues({ postId }), attributeValues: util.dynamodb.toMapValues({ title, description }), condition: util.transform.toDynamoDBConditionExpression({ title: { eq: oldTitle }, }), }, { table: 'authors', operation: 'UpdateItem', key: util.dynamodb.toMapValues({ authorId }), update: { expression: 'SET authorName = :name', expressionValues: util.dynamodb.toMapValues({ ':name': authorName }), }, }, ], }; }
如果交易成功,ctx.result
中可用的叫用結果如下所示:
{ "keys": [ // Key of the PutItem request { "post_id": "p1", }, // Key of the UpdateItem request { "author_id": "a1" } ], "cancellationReasons": null }
如果交易因PutItem
請求的條件檢查失敗而失敗, 中可用的調用結果ctx.result
如下所示:
{ "keys": null, "cancellationReasons": [ { "item": { "post_id": "p1", "post_title": "Actual old title", "post_description": "Old description" }, "type": "ConditionCheckFailed", "message": "The condition check failed." }, { "type": "None", "message": "None" } ] }
ctx.error
包含錯誤的詳細資訊。金鑰金鑰 和 cancellationReasons保證會出現在 中ctx.result
。