Audience Activation到Microsoft Azure事件中心 — 定义Azure函数

文档 Experience Platform 全面的技术教程

2.4.6创建您的Microsoft Azure项目

Last update: Thu Nov 21 2024 00:00:00 GMT+0000 (Coordinated Universal Time)

熟悉础锄耻谤别事件中心功能

Azure Functions允许您运行一小段代码（称为? 函数），而无需担心应用程序基础架构。利用Azure Functions，云基础架构可提供保持应用程序大规模运行所需的所有最新服务器。

函数是由特定类型的事件触发的? ?。支持的触发器包括响应数据更改、响应消息（例如事件中心）、按计划运行或作为HTTP请求的结果。

Azure Functions是一种无服务器计算服务，可让您运行事件触发的代码，而无需明确配置或管理基础架构。

Azure事件中心与Azure Functions集成以实现无服务器架构。

打开Visual Studio代码并登录到础锄耻谤别

Visual Studio Code可以轻松地……

定义础锄耻谤别函数并将其绑定到事件中心
本地测试
部署到础锄耻谤别
远程日志函数执行

打开Visual Studio Code

登录到础锄耻谤别

使用您在上一个练习中注册的Azure帐户登录时，Visual Studio Code将允许您查找并绑定所有事件中心资源。

打开Visual Studio Code并单击? Azure ?图标。

接下来，选择? 登录到础锄耻谤别：

系统会将您重定向到浏览器以登录。请记住选择用于注册的Azure帐户。

当您在浏览器中看到以下屏幕时，您是使用Visual Code Studio登录的：

返回到Visual Code Studio（您将看到Azure订阅的名称，例如? 础锄耻谤别订阅1）：

创建础锄耻谤别项目

单击? 创建函数项目……：

选择或创建您选择的本地文件夹以保存项目，然后单击? 选择：

现在，您将进入项目创建向导。单击? Javascript ?作为项目的语言：

然后选择? 模型惫4。

选择? 础锄耻谤别事件中心触发器 ?作为项目的第一个函数模板：

输入函数的名称，使用以下格式--aepUserLdap---aep-event-hub-trigger并按贰苍迟别谤键：

选择? 新建本地应用设置：

单击以选择您之前创建的名为--aepUserLdap---aep-enablement的事件中心命名空间。

接下来，单击以选择您之前创建的名为--aepUserLdap---aep-enablement-event-hub的事件中心。

单击以选择? RootManageSharedAccessKey ?作为事件中心策略：

选择? 添加到工作区，了解如何打开项目：

您随后可能会收到这样的消息。在这种情况下，请单击? 是，我信任作者。

创建项目后，在编辑器中打开文件--aepUserLdap---aep-event-hub-trigger.js：

51黑料不打烊 Experience Platform发送到事件中心的有效负载将如下所示：

{
  "identityMap": {
    "ecid": [
      {
        "id": "36281682065771928820739672071812090802"
      }
    ]
  },
  "segmentMembership": {
    "ups": {
      "94db5aed-b90e-478d-9637-9b0fad5bba11": {
        "createdAt": 1732129904025,
        "lastQualificationTime": "2024-11-21T07:33:52Z",
        "mappingCreatedAt": 1732130611000,
        "mappingUpdatedAt": 1732130611000,
        "name": "vangeluw - Interest in Plans",
        "status": "realized",
        "updatedAt": 1732129904025
      }
    }
  }
}

使用以下代码更新Visual Studio代码的--aepUserLdap---aep-event-hub-trigger.js中的代码。每次Real-time CDP将受众资格发送到事件中心目标时，都将执行此代码。在此示例中，代码仅用于显示传入有效负载，但您可以想象任何类型的附加功能，以便实时处理受众资格并使用进一步的数据管道生态系统。

文件--aepUserLdap---aep-event-hub-trigger.js中的第11行当前显示以下内容：

context.log('Event hub message:', message);

将--aepUserLdap---aep-event-hub-trigger.js中的第11行更改为：

context.log('Event hub message:', JSON.stringify(message));

总有效负载应如下所示：

const { app } = require('@azure/functions');

app.eventHub('--aepUserLdap---aep-event-hub-trigger', {
    connection: '--aepUserLdap--aepenablement_RootManageSharedAccessKey_EVENTHUB',
    eventHubName: '--aepUserLdap---aep-enablement-event-hub',
    cardinality: 'many',
    handler: (messages, context) => {
        if (Array.isArray(messages)) {
            context.log(`Event hub function processed ${messages.length} messages`);
            for (const message of messages) {
                context.log('Event hub message:', message);
            }
        } else {
            context.log('Event hub function processed message:', messages);
        }
    }
});

结果应如下所示：