Event-driven architecture essentials

AWS Lambda के साथ Serverless Applications

Claudio Canales

Senior DevOps Engineer

Recap: one Lambda mental model

Event source: क्या Lambda को ट्रिगर करता है.
Event payload: जो हुआ उसका JSON.
Handler: उसे प्रोसेस करने वाला कोड.
Outcome: प्रतिक्रिया या साइड इफेक्ट.
Logs: जहाँ आप डीबग करते हैं.

Lambda execution flow

Events are messages

एक event बताता है क्या हुआ.
यह आमतौर पर metadata वाला JSON मैसेज होता है.
आपका handler फ़ील्ड निकालकर कार्रवाई करता है.

Events के लिए डोरबेल सादृश्य

Common event sources in AWS

Amazon S3 अपलोड पर events ट्रिगर करता है.
Amazon SQS एक managed queue है जो messages डिलीवर करता है.
DynamoDB Streams change log बनाता है.
हर एक अलग JSON payload देता है.

Event sources: S3 vs SQS vs Streams

Synchronous vs asynchronous invocation

Synchronous: कॉलर परिणाम का इंतज़ार करता है.
Asynchronous: कॉलर को acknowledgment मिलता है; event बाद में प्रोसेस होता है.

Sync vs async सादृश्य

Event-driven architecture essentials

Events AWS सेवाओं से JSON के रूप में आते हैं.
Invocation मोड बदलता है कि errors कहाँ दिखेंगी.
Payloads अलग होते हैं, इसलिए सावधानी से parse और validate करें.
Retries और duplicates मानकर चलें.

Key takeaways पाइपलाइन

Payloads are contracts

Payloads अनुबंध जैसे हैं: भेजने वाला shape तय करता है.
आपके handler को पता होना चाहिए फ़ील्ड कहाँ हैं.
जो चाहिए निकालें, validate करें, प्रोसेस करें, और log करें.

Payload अनुबंध और parsing workflow

Example payload: SQS message event

एनोटेटेड SQS event payload

Records बैच है.
body एक string है.
messageId ट्रेस और deduplicate करने में मदद करता है.

Walkthrough: iterate through Records

def lambda_handler(event, context):
    records = event.get("Records", [])
    for record in records:
        body = record.get("body", "")
        print("BODY:", body)
    return {"statusCode": 200}

सुरक्षित default के साथ Records पढ़ें.
हर record पर loop चलाएँ और body निकालें.
ज़रूरी बात log करें, फिर return करें.

Records पर लूप चलाएँ

Walkthrough: parse JSON body safely

import json
def lambda_handler(event, context):
    records = event.get("Records") or [{}]
    body = records[0].get("body", "{}")
    payload = json.loads(body)
    oid = payload.get("order_id")
    return json.dumps({"order_id": oid})