在雲原生應用架構中，事件驅動架構（Event-Driven Architecture，EDA）正成為構建彈性系統的關鍵範式。Bicep Registry Modules提供了豐富的事件處理組件，幫助開發者快速構建響應式系統。本文將通過實際案例展示如何利用Event Grid、Service Bus等模塊實現事件驅動架構，解決傳統系統耦合度高、擴展性差的痛點。

事件驅動架構核心組件

事件驅動架構依賴三大核心組件：事件源（Event Source）、事件總線（Event Bus）和事件處理器（Event Handler）。在Bicep Registry Modules中，這些組件通過標準化模塊提供，確保一致性和可重用性。

Event Grid系統主題模塊

Event Grid（事件網格）是Azure的全託管事件路由服務，作為事件總線的核心實現。avm/res/event-grid/system-topic/main.bicep模塊提供了系統主題的完整部署能力，支持Azure服務事件（如Blob存儲創建、虛擬機狀態變更）的捕獲與路由。

module avmEventGridSystemTopic 'br/public:avm/res/event-grid/system-topic:0.6.3' = {
  name: take('avm.res.event-grid.system-topic.${eventGridSystemTopicName}', 64)
  params: {
    name: eventGridSystemTopicName
    source: storageAccount.id
    topicType: 'Microsoft.Storage.StorageAccounts'
    eventSubscriptions: [
      {
        name: '${projectName}-event-subscription'
        destination: {
          endpointType: 'ServiceBusQueue'
          properties: {
            resourceId: serviceBusQueue.id
          }
        }
        filter: {
          includedEventTypes: ['Microsoft.Storage.BlobCreated']
        }
      }
    ]
  }
}

上述代碼片段來自avm/ptn/sa/chat-with-your-data/main.bicep，展示瞭如何將Storage Account作為事件源，通過Event Grid系統主題將Blob創建事件路由到Service Bus隊列。

Service Bus命名空間模塊

Service Bus（服務總線）提供可靠的消息傳遞能力，常用於事件的持久化和異步處理。avm/res/service-bus/namespace/main.bicep模塊支持標準、高級兩種SKU，滿足不同吞吐量和延遲需求。高級SKU提供分區隊列和話題功能，支持消息優先級和事務處理。

響應式架構實現步驟

1. 部署事件源與系統主題

以Blob存儲作為事件源為例，首先部署Storage Account，然後通過Event Grid系統主題捕獲其事件：

// 部署存儲賬户（事件源）
module storageAccount 'br/public:avm/res/storage/storage-account:1.0.0' = {
  name: 'storage-account-deployment'
  params: {
    name: storageAccountName
    skuName: 'Standard_GRS'
    kind: 'StorageV2'
  }
}

// 部署Event Grid系統主題
module eventGridSystemTopic 'br/public:avm/res/event-grid/system-topic:0.6.3' = {
  name: 'event-grid-system-topic-deployment'
  params: {
    name: 'storage-events-system-topic'
    source: storageAccount.id
    topicType: 'Microsoft.Storage.StorageAccounts'
  }
  dependsOn: [storageAccount]
}

2. 配置事件訂閲與路由

通過事件訂閲將事件路由到目標處理器。支持的目標類型包括Web Hook、Azure Functions、Service Bus等。以下示例將事件路由到Service Bus隊列，確保消息可靠傳遞：

// 部署Service Bus命名空間和隊列
module serviceBusNamespace 'br/public:avm/res/service-bus/namespace:0.5.0' = {
  name: 'service-bus-namespace-deployment'
  params: {
    name: serviceBusNamespaceName
    skuName: 'Premium' // 高級SKU支持分區隊列
  }
}

module serviceBusQueue 'br/public:avm/res/service-bus/namespace/queue/main.bicep' = {
  name: 'service-bus-queue-deployment'
  params: {
    name: 'event-queue'
    namespaceName: serviceBusNamespace.outputs.name
    maxSizeInMegabytes: 1024
    enablePartitioning: true
  }
  dependsOn: [serviceBusNamespace]
}

// 創建事件訂閲，路由到Service Bus隊列
module eventSubscription 'avm/res/event-grid/system-topic/event-subscription/main.bicep' = {
  name: 'event-subscription-deployment'
  params: {
    systemTopicName: eventGridSystemTopic.outputs.name
    name: 'storage-to-servicebus-subscription'
    destination: {
      endpointType: 'ServiceBusQueue'
      properties: {
        resourceId: serviceBusQueue.outputs.id
      }
    }
    filter: {
      includedEventTypes: ['Microsoft.Storage.BlobCreated', 'Microsoft.Storage.BlobDeleted']
      subjectBeginsWith: '/blobServices/default/containers/data/'
    }
    retryPolicy: {
      maxDeliveryAttempts: 5
      eventTimeToLiveInMinutes: 120
    }
  }
  dependsOn: [eventGridSystemTopic, serviceBusQueue]
}

