使用 Microsoft Purview 配置事件中心以发送和接收 Atlas Kafka 主题消息

项目
10/06/2023

本文介绍如何将 Microsoft Purview 配置为能够使用 Azure 事件中心发送和接收 Atlas Kafka 主题事件。

如果已配置环境，可以按照我们的指南开始使用 Azure.Messaging.EventHubs .NET 库发送和接收消息。

先决条件

若要配置环境，需要满足某些先决条件：

Microsoft Azure 订阅。若要使用 Azure 服务（包括事件中心），需要 Azure 订阅。如果没有 Azure 帐户，可以在创建帐户时注册免费试用版或使用 MSDN 订阅者权益。
有效的 Microsoft Purview 帐户。

配置事件中心

若要发送或接收 Atlas Kafka 主题消息，至少需要配置一个事件中心命名空间。您可以：

创建自己的Azure 事件中心命名空间并将其配置为与 Microsoft Purview 配合使用
使用 REST API 创建托管命名空间

注意

如果你的 Microsoft Purview 帐户是在 2022 年 12 月 15 日之前创建的，则可能已有一个与你的帐户关联的托管事件中心资源。可以在Azure 门户的 Microsoft Purview 帐户页上的设置下检查托管资源。显示Azure 门户中 Microsoft Purview 帐户页的“托管资源”页上突出显示的事件中心命名空间切换的屏幕截图。

如果未看到此资源或已禁用，请按照以下步骤配置事件中心。
如果 已启用，可以根据需要继续使用此托管事件中心命名空间。 (存在相关成本。请参阅定价页。) 如果要管理自己的事件中心帐户，必须先禁用此功能，然后按照以下步骤操作。 如果禁用托管事件中心资源，将无法重新启用托管事件中心资源。只能配置自己的事件中心.

自带命名空间

可以使用事件中心配置现有Azure 事件中心命名空间，也可以创建一个新命名空间以与 Microsoft Purview 连接。

重要

目前，无法使用 Microsoft Purview for Atlas Kafka 主题消息配置使用专用终结点的事件中心。如果需要专用终结点，请使用托管命名空间。

事件中心权限

若要向事件中心进行身份验证，可以使用：

Microsoft Purview 托管标识
用户分配的托管标识 - 仅在帐户创建后配置命名空间时才可用。

其中一个标识至少需要对事件中心参与者权限，才能将它们配置为与 Microsoft Purview 一起使用。

配置事件中心以将消息发布到 Microsoft Purview

在Azure 门户的 Microsoft Purview 帐户页上的“设置”下导航到 Kafka 配置。
选择 “添加配置 ”和“ 挂钩配置”。

注意

可以根据需要添加任意数量的挂钩配置。
为挂钩配置指定名称，选择订阅、现有事件中心命名空间、要向其发送通知的现有事件中心、要使用的使用者组以及要使用的身份验证类型。

提示

可以多次使用相同的事件中心命名空间，但每个配置都需要自己的事件中心。
选择“保存”。完成配置需要几分钟时间。
配置完成后，可以开始将消息发布到 Microsoft Purview 的步骤。

配置事件中心以接收来自 Microsoft Purview 的消息

在Azure 门户的 Microsoft Purview 帐户页上的“设置”下导航到 Kafka 配置。
如果已将某个配置列为 “通知”类型，则事件中心已配置，你可以开始执行接收 Microsoft Purview 消息的步骤。

注意

一次只能配置一个通知事件中心。
如果尚未列出通知配置，请选择 “添加配置 ”和“ 通知配置”。
为通知配置指定名称，选择订阅、现有事件中心命名空间、要向其发送通知的现有事件中心、要使用的分区以及要使用的身份验证类型。

提示

可以多次使用相同的事件中心命名空间，但每个配置都需要自己的事件中心。
选择“保存”。完成配置需要几分钟时间。
配置完成后，可以开始执行接收 Microsoft Purview 消息的步骤。

删除配置的事件中心

若要删除配置的事件中心命名空间，可以按照以下步骤操作：

在Azure 门户中搜索并打开 Microsoft Purview 帐户。
在Azure 门户的 Microsoft Purview 帐户页上的“设置”下选择“Kafka 配置”。
选择要禁用的事件中心。 (Hook 中心将消息发送到 Microsoft Purview。通知中心接收 notifications.)
选择“ 删除 ”以保存该选项并开始禁用过程。这可能需要几分钟才能完成。

创建托管命名空间

如果需要事件中心命名空间使用专用终结点进行连接，或者希望使用托管事件中心命名空间，则需要使用 REST API 来配置帐户。

可以使用以下脚本 (设置 apiVersion = 2021-12-01) 来更新帐户，这样只会影响事件中心配置：

$body = @{"properties" = @{ "managedEventHubState" = "Enabled" }; "location" = $($location); "identity" = @{ "type"= $($type) } } | ConvertTo-Json
$Token=Get-AzAccessToken
$Headers = @{ "Authorization" = "Bearer $($Token.Token)" }
$Uri = "https://management.azure.com/subscriptions/$($subscription)/resourceGroups/$($rg)/providers/Microsoft.Purview/accounts/$($accountName)?api-version=$($apiVersion)"

Invoke-WebRequest -URI $Uri -Method Put -Body $body -Headers $Headers -ContentType "application/json"

通过