Amazon EventBridge: Hướng dẫn về Kiến trúc Hướng Sự kiện

Amazon EventBridge là một dịch vụ event bus không máy chủ (serverless) mạnh mẽ, giúp nhà phát triển xây dựng kiến trúc hướng sự kiện với chi phí vận hành tối thiểu. 

Trong công việc với các hệ thống cloud-native, tôi thấy mức độ phản hồi theo thời gian thực và tách ghép (decoupling) dịch vụ có vai trò sống còn để xây dựng ứng dụng có khả năng mở rộng, dễ bảo trì, và EventBridge đáp ứng chính xác những điều đó.

Amazon EventBridge là gì?

Trước khi đi vào cấu hình, điều quan trọng là hiểu EventBridge là gì, vì sao nó quan trọng và nó phù hợp như thế nào trong hệ sinh thái công cụ hướng sự kiện rộng lớn của AWS.

Tổng quan về Amazon EventBridge

Amazon EventBridge is a fully managed, serverless event bus service cho phép các ứng dụng giao tiếp thông qua sự kiện gần như theo thời gian thực. 

Nó đơn giản hóa việc định tuyến sự kiện giữa các nhà sản xuất sự kiện (nguồn thay đổi, như S3, DynamoDB hoặc ứng dụng tùy chỉnh) và các bên tiêu thụ sự kiện (các dịch vụ xử lý các thay đổi này, như Lambda, Step Functions hoặc SNS).

Hình ảnh minh họa EventBridge định tuyến sự kiện từ nhà sản xuất đến nhiều đích. Nguồn: AWS Blogs

EventBridge được thiết kế với khả năng mở rộng và linh hoạt. 

Nó tự động mở rộng để xử lý hàng triệu sự kiện mỗi giây và cho phép logic định tuyến phức tạp thông qua các quy tắc dựa trên JSON.

Một số khả năng chính bao gồm:

• Tích hợp gốc với hơn 90 dịch vụ AWS (ví dụ: EC2, CodePipeline, CloudTrail)
• Hỗ trợ nguồn sự kiện SaaS bên ngoài như Zendesk, Shopify và Datadog
• Khả năng khám phá và đăng ký schema tích hợp, tự động phát hiện và ghi nhận cấu trúc sự kiện
• Lưu trữ và phát lại sự kiện, hỗ trợ gỡ lỗi, kiểm toán hoặc xử lý lại sự kiện trong quá khứ

Điều này khiến EventBridge trở thành công cụ nền tảng để xây dựng kiến trúc đám mây tách ghép và bền bỉ.

EventBridge và kiến trúc hướng sự kiện

EventBridge được xây dựng dựa trên mô hình kiến trúc hướng sự kiện (EDA).

Trong EDA, các dịch vụ giao tiếp bằng cách phát ra và phản ứng với sự kiện, thay vì gọi đồng bộ lẫn nhau.

Ví dụ, thay vì một dịch vụ gọi API của dịch vụ khác để bắt đầu một tác vụ, nó chỉ cần phát ra một sự kiện như "ImageUploaded", và các dịch vụ lắng nghe sự kiện đó sẽ phản ứng tương ứng.

Hình dưới minh họa thiết lập này, với Amazon API Gateway đóng vai trò điểm vào an toàn tới event bus trung tâm của EventBridge.

Hình ảnh cho thấy Amazon API Gateway là điểm vào an toàn tới event bus cốt lõi của EventBridge. Nguồn: AWS Blogs

Lợi ích của kiến trúc hướng sự kiện:

Hình ảnh minh họa các lợi ích của kiến trúc hướng sự kiện.

• Tách ghép lỏng lẻo: Các dịch vụ độc lập và không cần biết sự tồn tại của nhau.
• Khả năng mở rộng: Có thể mở rộng từng thành phần riêng lẻ.
• Khả năng chịu lỗi: Lỗi ở một phần không lan sang phần khác.
• Xử lý bất đồng bộ: Cải thiện độ phản hồi và hiệu năng hệ thống.

