Ravindra BagaleCourses & study guides English

Project: SQS, Lambda आणि DynamoDB ने Async Order API बनवा (Source Code)

By , trainer LinkedIn Last updated:

Flash-sale: order लगेच accept, नंतर process. Intake → SQS; worker → DynamoDB.

या chapter मध्ये तुम्ही काय शिकाल

  • Worker पुढे queue का
  • SQS + worker + table
  • 202 Accepted
  • Cleanup

1. रोजचं उदाहरण

हे का लागतं?

शेकडो Place order — slow path timeout. SQS spike absorb; workers drain.

हे काय आहे?

HTTP API → intake → SQS → worker → DynamoDB. Client ला 202.

Async मार्गClientPOSTIntakeSendMessageSQSWorkerDynamoDB
Worker slow तरी API जलद.

Download: async-order-api.zip

2. Lab

कसं करायचं (step by step)

A. Queue + table

  1. SQS queue. URL copy.
  2. Table PK orderId.

B. Worker

  1. Role: SQS + PutItem.
  2. Worker + SQS trigger.

C. Intake API

  1. Intake + QUEUE_URL.
  2. POST /orders.
curl -s -X POST "$API_BASE/orders" -H 'content-type: application/json' \
  -d '{"sku":"TEE-RED","qty":2}'
# wait ~2s — DynamoDB item status accepted

Cleanup

  1. Trigger, Lambdas, API, queue, table, roles.

3. Interview

प्र. 202 का?

Async accept.

प्र. Standard vs FIFO?

Lab ला Standard.

प्र. Worker fail?

Retry + DLQ.

प्र. Native SQS?

शक्य; lab मध्ये intake.

प्र. Cleanup?

Queue, Lambdas, API, table.

घरी करून बघा

  1. DLQ after 3.
  2. GET /orders/{id}.

थोडक्यात सांगायचं तर

  1. Async = intake → SQS → worker → DynamoDB.
  2. 202 API जलद.
  3. Triggers + IAM.
  4. Queues cleanup.

सराव Tasks

या scenario बद्दल

Dubai Gold Souk हा दुबई मधला दागिने व्यवसाय आहे. Fatima Al Mansoori त्यांचं IT व cloud काम पाहतात. त्यांचे पैसे AED मध्ये मोजले जातात आणि AWS resources me-central-1 Region मध्ये चालतात. खालच्या tasks मध्ये तुम्ही या lesson मध्ये शिकलेलं वापरून त्यांची खरी कामं करता. सगळी नावं, account IDs, IP addresses व numbers सरावासाठी काल्पनिक आहेत.

0 / 12

सोपं Functions ची list

का: या Region मध्ये कोणते functions आहेत ते पाहा.

काय करायचं: me-central-1 मधले Lambda functions दाखवा.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

मध्यम Function invoke करा

का: Invoke function आत्ता चालवतो व उत्तर file मध्ये ठेवतो.

काय करायचं: dubaigold-orders-fn invoke करा व response out.json मध्ये ठेवा.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

मध्यम Lambda role साठी trust policy

का: Trust policy role कोण घेऊ शकतो ते सांगते.

काय करायचं: lambda.amazonaws.com ला role assume करू देणारी trust policy लिहा.

कसं करायचं:
  1. { "Version": "2012-10-17", "Statement": [ ... ] } ने सुरू करा.
  2. प्रत्येक statement मध्ये Effect, Action व Resource लिहा.
  3. Task ला लागेल तेवढंच द्या (least privilege).
  4. Double quotes व commas नीट वापरा. Check answer दाबा.

मध्यम Item टाका

का: DynamoDB JSON प्रत्येक value चा type दाखवतो: S string, N number.

काय करायचं: dubaigold-orders मध्ये orderId "o-101" (string) व amount 2500 (number) असलेला item टाका.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

मध्यम Timeout व memory बदला

का: जास्त memory म्हणजे जास्त CPU; timeout अडकलेले runs थांबवतो.

काय करायचं: dubaigold-orders-fn चा timeout 30 seconds व memory 512 MB करा.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

मध्यम Function ला logs लिहू द्या

का: या actions शिवाय Lambda logs CloudWatch मध्ये दिसत नाहीत.

काय करायचं: फक्त arn:aws:logs:*:*:* वर logs:CreateLogGroup, logs:CreateLogStream, logs:PutLogEvents allow करा.

कसं करायचं:
  1. { "Version": "2012-10-17", "Statement": [ ... ] } ने सुरू करा.
  2. प्रत्येक statement मध्ये Effect, Action व Resource लिहा.
  3. Task ला लागेल तेवढंच द्या (least privilege).
  4. Double quotes व commas नीट वापरा. Check answer दाबा.

अवघड SQS queue Lambda ला जोडा

का: Event source mapping मुळे Lambda queue poll करून batches मध्ये messages process करतो.

