基于 Azure 机器学习事件触发应用程序、进程或 CI/CD 工作流

本文介绍如何基于 Azure 机器学习事件设置事件驱动的应用程序、进程或 CI/CD 工作流。 例如，当使用 Azure 事件网格检测到某些条件时，故障通知电子邮件或 ML 管道会运行。

Azure 机器学习管理机器学习进程的整个生命周期，包括模型训练、模型部署和监视。 可以借助现代无服务器体系结构，使用事件网格对 Azure 机器学习事件做出反应，例如完成训练运行、注册和部署模型以及检测数据偏移。 然后，可以订阅和使用事件，例如运行状态更改、运行完成、模型注册、模型部署以及工作区中的数据偏移检测。

何时将事件网格用于事件驱动的操作：

• 在运行失败和运行完成时发送电子邮件
• 注册模型后使用 Azure 函数
• 将事件从 Azure 机器学习流式传输到各种终结点
• 检测到偏移时触发 ML 管道

Prerequisites

要使用事件网格，需要以参与者或所有者身份访问将为其创建事件的 Azure 机器学习工作区。

事件模型与类型

Azure 事件网格从 Azure 机器学习和其他 Azure 服务等源中读取事件。 然后，将这些事件发送到事件处理程序，例如 Azure 事件中心、Azure Functions、逻辑应用等。 下图显示了事件网格如何连接源和处理程序，但未完整列出受支持的集成。

有关事件源和事件处理程序的详细信息，请参阅什么是事件网格？

Azure 机器学习的事件类型

Azure 机器学习在机器学习生命周期的各个点提供事件：

筛选并订阅事件

这些事件通过 Azure 事件网格发布。 在 Azure门户、PowerShell 或 Azure CLI 中，可以通过指定一种或多种事件类型并筛选条件来轻松地订阅事件。

设置事件时，可以应用筛选器，以仅在特定事件数据上触发。 在以下示例中，对于运行状态更改的事件，可以按运行类型进行筛选。 仅在满足条件时触发事件。 有关可以筛选的事件数据的详细信息，请参阅 Azure 机器学习事件网格架构。

Azure 机器学习事件的订阅由 Azure 基于角色的访问控制 (Azure RBAC) 进行保护。 只有工作区参与者或所有者可以创建、更新和删除事件订阅。 可在创建事件订阅期间或以后将筛选器应用于事件订阅。

1. 转到 Azure 门户，选择新订阅或现有订阅。

2. 从左窗格中选择“事件”条目，然后选择“ + 事件订阅”。

3. 选择“筛选器”选项卡，然后向下滚动到“高级筛选器”。 对于“键”和“值”，提供要作为筛选依据的属性类型。 可以在下面看到事件在运行类型为管道运行或管道步骤运行时触发。

   

• 按事件类型筛选：事件订阅可以指定一个或多个 Azure 机器学习事件类型。

• 按事件主题筛选：Azure 事件网格支持根据“开头为”和“结尾为”的匹配筛选主题，以便将具有匹配主题的事件传递给订阅者。 不同的机器学习事件具有不同的主题格式。

  事件类型	主题格式	示例主题
  Microsoft.MachineLearningServices.RunCompleted	experiments/{ExperimentId}/runs/{RunId}	experiments/b1d7966c-f73a-4c68-b846-992ace89551f/runs/my_exp1_1554835758_38dbaa94
  Microsoft.MachineLearningServices.ModelRegistered（预览版）	models/{modelName}:{modelVersion}	models/sklearn_regression_model:3
  Microsoft.MachineLearningServices.ModelDeployed（预览版）	endpoints/{serviceId}	endpoints/my_sklearn_aks
  Microsoft.MachineLearningServices.DatasetDriftDetected（预览版）	datadrift/{data.DataDriftId}/run/{data.RunId}	datadrift/4e694bf5-712e-4e40-b06a-d2a2755212d4/run/my_driftrun1_1550564444_fbbcdc0f
  Microsoft.MachineLearningServices.RunStatusChanged	experiments/{ExperimentId}/runs/{RunId}	experiments/b1d7966c-f73a-4c68-b846-992ace89551f/runs/my_exp1_1554835758_38dbaa94