EventBridge đóng vai trò xương sống của EDA trên AWS, cho phép bạn kết nối microservices, tài nguyên đám mây và cả hệ thống bên thứ ba mà không cần ràng buộc chặt chẽ.

> Nếu bạn muốn xây nền tảng vững chắc về hệ sinh thái hướng sự kiện của AWS, hãy khám phá khóa học AWS Cloud Technology and Services.

EventBridge khác gì so với các tùy chọn hướng sự kiện khác

AWS cung cấp nhiều công cụ xử lý sự kiện và thông điệp, nhưng EventBridge có những tính năng độc đáo, khác biệt so với các lựa chọn như SNS và SQS.

SNS (Simple Notification Service) 

SNS phù hợp cho mô hình pub/sub đơn giản.

Bạn có thể xuất bản một thông điệp lên một chủ đề (topic) và phân phối đến nhiều subscriber như email, SMS hoặc Lambda. 

Tuy nhiên, nó thiếu tính năng định tuyến tinh vi và lọc sự kiện.

SQS (Simple Queue Service)

SQS cung cấp hàng đợi đáng tin cậy, có khả năng mở rộng để lưu trữ và xử lý thông điệp. 

Bên tiêu thụ sẽ thăm dò (poll) hàng đợi để lấy thông điệp, hữu ích cho hệ thống bất đồng bộ, tách ghép nhưng không hỗ trợ định tuyến theo cơ chế đẩy (push) theo thời gian thực.

EventBridge

EventBridge kết hợp ưu điểm của cả hai: định tuyến theo thời gian thực, lọc phong phú, xác thực schema và tích hợp SaaS. 

Nó được thiết kế cho các hệ thống hướng sự kiện phức tạp, quy mô lớn, cần quy tắc linh hoạt, nhiều đích và tích hợp liền mạch giữa các dịch vụ.

CloudWatch Events

CloudWatch Events là tiền thân của EventBridge. 

EventBridge là thế hệ tiếp theo, bổ sung:

• Tích hợp đối tác SaaS
• Custom event bus
• Khám phá và đăng ký schema
• Cải thiện quản lý quy tắc và quyền

Nếu bạn vẫn đang dùng CloudWatch Events, hãy cân nhắc chuyển sang EventBridge để có nhiều tính năng hơn.

Dưới đây là so sánh nhanh giữa các dịch vụ đã thảo luận:

Thành phần cốt lõi và tính năng chính của Amazon EventBridge

Để sử dụng Amazon EventBridge hiệu quả, cần hiểu các khối xây dựng cốt lõi của nó. 

Các thành phần này phối hợp để kích hoạt quy trình làm việc hướng sự kiện linh hoạt với chi phí hạ tầng tối thiểu. 

Dưới đây là phân tích chi tiết từng thành phần, chức năng và cách sử dụng.

Event bus

Trung tâm của EventBridge là event bus, đóng vai trò kênh dẫn cho mọi sự kiện. 

Một event bus nhận sự kiện từ các dịch vụ AWS, ứng dụng tùy chỉnh hoặc nhà cung cấp SaaS, rồi định tuyến đến các đích phù hợp dựa trên quy tắc khớp.

Hình dưới hiển thị phần EventBridge Buses trong AWS Console.

Hình ảnh chứa ảnh chụp màn hình AWS Console hiển thị phần EventBridge Buses.

Các loại event bus

Dưới đây là các loại event bus có trong AWS:

Default Event Bus:

• Được cung cấp tự động trong mọi tài khoản AWS.
• Chủ yếu dùng để nhận sự kiện từ các dịch vụ AWS (như thay đổi trạng thái EC2 hoặc sự kiện S3).
• Bạn cũng có thể gửi sự kiện tùy chỉnh của mình tới default bus nếu không cần bus khác.

Custom Event Buses:

