Bagaimana untuk membetulkan ralat permintaan dynamodb Query?

editor php Yuzai mempersembahkan kepada anda: Bagaimana untuk membetulkan ralat permintaan dynamodb Pertanyaan? DynamoDB ialah perkhidmatan pangkalan data NoSQL berskala tinggi yang disediakan oleh Amazon. Apabila menggunakan DynamoDB untuk membuat pertanyaan, anda mungkin menghadapi pelbagai ralat yang menjejaskan operasi normal sistem. Untuk membetulkan ralat ini, anda perlu menyemak dengan teliti ketepatan pernyataan pertanyaan dan memastikan parameter yang disediakan dan struktur jadual sepadan. Selain itu, anda juga boleh meningkatkan prestasi pertanyaan dengan meningkatkan Kapasiti Baca dan menggunakan indeks yang sesuai untuk mengoptimumkan kelajuan pertanyaan. Selain itu, memahami dan mengikuti amalan terbaik DynamoDB, seperti penggunaan rasional operasi kelompok dan ungkapan bersyarat, juga boleh mengelakkan ralat pertanyaan dengan berkesan. Melalui kaedah di atas, anda boleh membetulkan dan mengoptimumkan ralat dalam pertanyaan DynamoDB dengan mudah dan meningkatkan kestabilan dan prestasi sistem.

Kandungan soalan

Dalam dynamodb, saya mempunyai jadual yang mengandungi:

- email (primary key)
- password (attribute)
- rname (attribute)

Saya menggunakan aws go sdk v1 untuk melaksanakan pertanyaan menggunakan kunci utama pangkalan data sahaja:

Struktur yang saya ingin unmarshal ialah:

type item struct {
    email    string `json:"email"`
    password string `json:"password"`
    rname    string `json:"rname"`
}

dan kod:

result, err := client.Query(&dynamodb.QueryInput{
        TableName: aws.String("accountsTable"),
        KeyConditions: map[string]*dynamodb.Condition{
            "email": {
                ComparisonOperator: aws.String("EQ"),
                AttributeValueList: []*dynamodb.AttributeValue{
                    {
                        S: aws.String(email),
                    },
                },
            },
        },
    })
    if err != nil {
        return false, err
    }

    item := []Item{}

    err = dynamodbattribute.UnmarshalListOfMaps(result.Items, &item)
    if err != nil {
        return false, err
    }

Walau bagaimanapun, saya mendapat isu utama yang tidak sah. Saya menyemak kunci dalam pangkalan data dan ia juga sepadan dengan kunci yang saya cetak ke konsol.

Tidak pasti cara membetulkannya kerana contoh yang saya lihat nampaknya sesuai untuk contoh mereka dan kelihatan sama.

Sebarang bantuan untuk menyelesaikan isu ini amatlah dihargai :)

Penyelesaian

Anda perlu menetapkan nilai kata laluan dan nama kepada omitempty supaya ia tidak ditetapkan kepada null kerana ia bukan kunci dan ia tidak sepatutnya dimasukkan dalam pertanyaan , kerana ia membuang pengecualian kunci yang tidak sah:

type item struct {
    email    string `json:"email" dynamodbav:"email,omitempty"`
    password string `json:"password" dynamodbav:"password,omitempty"`
    rname    string `json:"rname" dynamodbav:"rname,omitempty"`
}

Kemas kini

Saya rasa masalahnya adalah disebabkan anda cuba menyusun keseluruhan respons ke dalam satu arahan, namun, lelaran berfungsi untuk saya. (Saya tidak menggunakan go).

package main
import (
    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/dynamodb"
    "github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"

    "fmt"
)


func main() {

    // create session
    sess := session.must(session.newsessionwithoptions(session.options{
        sharedconfigstate: session.sharedconfigenable,
    }))

    // create dynamodb client with logging
    client := dynamodb.new(sess, aws.newconfig())


    type item struct {
        email    string `dynamodbav: "email"`
        password string `dynamodbav: "password,omitempty"`
        rname    string `dynamodbav: "rname,omitempty"`
    }

    result, err := client.query(&dynamodb.queryinput{
        tablename: aws.string("accountstable"),
        keyconditions: map[string]*dynamodb.condition{
            "email": {
                comparisonoperator: aws.string("eq"),
                attributevaluelist: []*dynamodb.attributevalue{
                    {
                        s: aws.string("<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="aec2c6c0c0c9eecfc3cfd4c1c080cdc1c3">[email&#160;protected]</a>"),
                    },
                },
            },
        },
    })

    if err != nil {
        fmt.println("query api call failed:")
        fmt.println((err.error()))
    }



    for _, i := range result.items {
        
        item := item{}
        err = dynamodbattribute.unmarshalmap(i, &item)
    
        if err != nil {
            fmt.println("got error unmarshalling: %s", err)
        }
    
        fmt.println("email: ", item.email)
        fmt.println()
        
    }
}

Selain itu, apabila anda menggunakan email 的单个密钥时，这意味着最多有 1 个项目具有相同的电子邮件地址，这意味着您应该使用 getitem 而不是 query:

package main

import (
    "fmt"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/dynamodb"
    "github.com/aws/aws-sdk-go/service/dynamodb/dynamodbattribute"
)

func main() {

    // Item to Get
    type Item struct {
        Email    string `dynamodbav: "email"`
        Password string `dynamodbav: "password,omitempty"`
        Rname    string `dynamodbav: "rname,omitempty"`
    }

    // Create Session
    sess := session.Must(session.NewSessionWithOptions(session.Options{
        SharedConfigState: session.SharedConfigEnable,
    }))

    // Create DynamoDB Client
    client := dynamodb.New(sess, aws.NewConfig())

    // Get Item
    result, err := client.GetItem(&dynamodb.GetItemInput{
        TableName: aws.String("accountsTable"),
        Key: map[string]*dynamodb.AttributeValue{
            "email": {
                S: aws.String("<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="4a262224242d0a2b272b30252464292527">[email&#160;protected]</a>"),
            },
        },
    })

    // Catch Error
    if err != nil {
        fmt.Println("GetItem API call failed:")
        fmt.Println((err.Error()))
    }

    item := Item{}

    // Unmarhsall
    err = dynamodbattribute.UnmarshalMap(result.Item, &item)

    if err != nil {
        panic(fmt.Sprintf("Failed to unmarshal Record, %v", err))
    }

    // If Item Returns Empty
    if item.Email == "" {
        fmt.Println("Could not find Item")
        return
    }

    // Print Result
    fmt.Println("Found item:")
    fmt.Println("Email:  ", item.Email)

}

Atas ialah kandungan terperinci Bagaimana untuk membetulkan ralat permintaan dynamodb Query?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!