• 高级筛选：Azure 事件网格还支持基于已发布事件架构的高级筛选。 有关 Azure 机器学习事件架构的详细信息，请参阅 Azure 机器学习的 Azure 事件网格事件架构。 对于 Microsoft.MachineLearningServices.ModelRegistered 事件，筛选模型的标记值：

  --advanced-filter data.ModelTags.key1 StringIn ('value1')
  

  要了解有关如何应用筛选器的详细信息，请参阅事件网格的筛选事件。

使用机器学习事件

处理机器学习事件的应用程序应遵循一些建议的做法：

使用 Azure 事件网格，客户可以构建解耦的消息处理程序，该消息处理程序可以由 Azure 机器学习事件触发。 一些需要注意的消息处理程序的示例是：

• Azure Functions
• Azure Logic Apps
• Azure 事件中心
• Azure 数据工厂管道
• 通用 Webhook，可能在 Azure 平台或其他平台上托管

在 Azure 门户中设置

1. 打开 Azure 门户，然后转到 Azure 机器学习工作区。

2. 在左侧边栏中，选择“事件”，然后选择“事件订阅”。

   

3. 选择要使用的事件类型。

   

4. 选择要将事件发布到的终结点。 在以下屏幕截图中，“事件中心”是选定的终结点：

   

确认所选内容后，选择“创建”。 配置后，这些事件将被推送到终结点。

使用 CLI 进行设置

可以安装最新的 Azure CLI，也可以使用作为 Azure 订阅的一部分提供的 Azure Cloud Shell。

要安装事件网格扩展，请在 CLI 中使用以下命令：

az extension add --name eventgrid

下面的示例演示如何选择 Azure 订阅以及为 Azure 机器学习创建新的事件订阅：

# Select the Azure subscription that contains the workspace
az account set --subscription "<name or ID of the subscription>"

# Subscribe to the machine learning workspace. This example uses EventHub as a destination. 
az eventgrid event-subscription create --name {eventGridFilterName} \
  --source-resource-id /subscriptions/{subId}/resourceGroups/{RG}/providers/Microsoft.MachineLearningServices/workspaces/{wsName} \
  --endpoint-type eventhub \
  --endpoint /subscriptions/{SubID}/resourceGroups/TestRG/providers/Microsoft.EventHub/namespaces/n1/eventhubs/EH1 \
  --included-event-types Microsoft.MachineLearningServices.ModelRegistered \
  --subject-begins-with "models/mymodelname"

示例

示例：发送电子邮件警报

使用 Azure 逻辑应用为所有事件配置电子邮件。 根据条件进行自定义，并指定收件人，以实现跨协作团队的协作和意识。

1. 在 Azure 门户中，转到 Azure 机器学习工作区，然后从左侧边栏中选择“事件”选项卡。 在此处选择“逻辑应用”。

   

2. 登录逻辑应用 UI，然后选择机器学习服务作为主题类型。

   

3. 选择要通知的事件。 例如，以下屏幕截图 RunCompleted。

   

4. 接下来，添加一个步骤，以使用此事件并搜索电子邮件。 可以使用几个不同的邮件帐户来接收事件。 还可以配置何时发送电子邮件警报的条件。

   

5. 选择“发送电子邮件”并填写参数。 在主题中，可以添加“事件类型”和“主题”以帮助筛选事件。 还可以在消息正文中包含指向运行的工作区页面的链接。

   要保存此操作，请选择页面左上角的“另存为”。

   

后续步骤

要详细了解事件网格并尝试使用 Azure 机器学习事件，请参阅：

• 关于事件网格

• Azure 机器学习的事件架构