AWS SDK Step Functions आणि EventBridge: Workflows चालवा आणि Events Publish करा (Python, PHP, Node.js)

By Ravindra Bagale, trainer · LinkedIn · Last updated: 24 October 2026

1. मोठं चित्र: tour checklist

हे का लागतं?

Tour desk कडे checklist असते: hotel book, train book, guide चा होकार थांबा, tickets पाठवा. Manager प्रत्येक box tick करतो व hotel line busy असेल तर retry करतो. Step Functions तो manager. EventBridge हा notice board, जिथे कोणीही "booking confirmed" लावतो आणि योग्य teams react करतात.

हे काय आहे?

State machine Amazon States Language (JSON) मध्ये लिहिली जाते. StartExecution executionArn देतं; DescribeExecution RUNNING, SUCCEEDED किंवा FAILED status देतं. EventBridge PutEvents bus वर events पाठवतं; rules patterns match करून targets call करतात; EventBridge Scheduler cron किंवा rate ने targets चालवतो.

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

2. Execution start करा

हे का लागतं?

Aiko ¥84,000 ची Kyoto trip book करते आणि customer ने पैसे भरताच workflow सुरू व्हावा अशी तिची इच्छा आहे.

हे काय आहे?

StartExecution stateMachineArn, optional unique name (duplicates थांबवतो) आणि JSON string input घेतं.

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

1. Python.

import boto3, json
sf = boto3.client("stepfunctions", region_name="ap-northeast-1")
r = sf.start_execution(
    stateMachineArn="arn:aws:states:ap-northeast-1:111122223333:stateMachine:TripBooking",
    name="trip-kyoto-5012",
    input=json.dumps({"tripId": "5012", "amount": 84000, "currency": "JPY"}))
print(r["executionArn"].split(":")[-1])

अपेक्षित output:

trip-kyoto-5012

2. Node.js.

import { SFNClient, StartExecutionCommand } from "@aws-sdk/client-sfn";
const sf = new SFNClient({ region: "ap-south-1" });
const r = await sf.send(new StartExecutionCommand({
  stateMachineArn: "arn:aws:states:ap-south-1:111122223333:stateMachine:TripBooking",
  name: "trip-jaipur-7731",
  input: JSON.stringify({ tripId: "7731", amount: 18500, currency: "INR" })
}));
console.log(r.executionArn.split(":").pop());

अपेक्षित output:

trip-jaipur-7731

3. PHP.

<?php
require "vendor/autoload.php";
$sf = new Aws\Sfn\SfnClient(["region" => "eu-west-2"]);
$r = $sf->startExecution([
  "stateMachineArn" => "arn:aws:states:eu-west-2:111122223333:stateMachine:TripBooking",
  "name" => "trip-york-310",
  "input" => json_encode(["tripId" => "310", "amount" => 640, "currency" => "GBP"])]);
echo basename(str_replace(":", "/", $r["executionArn"])), PHP_EOL;

अपेक्षित output:

trip-york-310

4. CLI ने verify.

aws stepfunctions list-executions --state-machine-arn arn:aws:states:ap-northeast-1:111122223333:stateMachine:TripBooking --max-results 1 --query "executions[0].name" --output text

अपेक्षित output:

trip-kyoto-5012

3. Status व output पाहा

हे का लागतं?

Workflow संपेपर्यंत Rohan customers ना "Booking in progress" दाखवतो.

हे काय आहे?

DescribeExecution status आणि SUCCEEDED झाल्यावर output (JSON string) देतं. Delay ने poll करा, किंवा EventBridge मधल्या Step Functions status event वर react करा.

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

1. Python: संपेपर्यंत poll.

import time
arn = r["executionArn"]
while (d := sf.describe_execution(executionArn=arn))["status"] == "RUNNING":
    time.sleep(2)
print(d["status"], json.loads(d["output"])["ticket"])

अपेक्षित output:

SUCCEEDED KYO-5012-A

2. Node.js.

import { DescribeExecutionCommand } from "@aws-sdk/client-sfn";
const d = await sf.send(new DescribeExecutionCommand({ executionArn: r.executionArn }));
console.log(d.status);

अपेक्षित output:

RUNNING

3. PHP: failed कारण दाखवा.

$d = $sf->describeExecution(["executionArn" => $r["executionArn"]]);
echo $d["status"], " ", $d["error"] ?? "-", PHP_EOL;

अपेक्षित output:

FAILED HotelSoldOut

4. CLI ने verify.

aws stepfunctions describe-execution --execution-arn arn:aws:states:ap-northeast-1:111122223333:execution:TripBooking:trip-kyoto-5012 --query status --output text

अपेक्षित output:

SUCCEEDED

4. Task token ने resume

हे का लागतं?

Tickets जाण्याआधी जयपूरच्या guide ने group स्वीकारायला हवा. Workflow थांबतो आणि त्याच्या tap ची वाट पाहतो.

हे काय आहे?

".waitForTaskToken" असलेला task $$.Task.Token (उदा.) SQS ला देतो. नंतर app त्या token सह SendTaskSuccess किंवा SendTaskFailure call करतं.

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