• Do bạn tạo để hỗ trợ các miền, dịch vụ hoặc khối lượng công việc khác nhau.
• Lý tưởng để cô lập sự kiện ứng dụng hoặc tách môi trường phát triển và sản xuất.
• Cho phép kiểm soát chi tiết hơn về chính sách truy cập và định tuyến sự kiện.

Ví dụ trường hợp sử dụng:

Tạo các event bus riêng cho các miền khác nhau, như một cái cho vận hành thương mại điện tử và một cái cho phân tích, để giữ luồng sự kiện tách biệt và dễ quản lý.

Tạo custom event bus:

aws events create-event-bus --name my-app-busĐược hỗ trợ bởi

Hiểu về quy tắc (rules) và đích (targets)

Quy tắc xác định sự kiện nào sẽ được định tuyến đến đích nào. 

Chúng sử dụng so khớp mẫu JSON để lọc sự kiện đi vào bus và chuyển tiếp tới một hoặc nhiều đích.

Các khía cạnh chính của quy tắc:

• Bạn có thể lọc theo bất kỳ thuộc tính sự kiện nào, như nguồn, detail-type hoặc các trường detail lồng nhau.
• Nhiều quy tắc có thể khớp cùng một sự kiện, cho phép hành vi fan-out.
• Một quy tắc có thể có nhiều đích, cho phép một sự kiện kích hoạt các pipeline xử lý song song.

Các đích được hỗ trợ gồm:

• AWS Lambda
• Step Functions
• Kinesis Data Streams
• SNS, SQS
• Tác vụ ECS
• API Gateway

Hình ảnh chứa các biểu tượng dịch vụ AWS cho các đích được hỗ trợ.

Ví dụ sau minh họa cách định nghĩa một quy tắc sự kiện và liên kết nó tới một hàm Lambda làm đích:

aws events put-rule \
  --name "ImageUploadRule" \
  --event-pattern file://event-pattern.json \
  --event-bus-name my-app-bus

aws events put-targets \
  --rule "ImageUploadRule" \
  --targets "Id"="1","Arn"="arn:aws:lambda:region:account-id:function:ImageProcessor"Được hỗ trợ bởi

Mẫu mẫu sự kiện (event-pattern.json):

{
  "source": ["myapplication.upload"],
  "detail-type": ["Image Uploaded"]
}Được hỗ trợ bởi

Pipes

EventBridge Pipes đơn giản hóa việc kết nối giữa nguồn (như DynamoDB Streams) và đích (như SQS hoặc Lambda) mà không cần viết mã tùy chỉnh.

Hình dưới hiển thị phần EventBridge Pipes trong AWS Console.

Hình ảnh chứa ảnh chụp màn hình AWS Console hiển thị phần EventBridge Pipes.

Các tính năng chính của Pipes:

• Lọc: Dùng mẫu sự kiện để giới hạn sự kiện đi qua pipe.
• Bổ sung ngữ cảnh (Enrichment): Gọi hàm Lambda để làm giàu sự kiện trước khi gửi.
• Chuyển đổi: Biến đổi cấu trúc sự kiện bằng input transformer.

Khi nào dùng Pipes:

• Kết nối luồng dữ liệu (ví dụ, Kinesis hoặc DynamoDB) tới các bên tiêu thụ ở hạ nguồn.
• Tích hợp các dịch vụ AWS có định dạng sự kiện khác nhau.

Scheduler

EventBridge Scheduler cho phép thực thi tác vụ theo thời gian, lý tưởng để tự động hóa như sao lưu hằng ngày, đồng bộ dữ liệu hàng giờ hoặc kích hoạt workflow theo lịch.

Hình dưới hiển thị phần EventBridge Scheduler trong AWS Console.

Hình ảnh chứa ảnh chụp màn hình AWS Console hiển thị phần EventBridge Scheduler.

Các tính năng chính gồm:

• Thực thi một lần hoặc định kỳ
• Hỗ trợ biểu thức cron hoặc rate-based
• Kiểm soát múi giờ, khoảng thời gian bắt đầu/kết thúc, và logic thử lại