काय करायचं: Queue arn:aws:sqs:me-central-1:112884599412:dubaigold-orders पासून dubaigold-orders-fn ला batch size 10 सह event source mapping बनवा.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

अवघड Lambda function बनवा

का: Lambda ला code zip, runtime, handler नाव व execution role लागतो.

काय करायचं: dubaigold-orders-fn function बनवा: runtime python3.12, handler app.handler, role arn:aws:iam::112884599412:role/lambda-basic, code function.zip मध्ये.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

अवघड Environment variables द्या

का: Table नावांसारख्या settings code बाहेर ठेवा.

काय करायचं: dubaigold-orders-fn वर environment variable TABLE=dubaigold-orders द्या.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

अवघड JSON payload सह invoke करा

का: CLI v2 मध्ये raw JSON साठी --cli-binary-format raw-in-base64-out लागतो.

काय करायचं: dubaigold-orders-fn ला payload {"orderId":"o-101"} (raw JSON) सह invoke करा व उत्तर out.json मध्ये.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

अवघड Lambda GB-seconds

का: Lambda memory × time bill करतो.

काय करायचं: 1,000,000 invocations, 512 MB, प्रत्येकी 200 ms. किती GB-seconds?

कसं करायचं:
  1. Task मधले numbers लिहून घ्या.
  2. कागदावर step by step काढा.
  3. Box मध्ये फक्त final उत्तर लिहा.
  4. Check answer दाबा.

अवघड S3 ला function call करू द्या

का: S3 function invoke करण्याआधी resource-based permission लागते.

काय करायचं: dubaigold-orders-fn ला s3invoke permission statement द्या: s3.amazonaws.com ने bucket arn:aws:s3:::dubaigold-uploads कडून lambda:InvokeFunction करावं.

कसं करायचं:
  1. Task वाचा आणि ते कोणत्या AWS service बद्दल आहे ते ठरवा.
  2. aws लिहा, मग service चं नाव, मग operation (action शब्द).
  3. प्रत्येक आवश्यक flag (--name) व त्यापुढे task मधली value लिहा.
  4. Flags कोणत्याही क्रमाने चालतात. Check answer दाबा.

सगळे सराव tasks Task Hub मध्ये पाहा →

उजळणी, तुलना आणि मुलाखत cards

हा lesson काही मिनिटांत revise करा. Cards phone वर save करा किंवा PNG download करा. प्रत्येक card वरचा QR हा lesson उघडतो.

उजळणी card: Async order API का?. Checkout inventory/fraud/email ची वाट पाहिली की spinner + retries. API जलद 202 → SQS message → worker Lambda नंतर DynamoDB. Queue + table + intake + worker + POST /orders. POST → 202; ~2 s नंतर DynamoDB accepted.
उजळणी card: Async order API का? · PNG download करा · Card page उघडा
उजळणी card: SQS म्हणजे buffer. Flash sale एका Lambda concurrency ला बुडवू शकतो. काम safely थांबायला हवं. SQS = managed queue. SendMessage → नंतर receive. Lab ला Standard. Queue → IAM → SQS trigger batch 5. Worker slow → queue depth वाढतो; API तरी 202.
उजळणी card: SQS म्हणजे buffer · PNG download करा · Card page उघडा
उजळणी card: HTTP 202 vs 201. Status codes success चा अर्थ सांगतात. चुकीचे codes → retries गोंधळ. 201 = पूर्ण create. 202 = स्वीकारलं, process बाकी. Intake 202 + orderId; worker async row. App “Order received” दाखवतो; नंतर GET status.
उजळणी card: HTTP 202 vs 201 · PNG download करा · Card page उघडा
तुलना: Sync API to DynamoDB vs Async API via SQS. Sync API to DynamoDB: Caller row लिह्येपर्यंत वाट पाहतो. Async API via SQS: Caller ला 202; worker नंतर लिहितो.
तुलना: Sync API to DynamoDB vs Async API via SQS · PNG download करा · Card page उघडा
मुलाखत card: 202 Accepted कधी?. काम async पूर्ण होणार — accepted. 201 = पूर्ण create दावा. SendMessage → 202; worker नंतर write.
मुलाखत card: 202 Accepted कधी? · PNG download करा · Card page उघडा
मुलाखत card: Worker सतत fail झाला तर?. Visibility नंतर पुन्हा; maxReceiveCount → DLQ. Poison messages वेगळे; debug साठी copy. Redrive maxReceiveCount=3.
मुलाखत card: Worker सतत fail झाला तर? · PNG download करा · Card page उघडा
मुलाखत card: Lab साठी Standard की FIFO?. Strict order/dedupe नको तर Standard पुरेसं. FIFO = order + dedupe; throughput कमी. Lab Standard; per-customer strict order → FIFO.
मुलाखत card: Lab साठी Standard की FIFO? · PNG download करा · Card page उघडा

अजून cards: Ravi Sir's Cards.