1. Python: guide स्वीकारतो.

sf.send_task_success(taskToken=token, output=json.dumps({"guide": "Rohan", "accepted": True}))
print("resumed")

अपेक्षित output:

resumed

2. Node.js: guide नकार देतो.

import { SendTaskFailureCommand } from "@aws-sdk/client-sfn";
await sf.send(new SendTaskFailureCommand({ taskToken: token, error: "GuideBusy", cause: "Festival week" }));
console.log("failed GuideBusy");

अपेक्षित output:

failed GuideBusy

3. PHP: मोठी वाट चालू ठेवा.

$sf->sendTaskHeartbeat(["taskToken" => $token]);
echo "heartbeat sent", PHP_EOL;

अपेक्षित output:

heartbeat sent

4. CLI ने verify.

aws stepfunctions get-execution-history --execution-arn arn:aws:states:ap-south-1:111122223333:execution:TripBooking:trip-jaipur-7731 --reverse-order --max-results 1 --query "events[0].type" --output text

अपेक्षित output:

ExecutionSucceeded

5. Events आणि schedules

हे का लागतं?

Booking confirm झाल्यावर Lyon ची invoice team (€1,250) व SMS team दोघांना कळायला हवं, आणि रोज सकाळी 9 ला reminders जायला हवेत.

हे काय आहे?

PutEvents 10 entries पर्यंत (Source, DetailType, Detail JSON) पाठवतं. Event pattern असलेला rule त्यांना targets कडे पाठवतो. EventBridge Scheduler CreateSchedule time zone सह cron/rate ने target चालवतो.

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

1. Python: event publish.

eb = boto3.client("events", region_name="eu-west-3")
r = eb.put_events(Entries=[{"Source": "travel.bookings", "DetailType": "BookingConfirmed",
    "Detail": json.dumps({"tripId": "88", "amount": 1250, "currency": "EUR"}), "EventBusName": "default"}])
print("failed:", r["FailedEntryCount"])

अपेक्षित output:

failed: 0

2. Node.js: rule व target.

import { EventBridgeClient, PutRuleCommand, PutTargetsCommand } from "@aws-sdk/client-eventbridge";
const eb = new EventBridgeClient({ region: "eu-west-3" });
await eb.send(new PutRuleCommand({ Name: "booking-confirmed",
  EventPattern: JSON.stringify({ source: ["travel.bookings"], "detail-type": ["BookingConfirmed"] }) }));
const t = await eb.send(new PutTargetsCommand({ Rule: "booking-confirmed",
  Targets: [{ Id: "sms", Arn: "arn:aws:sqs:eu-west-3:111122223333:sms-queue" }] }));
console.log("target failures:", t.FailedEntryCount);

अपेक्षित output:

target failures: 0

3. PHP: रोजचा schedule.

$sc = new Aws\Scheduler\SchedulerClient(["region" => "ap-south-1"]);
$sc->createSchedule(["Name" => "trip-reminders", "ScheduleExpression" => "cron(0 9 * * ? *)",
  "ScheduleExpressionTimezone" => "Asia/Kolkata", "FlexibleTimeWindow" => ["Mode" => "OFF"],
  "Target" => ["Arn" => "arn:aws:sqs:ap-south-1:111122223333:reminders",
               "RoleArn" => "arn:aws:iam::111122223333:role/scheduler-sqs"]]);
echo "schedule created", PHP_EOL;

अपेक्षित output:

schedule created

4. CLI ने verify.

aws scheduler get-schedule --name trip-reminders --region ap-south-1 --query ScheduleExpression --output text

अपेक्षित output:

cron(0 9 * * ? *)

6. हीच action Python, Node.js, Java, Go, .NET आणि PHP मध्ये

हे का लागतं?

Scripts CLI मध्ये सुरू होतात. Apps तोच API SDK मधून call करतात. दोन्ही माहीत असले की test केलेली command थेट code मध्ये नेता येते.

हे काय आहे?

प्रत्येक CLI command म्हणजे एक API call. उदा. aws stepfunctions start-execution ... म्हणजे StartExecution API.

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

हीच action (CreateSchedule) code मधून. प्रत्येक SDK CLI सारखेच profile, region आणि credentials वाचतो.

7. काहीही खर्च चालू राहू नये म्हणून cleanup

हे का लागतं?

चालू ठेवलेले lab resources पैसे खातात आणि security risk बनतात.

हे काय आहे?

उलट्या क्रमाने delete करा: आधी children, मग parents.

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

1. Schedule, rule targets व rule delete करा.

aws scheduler delete-schedule --name trip-reminders --region ap-south-1
aws events remove-targets --rule booking-confirmed --ids sms --region eu-west-3
aws events delete-rule --name booking-confirmed --region eu-west-3

अपेक्षित output:

(no output means success)

2. Test state machine delete करा.

aws stepfunctions delete-state-machine --state-machine-arn arn:aws:states:ap-northeast-1:111122223333:stateMachine:TripBooking

अपेक्षित output:

(no output means success)

8. मुलाखत प्रश्न आणि उत्तरं

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

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

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