สถาปัตยกรรมแบบไร้เซิร์ฟเวอร์:AWS Lambda, Upstash Redis &Go สำหรับแอปที่ปรับขนาดได้และคุ้มค่า

จากนั้นรัน 291 เพื่อดึงข้อมูลการอ้างอิงโค้ดทั้งหมด อย่าลืมเรียกใช้สิ่งนี้ทุกครั้งที่คุณเพิ่มหรือลบการขึ้นต่อกันของ Go

สุดท้ายให้รัน 303 หนึ่งครั้ง เพื่อสร้างทุกอย่างและตรวจสอบให้แน่ใจว่าพื้นที่ทำงานของคุณได้รับการตั้งค่าแล้ว ก่อนที่เราจะเจาะลึกโค้ด

2. การใช้งาน API

สำหรับส่วนนี้ เราจะทำงานภายใน 318 เสมอ ไฟล์

สองสามบรรทัดต่อไปนี้จะกำหนดตำแหน่งข้อมูล API ที่เรากล่าวถึงก่อนหน้านี้ โดยใช้ 321 ที่น่าทึ่ง ห้องสมุด

import (
 //...
 "github.com/go-chi/chi/v5"
 "github.com/go-chi/chi/v5/middleware"
)
 
func NewMux() *chi.Mux {
 r := chi.NewRouter()
 
 r.Use(middleware.RequestID)
 r.Use(middleware.Logger)
 r.Use(middleware.Recoverer)
 
 r.Get("/login", login)
 r.Post("/login", login)
 r.Group(func(r chi.Router) {
 r.Use(UsersWithSessionOnly)
 r.Get("/lessons/completed", listLessonsCompleted)
 r.Post("/lessons/{lessonSlug}/mark-complete", markLessonComplete)
 })
 
 return r
}

ในตัวอย่างด้านบน 331 สร้างเลเยอร์ที่ใช้ร่วมกันซึ่งเราสามารถใช้มิดเดิลแวร์ทั่วไปสำหรับเส้นทางใด ๆ ที่กำหนดไว้ภายในนั้น ในกรณีนี้ เราจะเพิ่มมิดเดิลแวร์ของเราเอง 344 ซึ่งดังที่เราจะเห็นในภายหลังรับประกันว่าคำขอมีคุกกี้ที่มีรหัสเซสชันที่ใช้งานอยู่

2.1 UsersWithSessionOnly มิดเดิลแวร์

ในมิดเดิลแวร์นี้ เราต้องการใช้สิ่งต่อไปนี้:

1. แยกคุกกี้ที่มีรหัสเซสชันและล้มเหลวมิฉะนั้น
2. ค้นหา Redis เพื่อดึงรายละเอียดผู้ใช้ตามรหัสเซสชัน และล้มเหลวหากรหัสเซสชันที่ระบุไม่ทำงาน
3. จัดเก็บ ID ผู้ใช้ในคำขอ 354 เพื่อให้พร้อมใช้งานสำหรับมิดเดิลแวร์หรือตัวจัดการดาวน์สตรีม

ขั้นแรก เราต้องการโค้ดสำเร็จรูปสำหรับการนำเข้าและคำจำกัดความบางอย่างที่ใช้ทุกที่

import (
 //...
 "log"
 "os"
 "strings"
 
 "github.com/go-redis/redis/v8"
)
 
type contextKey struct {
 name string
}
const (
 COOKIE_AUTH_NAME = "xxx_session_id"
)
var (
 CTX_USER_ID = &contextKey{"LoggedInUserId"}
 redisDb = NewClient()
)
 
func NewClient() *redis.Client {
 redisUrl := strings.TrimSpace(os.Getenv("UPSTASH_REDIS_URL"))
 if redisUrl == "" {
 log.Fatalln("Required env UPSTASH_REDIS_URL not set!")
 }
 opt, _ := redis.ParseURL(redisUrl)
 redisDb := redis.NewClient(opt)
 
 return redisDb
}

