从存储中的事件网格事件运行批处理终结点

创建 托管标识资源 ：

# Use the Azure CLI to create the managed identity. Then copy the value of the variable IDENTITY into a Python variable
identity="/subscriptions/<subscription>/resourcegroups/<resource-group>/providers/Microsoft.ManagedIdentity/userAssignedIdentities/azureml-cpu-cluster-idn"
from azure.ai.ml import MLClient
from azure.ai.ml.entities import AmlCompute, ManagedIdentityConfiguration
from azure.ai.ml.constants import ManagedServiceIdentityType
compute_name = "batch-cluster"
compute_cluster = ml_client.compute.get(name=compute_name)
compute_cluster.identity.type = ManagedServiceIdentityType.USER_ASSIGNED
compute_cluster.identity.user_assigned_identities = [
    ManagedIdentityConfiguration(resource_id=identity)
ml_client.compute.begin_create_or_update(compute_cluster)
在 Azure 门户中，确保托管标识具有读取数据的正确权限。
若要访问存储服务，必须至少具有存储帐户存储 Blob 数据读取者访问权限。 只有存储帐户所有者可以通过 Azure 门户更改访问级别。
创建逻辑应用
在 Azure 门户中的 Azure 主页上，选择“创建资源”。

在“Azure 市场”菜单上，选择“集成”>“逻辑应用”。

在“创建逻辑应用”窗格中的“基本信息”选项卡上，提供有关你的逻辑应用资源的以下信息。

properties
LA-TravelTime-RG
你在其中创建逻辑应用资源和相关资源的 Azure 资源组。 此名称在各个区域中必须唯一，并且只能包含字母、数字、连字符 (-)、下划线 (_)、括号（(、)）和句点 (.)。
LA-TravelTime
逻辑应用资源名称，在各个区域中必须唯一，并且只能包含字母、数字、连字符 (-)、下划线 (_)、括号（(、)）和句点 (.)。
我们希望每次在存储帐户的特定文件夹（数据资产）中创建新文件时触发逻辑应用工作流。 逻辑应用使用事件的信息来调用批处理终结点并传递要处理的特定文件。
在工作流设计器中，按照以下常规步骤添加名为“发生资源事件时”的事件网格触发器。

在连接信息框中，选择要使用的身份验证类型，然后选择“登录”。

在触发器框中，请提供以下信息：

从“高级参数”列表中选择“前缀筛选器”，并提供以下值：

/blobServices/default/containers/<container-name>/blobs/<path-to-data-folder>

“前缀筛选器”属性允许事件网格仅在我们指定的特定路径中创建 blob 时通知工作流。 在这种情况下，我们假设文件将由所选存储帐户中 <container-name> 容器内的 <path-to-data-folder> 文件夹中的某个外部进程创建。 配置此参数以匹配数据的位置。 否则，将为在存储帐户的任何位置创建的任何文件触发该事件。 有关详细信息，请参阅事件网格的事件筛选。

以下示例演示了触发器的显示方式：
concat('https://login.microsoftonline.com/', parameters('tenant_id'), '/oauth2/token')
若要输入此表达式，请在“URI”框中选择。 从显示的选项中选择表达式编辑器（公式图标）。
值为 application/x-www-form-urlencoded 的 Content-Type
concat('grant_type=client_credentials&client_id=', parameters('client_id'), '&client_secret=', parameters('client_secret'), '&resource=https://ml.azure.com')
若要输入此表达式，请在“正文”框中选择。 从显示的选项中选择表达式编辑器（公式图标）。
以下示例演示了一个示例“授权”操作：

在“授权”操作下，添加另一个 HTTP 操作，并将标题重命名为“调用”。

在“调用”操作中提供以下信息：

以前的有效负载对应于模型部署。 如果使用管道组件部署，请根据管道输入的预期调整格式。 有关如何在 REST 调用中构建输入的详细信息，请参阅为批处理终结点创建作业和输入数据 (REST)。

以下示例演示了一个示例“调用”操作：

“调用”操作会触发批处理作业，但该操作不会等待作业完成。 默认情况下，Azure 逻辑应用不是为长时间运行的应用程序设置的。 如果你需要等待作业完成，建议切换到从 Azure 数据工厂运行批处理终结点。

完成后，保存工作流。

逻辑应用工作流已准备好执行，每次在指定路径下创建新文件时都会自动触发。
若要确认应用已成功收到事件，请查看应用的“运行历史记录”：