Tạo một sự kiện theo lịch:

aws scheduler create-schedule \
  --name "DailyETLJob" \
  --schedule-expression "rate(1 day)" \
  --flexible-time-window '{"Mode":"OFF"}' \
  --target '{"Arn":"arn:aws:lambda:region:account-id:function:RunETL", "RoleArn":"arn:aws:iam::account-id:role/SchedulerExecutionRole"}'Được hỗ trợ bởi

Lịch này gọi hàm RunETL mỗi ngày.

Schema Registry và Event Replays

Schema Registry giúp nhà phát triển hiểu và ghi nhận cấu trúc sự kiện. 

Nó tự động khám phá schema từ các dịch vụ AWS và ứng dụng tùy chỉnh và lưu trong một registry.

Lợi ích của Schema Registry gồm:

• Tạo ràng buộc mã kiểu mạnh cho Java, Python và TypeScript.
• Cải thiện tính nhất quán và giảm lỗi phân tích cú pháp trong ứng dụng hướng sự kiện.

Event Replays cho phép bạn lưu trữ sự kiện trên bus và phát lại sau này. 

Điều này hữu ích cho:

• Gỡ lỗi workflow thất bại
• Phát lại sự kiện sau khi sửa lỗi
• Khôi phục xử lý dữ liệu bị mất hoặc trễ

Hình ảnh chứa sơ đồ khái niệm minh họa EventBridge định tuyến sự kiện. Nguồn: AWS Blogs

Bật lưu trữ sự kiện:

aws events create-archive \
  --archive-name "MyApplicationArchive" \
  --event-source-arn "arn:aws:events:region:account-id:event-bus/my-application-bus" \
  --retention-days 7Được hỗ trợ bởi

Phát lại sự kiện đã lưu trữ:

aws events start-replay \
  --replay-name "MyReplay" \
  --source-arn "arn:aws:events:region:account-id:archive/MyApplicationArchive" \
  --destination "arn:aws:events:region:account-id:event-bus/my-application-bus"Được hỗ trợ bởi

Các thành phần này—event bus, rule, pipe, scheduler và schema registry—kết hợp tạo nên một nền tảng toàn diện, linh hoạt để xây dựng và quản lý kiến trúc hướng sự kiện vững chắc trên AWS. 

Mỗi thành phần đóng vai trò riêng trong việc tách ghép dịch vụ, cải thiện khả năng mở rộng và thúc đẩy phát triển ứng dụng nhanh hơn.

Xây dựng ứng dụng hướng sự kiện với EventBridge

Sau khi hoàn tất phần thiết lập nền tảng, đã đến lúc áp dụng Amazon EventBridge vào các quy trình ứng dụng thực tế. 

Thiết lập EventBridge trong ứng dụng của bạn

Dưới đây là cách phát (emit) sự kiện tùy chỉnh từ ứng dụng của bạn bằng AWS CLI:

aws events put-events --entries '[
  {
    "Source": "myapplication.media",
    "DetailType": "ImageUploaded",
    "Detail": "{\"bucket\": \"my-bucket-name\", \"key\": \"image.jpg\"}",
    "EventBusName": "default"
  }
]'Được hỗ trợ bởi

Giải thích:

• Source: Tên hoặc miền của dịch vụ phát sự kiện.
• DetailType: Loại sự kiện được phát.
• Detail: Payload, được mã hóa dạng chuỗi JSON.
• EventBusName: Bus sẽ nhận và định tuyến sự kiện.

Bạn có thể tích hợp logic này trực tiếp vào hàm Lambda, dịch vụ backend hoặc workload chạy trong container bằng các SDK (ví dụ: Boto3, AWS SDK for JavaScript).

Định tuyến sự kiện giữa các dịch vụ AWS

Định tuyến sự kiện giữa các dịch vụ AWS cho phép tích hợp liền mạch, như kích hoạt Lambda từ hành động S3 qua EventBridge.

