Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Ekspresi kondisi

Saat Anda mengubah objek di DynamoDB dengan menggunakan operasiPutItem,UpdateItem, dan DeleteItem DynamoDB, Anda dapat secara opsional menentukan ekspresi kondisi yang mengontrol apakah permintaan harus berhasil atau tidak, berdasarkan status objek yang sudah ada di DynamoDB sebelum operasi dilakukan.

AWS AppSync DynamoDB resolver memungkinkan ekspresi kondisi untuk ditentukan PutItem dalamUpdateItem,, DeleteItem dan meminta dokumen pemetaan, dan juga strategi untuk mengikuti jika kondisi gagal dan objek tidak diperbarui.

Contoh 1

Dokumen PutItem pemetaan berikut tidak memiliki ekspresi kondisi. Akibatnya, ia menempatkan item di DynamoDB bahkan jika item dengan kunci yang sama sudah ada, sehingga menimpa item yang ada.

{
   "version" : "2017-02-28",
   "operation" : "PutItem",
   "key" : {
      "id" : { "S" : "1" }
   }
}

Contoh 2

Dokumen PutItem pemetaan berikut memang memiliki ekspresi kondisi yang memungkinkan operasi berhasil hanya jika item dengan kunci yang sama tidak ada di DynamoDB.

{
   "version" : "2017-02-28",
   "operation" : "PutItem",
   "key" : {
      "id" : { "S" : "1" }
   },
   "condition" : {
      "expression" : "attribute_not_exists(id)"
   }
}

Secara default, jika pemeriksaan kondisi gagal, penyelesai AWS AppSync DynamoDB mengembalikan kesalahan untuk mutasi dan nilai objek saat ini di DynamoDB di bidang di bagian respons GraphQL. data error Namun, AWS AppSync DynamoDB resolver menawarkan beberapa fitur tambahan untuk membantu pengembang menangani beberapa kasus tepi umum:

Ini dijelaskan secara lebih rinci di bagian Penanganan Kegagalan Pemeriksaan Kondisi.

Untuk informasi selengkapnya tentang ekspresi kondisi DynamoDB, lihat dokumentasi DynamoDB. ConditionExpressions

Menentukan suatu kondisi

Dokumen pemetaan PutItemUpdateItem,, dan DeleteItem permintaan semuanya memungkinkan condition bagian opsional untuk ditentukan. Jika dihilangkan, tidak ada pemeriksaan kondisi yang dilakukan. Jika ditentukan, kondisi harus benar agar operasi berhasil.

conditionBagian memiliki struktur sebagai berikut:

"condition" : {
    "expression" : "someExpression"
    "expressionNames" : {
        "#foo" : "foo"
    },
    "expressionValues" : {
        ":bar" : ... typed value
    },
    "equalsIgnore" : [ "version" ],
    "consistentRead" : true,
    "conditionalCheckFailedHandler" : {
        "strategy" : "Custom",
        "lambdaArn" : "arn:..."
    }
}

Bidang berikut menentukan kondisi:

Bidang yang tersisa memberi tahu AWS AppSync DynamoDB resolver cara menangani kegagalan pemeriksaan kondisi:

Menangani kegagalan pemeriksaan kondisi

Secara default, ketika pemeriksaan kondisi gagal, penyelesai AWS AppSync DynamoDB mengembalikan kesalahan untuk mutasi dan nilai objek saat ini di DynamoDB di bidang di bagian respons GraphQL. data error Namun, AWS AppSync DynamoDB resolver menawarkan beberapa fitur tambahan untuk membantu pengembang menangani beberapa kasus tepi umum:

Diagram alur untuk proses ini adalah:

Memeriksa hasil yang diinginkan

Ketika pemeriksaan kondisi gagal, penyelesai AWS AppSync DynamoDB melakukan permintaan DynamoDB GetItem untuk mendapatkan nilai item saat ini dari DynamoDB. Secara default, ini menggunakan pembacaan yang sangat konsisten, namun ini dapat dikonfigurasi menggunakan consistentRead bidang di condition blok dan membandingkannya dengan hasil yang diharapkan:

Jika status objek saat ini di DynamoDB berbeda dari hasil yang diharapkan, penyelesai AWS AppSync DynamoDB mengikuti strategi yang dikonfigurasi, untuk menolak mutasi atau memanggil fungsi Lambda untuk menentukan apa yang harus dilakukan selanjutnya.

Mengikuti strategi “tolak”

Saat mengikuti Reject strategi, penyelesai AWS AppSync DynamoDB mengembalikan kesalahan untuk mutasi, dan nilai objek saat ini di DynamoDB juga dikembalikan dalam bidang di bagian respons GraphQL. data error Item yang dikembalikan dari DynamoDB dimasukkan melalui template pemetaan respons untuk menerjemahkannya ke dalam format yang diharapkan klien, dan difilter oleh set pilihan.

