建立受控應用程式以儲存 Blob 摘要

在 Azure 入口網站上，您可以瀏覽至您想要開始建立 Blob 摘要的儲存體帳戶，然後移至 Events 刀鋒視窗。 您可以在該處建立事件訂用帳戶，並將其連線至 Azure 服務匯流排佇列端點。

佇列會使用工作階段來維護跨多個儲存體帳戶的排序，因此您也必須瀏覽至 Delivery Properties 索引標籤，並為此事件訂用帳戶輸入唯一的工作階段識別碼。

建立事件主題：

az eventgrid system-topic create \
--resource-group {resource_group} \
--name {sample_topic_name} \
--location {location} \
--topic-type microsoft.storage.storageaccounts \
--source /subscriptions/{subscription}/resourceGroups/{resource_group}/providers/Microsoft.Storage/storageAccounts/{storage_account_name}

resource-group - 應在其中建立主題的資源群組

name - 要建立的主題名稱

location - 要建立的主題位置

source - 要為其建立主題的儲存體帳戶資源識別碼

建立事件訂用帳戶：

az eventgrid system-topic event-subscription create \
--name {sample_subscription_name} \
--system-topic-name {sample_topic_name} \
--resource-group {resource_group} \
--event-delivery-schema EventGridSchema \
--included-event-types Microsoft.Storage.BlobCreated \
--delivery-attribute-mapping sessionId static {sample_session_id} false \
--endpoint-type servicebusqueue \
--endpoint /subscriptions/{subscription}/resourceGroups/{managed_resource_group}/providers/Microsoft.ServiceBus/namespaces/{service_bus_namespace}/queues/{service_bus_queue}

name - 要建立的訂用帳戶名稱

system-topic-name - 為其建立訂用帳戶的主題名稱 (應與新建立的主題相同)

resource-group - 應在其中建立訂用帳戶的資源群組

delivery-attribute-mapping - 必要 sessionId 欄位的對應。 輸入唯一的 sessionId

endpoint - 訂閱儲存體帳戶主題的服務匯流排佇列資源識別碼

az role assignment create \
--role "Storage Blob Data Owner" \
--assignee-object-id {function_oid} \
--assignee-principal-type ServicePrincipal\
--scope /subscriptions/{subscription}/resourceGroups/{resource_group}/providers/Microsoft.Storage/storageAccounts/{storage_account_name}

assignee-object-id - 使用受控應用程式建立之 Azure Function 的 OID。 可以在 [身分識別] 刀鋒視窗底下找到

scope - 要為其建立角色的儲存體帳戶資源識別碼

請務必包含 Session ID，因為佇列已啟用工作階段。

import json
import uuid
from azure.servicebus import ServiceBusClient, ServiceBusMessage

SERVICE_BUS_CONNECTION_STR = "<service_bus_connection_string>"
QUEUE_NAME = "<service_bus_queue_name>"
STORAGE_ACCOUNT_NAME = "<storage_account_name>"
BLOB_CONTAINER_NAME = "<blob_container_name>"
SESSION_ID = str(uuid.uuid4())

servicebus_client = ServiceBusClient.from_connection_string(conn_str=SERVICE_BUS_CONNECTION_STR, logging_enable=True)
sender = servicebus_client.get_queue_sender(queue_name=QUEUE_NAME)

message = {
    "eventType": "PerformAudit",
    "storageAccount": STORAGE_ACCOUNT_NAME,
    "blobContainer": BLOB_CONTAINER_NAME
}

message = ServiceBusMessage(json.dumps(message), session_id=SESSION_ID)
sender.send_messages(message)