Ví dụ: Kết nối Amazon S3 với một hàm Lambda qua EventBridge.

Bước 01: Tạo một bucket S3 và tải lên một đối tượng.

Bước 02: Bật Event Notifications của S3 qua EventBridge:

• Vào bucket S3.
• Bật tùy chọn "EventBridge" trong Event Notifications.

Bước 03: Tạo một quy tắc EventBridge để khớp mẫu sự kiện:

{
  "source": ["aws.s3"],
  "detail-type": ["Object Created"],
  "detail": {
    "bucket": {
      "name": ["my-bucket"]
    }
  }
}Được hỗ trợ bởi

Bước 04: Gắn một hàm Lambda làm đích của quy tắc để xử lý đối tượng đã tải lên.

Mẫu này cho phép mở rộng xử lý sau đó bằng cách thêm các đích khác như Step Functions hoặc SNS cho thông báo.

Ví dụ thực tế: Quy trình tải lên và thay đổi kích thước ảnh

Cùng đi qua một pipeline hướng sự kiện điển hình:

01: Người dùng tải ảnh lên S3.

02: S3 phát một sự kiện đến default EventBridge bus.

03: EventBridge khớp một quy tắc cho s3:ObjectCreated:* và định tuyến tới một hàm Lambda.

04: Lambda thay đổi kích thước ảnh, lưu vào bucket S3 khác và ghi log kết quả.

Mẫu này mạnh mẽ vì:

• Có khả năng mở rộng (có thể xử lý hàng nghìn sự kiện mỗi giây).
• Có tính mô-đun (có thể thay thế hàm thay đổi kích thước ảnh mà không ảnh hưởng phần khác).
• Cho phép song song (có thể gửi cùng sự kiện đến pipeline phân tích hoặc thông báo đồng thời).

Thêm quy tắc để mở rộng và linh hoạt

Bạn có thể dễ dàng fan-out sự kiện bằng cách gắn nhiều đích vào một quy tắc:

aws events put-targets --rule image-uploaded \
  --targets '[
    {"Id": "resizeLambda", "Arn": "arn:aws:lambda:region:account-id:function:ResizeImage"},
    {"Id": "notifySNS", "Arn": "arn:aws:sns:region:account-id:ImageUploadedTopic"}
]'Được hỗ trợ bởi

Điều này cho phép ứng dụng của bạn xử lý sự kiện, thông báo cho người dùng và cập nhật log, tất cả song song mà không ràng buộc các tác vụ với nhau.

Tối ưu hiệu năng và đảm bảo bảo mật

Tối ưu hiệu năng và bảo mật bằng cách thiết kế mẫu sự kiện chính xác để giảm xử lý không cần thiết và hạn chế rủi ro.

Thiết kế mẫu sự kiện hiệu quả

Tránh các mẫu rộng hoặc bao trùm gây kích hoạt thực thi không cần thiết. Thay vào đó, lọc sự kiện chính xác:

{
  "source": ["myapplication.service"],
  "detail-type": ["ImageUploaded"],
  "detail": {
    "bucket": ["media-uploads"]
  }
}Được hỗ trợ bởi

Cách này giảm chi phí, cải thiện độ trễ và đảm bảo chỉ xử lý sự kiện liên quan.

Triển khai kiểm soát bảo mật vững chắc

Bảo mật là yếu tố then chốt trong mọi kiến trúc serverless. Hãy tuân thủ các hướng dẫn sau:

• Dùng nguyên tắc đặc quyền tối thiểu trong IAM: Chỉ cấp quyền cần thiết để xuất bản hoặc tiêu thụ sự kiện.
• Bật mã hóa: EventBridge hỗ trợ mã hóa khi lưu trữ bằng AWS KMS.
• Triển khai DLQ (Dead Letter Queue) cho các lần gửi thất bại:

"DeadLetterConfig": {
  "Arn": "arn:aws:sqs:region:account-id:my-dlq"
}Được hỗ trợ bởi