3. 實現事件處理器

事件處理器可以是Azure Function、Logic App或自定義應用。以下展示如何使用Azure Function處理Service Bus隊列中的事件：

[FunctionName("ProcessBlobEvent")]
public static async Task Run(
    [ServiceBusTrigger("event-queue", Connection = "ServiceBusConnection")]string myQueueItem,
    ILogger log)
{
    log.LogInformation($"C# ServiceBus queue trigger function processed message: {myQueueItem}");
    
    // 解析事件數據
    var eventData = JsonSerializer.Deserialize<BlobCreatedEventData>(myQueueItem);
    await ProcessBlob(eventData.Url); // 自定義業務邏輯處理
}

高級特性與最佳實踐

事件過濾與路由

Event Grid支持精細的事件過濾，通過includedEventTypes、subjectBeginsWith/EndsWith等屬性減少不必要的事件傳遞。例如，僅處理特定容器下的Blob創建事件：

filter: {
  includedEventTypes: ['Microsoft.Storage.BlobCreated']
  subjectBeginsWith: '/blobServices/default/containers/images/'
  subjectEndsWith: '.png'
}

死信隊列與重試策略

為確保事件可靠處理，建議配置死信隊列（Dead Letter Queue）和重試策略。當事件處理失敗時，消息會被移至死信隊列，避免丟失：

deadLetterDestination: {
  endpointType: 'StorageBlob'
  properties: {
    resourceId: deadLetterStorageAccount.id
    blobContainerName: 'dead-letter-container'
  }
}
retryPolicy: {
  maxDeliveryAttempts: 5
  eventTimeToLiveInMinutes: 1440 // 24小時
}

身份驗證與授權

使用託管身份（Managed Identity）確保Event Grid與目標服務間的安全通信。avm/res/event-grid/system-topic/main.bicep模塊通過externalResourceRoleAssignments參數簡化權限配置：

externalResourceRoleAssignments: [
  {
    resourceId: serviceBusQueue.id
    roleDefinitionId: 'b24988ac-6180-42a0-ab88-20f7382dd24c' // 參與者角色
    description: 'Allow Event Grid to send events to Service Bus Queue'
  }
]

典型應用場景

圖像處理流水線

在圖像處理場景中，用户上傳圖片到Storage Account後，自動觸發裁剪、格式轉換、人臉識別等操作。通過Event Grid+Service Bus實現步驟解耦，每個步驟作為獨立處理器，可單獨擴展：

[Storage Account] --BlobCreated--> [Event Grid] --路由--> [Service Bus Queue] --觸發--> [Azure Functions]
                                                                                    |-- 裁剪圖片
                                                                                    |-- 格式轉換
                                                                                    |-- 人臉識別

實時數據分析

零售系統中，POS交易事件通過Event Grid實時路由到流分析作業，進行實時庫存更新和銷售趨勢分析。異常交易觸發警報處理器，通過Service Bus發送通知：

// 交易事件路由到流分析
module transactionEventSubscription 'avm/res/event-grid/system-topic/event-subscription/main.bicep' = {
  name: 'transaction-event-subscription'
  params: {
    name: 'transaction-to-stream-analytics'
    destination: {
      endpointType: 'Microsoft.StreamAnalytics/streamingJobs'
      properties: {
        resourceId: streamAnalyticsJob.id
      }
    }
  }
}

總結與展望

通過Bicep Registry Modules的事件驅動組件，開發者可快速構建鬆耦合、高彈性的響應式架構。Event Grid提供統一的事件路由，Service Bus確保消息可靠傳遞，配合Azure Functions等無服務器計算服務，實現真正的彈性擴展。

未來，隨着模塊生態的完善，事件驅動架構將進一步降低開發門檻，支持更多事件源和目標類型，如Kubernetes事件、自定義事件模式等。建議開發者關注CONTRIBUTING.md，參與模塊改進，共同推動響應式架構的標準化和普及。

掌握事件驅動架構，不僅能解決當前系統的擴展性問題，更能為構建下一代雲原生應用奠定基礎。立即開始嘗試示例模塊，體驗響應式架構的強大能力！