และตอนนี้ตรรกะหลักสำหรับมิดเดิลแวร์การรับรองความถูกต้อง

// UsersWithSessionOnly middleware restricts access to just logged-in users.
// If validation passes, then the context will contain the user id (CTX_USER_ID).
func UsersWithSessionOnly(next http.Handler) http.Handler {
 return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 c, err := r.Cookie(COOKIE_AUTH_NAME)
 if err != nil {
 render.Status(r, http.StatusForbidden)
 render.JSON(w, r, struct{}{})
 return
 }
 
 ctx := r.Context()
 userId, err := redisDb.Get(ctx, "session:"+c.Value).Result()
 if err == redis.Nil {
 // If session is not found then user is forbidden from accessing the API!
 render.Status(r, http.StatusForbidden)
 render.JSON(w, r, struct{}{})
 return
 } else if err != nil {
 // Something went wrong querying Redis!
 render.Status(r, http.StatusInternalServerError)
 render.JSON(w, r, struct{ Message string }{Message: "We could not validate the provided session ID"})
 return
 }
 // Set it for downstream middleware and handlers.
 next.ServeHTTP(w, r.WithContext(context.WithValue(ctx, CTX_USER_ID, userId)))
 })
}

2.2 markLessonComplete(...)

นี่เป็นการดำเนินการตรงไปตรงมาซึ่งเราต้องการเก็บไว้ใน Redis ซึ่งบทเรียนแสดงด้วย 365 พารามิเตอร์เส้นทางเสร็จสมบูรณ์ในเวลาปัจจุบันของคำขอ

ใน Redis เราต้องการเก็บแผนที่สำหรับผู้ใช้แต่ละราย โดยแต่ละคู่คีย์-ค่าในแผนที่จะเป็นบทเรียนเป็นคีย์ และวันที่เสร็จสมบูรณ์เป็นมูลค่า ดังนั้นเราจึงใช้ 373 คำสั่งเรดดิส นอกจากนี้เรายังสามารถจัดเก็บคีย์แยกต่างหากต่อบทเรียนได้ แต่จะทำให้ง่ายต่อการดึงบทเรียนทั้งหมดสำหรับผู้ใช้ในคราวเดียวในภายหลัง

func markLessonComplete(w http.ResponseWriter, r *http.Request) {
 ctx := r.Context()
 lessonSlug := chi.URLParam(r, "lessonSlug")
 userId := r.Context().Value(CTX_USER_ID).(string)
 timeNow := time.Now().Format(time.RFC3339)
 
 err := redisDb.HSet(ctx, "lessons:"+userId, lessonSlug, timeNow).Err()
 if err != nil {
 render.Status(r, http.StatusInternalServerError)
 render.JSON(w, r, struct{ Message string }{Message: "We could not save your progression..."})
 return
 }
 
 render.JSON(w, r, struct {
 LessonSlug string
 LastCompleted string
 }{
 lessonSlug,
 timeNow,
 })
}

2.3 รายการบทเรียนเสร็จสมบูรณ์(...)

ในทำนองเดียวกันกับส่วนก่อนหน้า ที่นี่เราเพียงต้องการส่งคืนแผนผังบทเรียนที่สมบูรณ์ทั้งหมด และส่งคืนให้กับผู้ใช้ในการตอบกลับ JSON เราใช้ 388 คำสั่งสำหรับสิ่งนี้

func listLessonsCompleted(w http.ResponseWriter, r *http.Request) {
 ctx := r.Context()
 userId := r.Context().Value(CTX_USER_ID).(string)
 
 lessons, err := redisDb.HGetAll(ctx, "lessons:"+userId).Result()
 if err == redis.Nil {
 lessons = map[string]string{}
 } else if err != nil {
 render.Status(r, http.StatusInternalServerError)
 render.JSON(w, r, struct{ Message string }{Message: "We could not load your lessons..."})
 return
 }
 
 render.JSON(w, r, struct {
 Lessons map[string]string
 }{
 lessons,
 })
}