DLQ ghi nhận các sự kiện không thể giao, cho phép bạn chẩn đoán và xử lý lại sau.

> Nếu bạn muốn tìm hiểu sâu về bảo mật ứng dụng đám mây và quản lý quyền AWS, hãy xem khóa học AWS Security and Cost Management.

Quản lý chi phí và hạn ngạch dịch vụ

Để quản lý hiệu quả chi phí và hiệu năng, điều quan trọng là hiểu mô hình giá của EventBridge và thường xuyên theo dõi hạn ngạch dịch vụ.

Hiểu cấu trúc giá

Bạn bị tính phí theo:

• Sự kiện được xuất bản (USD trên mỗi triệu sự kiện)
• Sự kiện được phát lại
• Việc sử dụng Pipes
• Công việc Scheduler

Free tier bao gồm 100.000 sự kiện mỗi tháng, đủ hào phóng cho hầu hết trường hợp phát triển và sản xuất nhỏ.

Giám sát và điều chỉnh hạn ngạch dịch vụ

Theo dõi và yêu cầu tăng hạn ngạch bằng:

aws service-quotas list-service-quotas --service-code eventsĐược hỗ trợ bởi

Các hạn ngạch quan trọng cần theo dõi:

• Số quy tắc trên mỗi event bus
• Số đích trên mỗi quy tắc
• Số lần gọi mỗi giây

Mở rộng việc sử dụng một cách có trách nhiệm đảm bảo hệ thống của bạn luôn tin cậy khi tải tăng lên.

Cấu hình EventBridge nâng cao và phương án thay thế

Với các kiến trúc hướng sự kiện phức tạp hơn, bạn nên cân nhắc các tính năng nâng cao của EventBridge và những mẫu thay thế để tăng cường kiểm soát, bảo mật và linh hoạt trong lập lịch.

Phân phối sự kiện xuyên tài khoản

Bật chia sẻ sự kiện an toàn giữa các tài khoản AWS:

{
  "Statement": [{
    "Effect": "Allow",
    "Principal": {"AWS": "arn:aws:iam::123456789012:root"},
    "Action": "events:PutEvents",
    "Resource": "arn:aws:events:region:account-id:event-bus/shared-bus"
  }]
}Được hỗ trợ bởi

Sử dụng AWS CloudTrail để kiểm toán việc sử dụng và đảm bảo tuân thủ.

Tính năng nâng cao của EventBridge Scheduler

Vượt ra ngoài lập lịch cơ bản với:

• Chiến lược thử lại linh hoạt
• Tuân thủ khung thời gian
• Hỗ trợ biểu thức cron hoặc rate()

Ví dụ biểu thức cron:

Kích hoạt một workflow lúc 9:00 sáng mỗi thứ Hai:

--schedule-expression "cron(0 9 ? * MON *)"Được hỗ trợ bởi

Khi nào cân nhắc phương án thay thế

Tùy theo yêu cầu, bạn có thể cân nhắc các dịch vụ AWS khác phù hợp hơn cho từng trường hợp cụ thể. 

Một số ví dụ:

Kết luận

Amazon EventBridge là khối xây dựng nền tảng cho các ứng dụng hiện đại, cloud-native, cho phép bạn xây dựng hệ thống có khả năng mở rộng, tách ghép lỏng lẻo, phản hồi với sự kiện theo thời gian thực trên AWS và các nền tảng SaaS, và tích hợp workflow với chi phí hạ tầng tối thiểu. 

Để thành công với EventBridge, hãy tập trung thiết kế các miền dựa trên sự kiện theo mô-đun, áp dụng thực tiễn tốt nhất về đặc quyền tối thiểu và hàng đợi thư chết, đồng thời liên tục giám sát mức sử dụng, hạn ngạch và chi phí.

Nếu bạn muốn nâng cao chuyên môn AWS, hãy khám phá the AWS Cloud Practitioner course track!