Misalnya, diberikan permintaan mutasi berikut:

mutation {
    updatePerson(id: 1, name: "Steve", expectedVersion: 1) {
        Name
        theVersion
    }
}

Jika item yang dikembalikan dari DynamoDB terlihat seperti berikut:

{
   "id" : { "S" : "1" },
   "name" : { "S" : "Steve" },
   "version" : { "N" : 8 }
}

Dan template pemetaan respons terlihat seperti berikut:

{
   "id" : $util.toJson($context.result.id),
   "Name" : $util.toJson($context.result.name),
   "theVersion" : $util.toJson($context.result.version)
}

Respons GraphQL terlihat seperti berikut:

{
  "data": null,
  "errors": [
    {
      "message": "The conditional request failed (Service: AmazonDynamoDBv2; Status Code: 400; Error Code: ConditionalCheckFailedException; Request ID: ABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZ)"
      "errorType": "DynamoDB:ConditionalCheckFailedException",
      "data": {
        "Name": "Steve",
        "theVersion": 8
      },
      ...
    }
  ]
}

Juga, jika ada bidang dalam objek yang dikembalikan diisi oleh resolver lain dan mutasi telah berhasil, mereka tidak akan diselesaikan ketika objek dikembalikan di bagian. error

Mengikuti strategi “kustom”

Saat mengikuti Custom strategi, penyelesai AWS AppSync DynamoDB memanggil fungsi Lambda untuk memutuskan apa yang harus dilakukan selanjutnya. Fungsi Lambda memilih salah satu opsi berikut:

Permintaan doa Lambda

Penyelesai AWS AppSync DynamoDB memanggil fungsi Lambda yang ditentukan dalam. lambdaArn Ini menggunakan service-role-arn konfigurasi yang sama pada sumber data. Muatan doa memiliki struktur sebagai berikut:

{
    "arguments": { ... },
    "requestMapping": {... },
    "currentValue": { ... },
    "resolver": { ... },
    "identity": { ... }
}

Bidang didefinisikan sebagai berikut:

Contoh lengkap dari muatan:

{
    "arguments": {
        "id": "1",
        "name": "Steve",
        "expectedVersion": 1
    },
    "requestMapping": {
        "version" : "2017-02-28",
        "operation" : "PutItem",
        "key" : {
           "id" : { "S" : "1" }
        },
        "attributeValues" : {
           "name" : { "S" : "Steve" },
           "version" : { "N" : 2 }
        },
        "condition" : {
           "expression" : "version = :expectedVersion",
           "expressionValues" : {
               ":expectedVersion" : { "N" : 1 }
           },
           "equalsIgnore": [ "version" ]
        }
    },
    "currentValue": {
        "id" : { "S" : "1" },
        "name" : { "S" : "Steve" },
        "version" : { "N" : 8 }
    },
    "resolver": {
        "tableName": "People",
        "awsRegion": "us-west-2",
        "parentType": "Mutation",
        "field": "updatePerson",
        "outputType": "Person"
    },
    "identity": {
        "accountId": "123456789012",
        "sourceIp": "x.x.x.x",
        "user": "AIDAAAAAAAAAAAAAAAAAA",
        "userArn": "arn:aws:iam::123456789012:user/appsync"
    }
}

Tanggapan Doa Lambda

Fungsi Lambda dapat memeriksa payload pemanggilan dan menerapkan logika bisnis apa pun untuk memutuskan bagaimana penyelesai AWS AppSync DynamoDB harus menangani kegagalan. Ada tiga opsi untuk menangani kegagalan pemeriksaan kondisi:

Berikut adalah contoh fungsi Lambda untuk menangani permintaan yang gagalPutItem. Logika bisnis melihat siapa yang membuat panggilan. Jika dibuat olehjeffTheAdmin, ia mencoba ulang permintaan, memperbarui version dan expectedVersion dari item yang saat ini ada di DynamoDB. Jika tidak, ia menolak mutasi.

exports.handler = (event, context, callback) => {
    console.log("Event: "+ JSON.stringify(event));

    // Business logic goes here.

    var response;
    if ( event.identity.user == "jeffTheAdmin" ) {
        response = {
            "action" : "retry",
            "retryMapping" : {
                "attributeValues" : event.requestMapping.attributeValues,
                "condition" : {
                    "expression" : event.requestMapping.condition.expression,
                    "expressionValues" : event.requestMapping.condition.expressionValues
                }
            }
        }
        response.retryMapping.attributeValues.version = { "N" : event.currentValue.version.N + 1 }
        response.retryMapping.condition.expressionValues[':expectedVersion'] = event.currentValue.version

    } else {
        response = { "action" : "reject" }
    }

    console.log("Response: "+ JSON.stringify(response))
    callback(null, response)
};