2.4 เข้าสู่ระบบ(...)

ในที่สุดปลายทางการเข้าสู่ระบบ โปรดอย่าคัดลอกโค้ดต่อไปนี้ลงในการใช้งานจริงอีกครั้ง เนื่องจากไม่ได้ทำการตรวจสอบใดๆ สำหรับวัตถุประสงค์ของบทความนี้ เราสนใจเฉพาะวิธีที่ Redis สืบค้น และวิธีตั้งค่าคุกกี้สำหรับ ID เซสชัน

รหัสเซสชันถูกสร้างขึ้นโดย 391 ไลบรารี่ซึ่งมีข้อได้เปรียบเหนือ UUID ทั่วไปเล็กน้อย และเราถือว่ามันใช้งานได้เพียง 1 ชั่วโมงเท่านั้น เราใช้ฟังก์ชันการทำงานตามเวลาจริงของ Redis 400 คำสั่งสำหรับการลบออกจากฐานข้อมูลโดยอัตโนมัติหลังจากหนึ่งชั่วโมง

import (
 // ...
 "github.com/segmentio/ksuid"
)
 
func login(w http.ResponseWriter, r *http.Request) {
 // Check credentials and update redis session and return Set-Cookie
 // WARNING: You should do an actual validation in production for credentials!
 // ...
 // For now we always assume correctness and automatically create a session token
 // by saving it to Redis, and also setting it as a cookie.
 userId := strings.TrimSpace(r.FormValue("userId"))
 if userId == "" {
 render.Status(r, http.StatusBadRequest)
 render.JSON(w, r, struct{ Message string }{Message: "Missing required userId"})
 return
 }
 
 sessionId := ksuid.New()
 redisDb.Set(r.Context(), "session:"+sessionId.String(), userId, time.Hour*1)
 http.SetCookie(w, &http.Cookie{
 Name: COOKIE_AUTH_NAME, Value: sessionId.String(),
 Path: "/", MaxAge: int((time.Hour * 1).Seconds()),
 // This should be true when deploying in production (https), but locally we need it false (http).
 Secure: false,
 })
 
 http.Redirect(w, r, "/lessons/completed", http.StatusTemporaryRedirect)
}

3. สาธิต - ภายในเครื่อง

วุ้ย นั่นเป็นโค้ดเยอะมาก😅

มาสาธิตสั้นๆ เพื่อให้แน่ใจว่าทุกอย่างทำงานได้ตามที่คาดหวัง

• ขั้นแรก ให้ตั้งค่า 417 ตัวแปรสภาพแวดล้อมเป็น URL ของฐานข้อมูลที่คุณสร้างในส่วนที่ 1 ด้านบน คุณสามารถดูได้ในรายละเอียด ของหน้าฐานข้อมูลของคุณ (ดูหัวข้อ 1.1 ด้านบน)

export UPSTASH_REDIS_URL="<your-url-here>"

• จากนั้น สร้างและเรียกใช้เซิร์ฟเวอร์ภายในเครื่อง:

make build-server && ./build/server

การทดสอบเบราว์เซอร์

ตอนนี้เรามาทำการทดสอบในเบราว์เซอร์โดยไปที่ http://localhost:5000/lessons/completed

เราได้รับ 423 ดังนั้นมาเข้าสู่ระบบกันดีกว่า โดยไปที่ http://localhost:5000/login?userId=lambros

เราเข้าสู่ระบบแล้ว และเราจะถูกเปลี่ยนเส้นทางไปที่ 434 โดยอัตโนมัติ แต่พวกมันว่างเปล่า ดังนั้น เรามาทำเครื่องหมายบทเรียนว่าเสร็จสมบูรณ์แล้ว ใน 448 แท็บภายใน devtools ของเบราว์เซอร์ของคุณเรียกใช้สิ่งต่อไปนี้:

await (
 await fetch("http://localhost:5000/lessons/123/mark-complete", {
 method: "POST",
 credentials: "same-origin",
 })
).json();
 
// Should output something like:
// {LessonSlug: '123', LastCompleted: '2022-10-12T02:01:14+03:00'}

การเยี่ยมชม http://localhost:5000/lessons/completed ควรแสดงบทเรียนนี้ว่าทำเครื่องหมายไว้แล้ว:

{ "Lessons": { "123": "2022-10-12T02:01:14+03:00" } }

ได้เลย. ทุกอย่างทำงานได้ดี!

การดูฐานข้อมูล Redis โดยใช้ Data Browser ออนไลน์ที่เพิ่งเปิดตัวเมื่อเร็วๆ นี้ ยังพิสูจน์ได้ว่ามีข้อมูลที่คาดหวังอยู่ที่นั่น

4. AWS แลมบ์ดา

เพื่อทดสอบและปรับใช้กับ AWS Lambda เราจะใช้ 453 คลิก

• ขั้นแรก ให้ตั้งค่า SAM cli และตรวจสอบให้แน่ใจว่าผู้ใช้/บทบาทของคุณมีสิทธิ์ที่ถูกต้อง

• 464 cli ต้องใช้เทมเพลต Cloudformation จึงจะทำงานได้ ดังนั้นให้คัดลอกสิ่งต่อไปนี้ลงใน 477 :

AWSTemplateFormatVersion: "2010-09-09"
Transform: AWS::Serverless-2016-10-31
Description: Defines all the AWS resources we need for our Upstash Redis API.
 
Resources:
 # https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/sam-resource-function.html
 GoUpstashRedis:
 Type: AWS::Serverless::Function
 Properties:
 CodeUri: ../build/handler.zip
 Handler: handler
 Runtime: go1.x
 MemorySize: 512
 FunctionUrlConfig:
 AuthType: NONE
 Cors:
 AllowCredentials: false
 AllowMethods: ["*"]
 AllowOrigins: ["*"]
 
Outputs:
 GoUpstashRedisApi:
 Description: "Endpoint URL"
 Value: !GetAtt GoUpstashRedisUrl.FunctionUrl
 GoUpstashRedis:
 Description: "Lambda Function ARN"
 Value: !GetAtt GoUpstashRedis.Arn
 GoUpstashRedisIamRole:
 Description: "Implicit IAM Role created for GoUpstashRedis"
 Value: !GetAtt GoUpstashRedisRole.Arn

make build-lambda

sam-deploy: build-lambda
 sam deploy -t aws-iac/sam-template.yml --stack-name "UpstashRedisGoArticleStackDemo" --region eu-west-1 --resolve-s3 --no-confirm-changeset --no-fail-on-empty-changeset --capabilities CAPABILITY_IAM CAPABILITY_NAMED_IAM CAPABILITY_AUTO_EXPAND

make sam-deploy

CloudFormation outputs from deployed stack
-----------------------------------------------------------------------------------------------------------------------------------------------------------
Outputs
-----------------------------------------------------------------------------------------------------------------------------------------------------------
Key GoUpstashRedis
Description Lambda Function ARN
Value arn:aws:lambda:eu-west-1:<redacted>:function:UpstashRedisGoArticleStackDem-GoUpstashRedis-baB8dQPkTfg0
 
Key GoUpstashRedisIamRole
Description Implicit IAM Role created for GoUpstashRedis
Value arn:aws:iam::<redacted>:role/UpstashRedisGoArticleStac-GoUpstashRedisRole-16UWC7HR6KII8
 
Key GoUpstashRedisApi
Description Endpoint URL
Value https://6pmmwqmg5vec3bcsldabckaf5i0nlgje.lambda-url.eu-west-1.on.aws/
-----------------------------------------------------------------------------------------------------------------------------------------------------------
 
Successfully created/updated stack - UpstashRedisGoArticleStackDemo in eu-west-1

sam local invoke -t aws-iac/sam-template.yml -e sample-event.json