为自定义实施配置事件

此配置的某些部分是自定义开发，需要满足以下条件：

• 在Adobe Campaign中掌握JSON、XML和Javascript解析的工作知识。
• QueryDef和Writer API的工作知识。
• 使用私钥进行加密和身份验证的工作概念。

由于编辑Javascript代码需要技术技能，因此如果没有适当的了解，请不要尝试这样做。

在JavaScript中处理事件

JavaScript文件

Pipeline使用JavaScript函数处理每条消息。 此函数由用户定义。

它配置于 NmsPipeline_Config “JSConnector”属性下的选项。 每次收到事件时，都会调用此JavaScript。 它由 pipelined 进程。

示例Javascript文件为cus：triggers.js。

JavaScript 函数

此 pipelined Javascript必须以特定函数开头。

此函数针对每个事件调用一次：

function processPipelineMessage(xmlTrigger) {}

它应返回为

<undefined/>

您应该重新启动 pipelined 编辑Javascript之后。

触发数据格式

此 trigger 数据以XML格式传递到JS函数。

• 此 @triggerId 属性包含 trigger.
• 此 扩充功能 JSON格式的元素包含Adobe Analytics生成的数据，并附加到触发器。
• @offset 是消息的“指针”。 它指示消息在队列中的顺序。
• @partition 是队列中的消息容器。 偏移相对于分区。
  队列中有大约15个分区。

示例:

<trigger offset="1500435" partition="4" triggerId="LogoUpload_1_Visits_from_specific_Channel_or_ppp">
 <enrichments>{"analyticsHitSummary":{"dimensions":{" eVar01":{"type":"string","data":["PI4INE1ETDF6UK35GO13X7HO2ITLJHVH"],"name":" eVar01","source":"session summary"}, "timeGMT":{"type":"int","data":[1469164186,1469164195],"name":"timeGMT","source":"session summary"}},"products":{}}}</enrichments>
 <aliases/>
 </trigger>

数据格式扩充

在Adobe Analytics中为每个触发器以JSON格式定义内容。
例如，在触发器LogoUpload_uploading_Visits中：

• eVar01 可以包含字符串格式的购物者ID，此ID用于与Adobe Campaign收件人进行协调。
  必须对其进行协调才能找到购物者ID（主键）。

• timeGMT 可以包含Adobe Analytics端的触发器时间（UTC纪元格式）（自01/01/1970 UTC以来的秒数）。

示例:

{
 "analyticsHitSummary": {
 "dimensions": {
 "eVar01": {
 "type": "string",
 "data": ["PI4INE1ETDF6UK35GO13X7HO2ITLJHVH"],
 "name": " eVar01",
 "source": "session summary"
 },
 "timeGMT": {
 "type": "int",
 "data": [1469164186, 1469164195],
 "name": "timeGMT",
 "source": "session summary"
 }
 },
 "products": {}
 }
 }

事件处理顺序

按偏移量顺序逐个处理事件。 的每一个线程 pipelined 处理不同的分区。

检索的最后一个事件的“offset”存储在数据库中。 因此，如果进程停止，它会从最后一条消息重新启动。 此数据存储在内置模式xtk：pipelineOffset中。

此指针特定于每个实例和每个使用者。 因此，当多个实例使用不同的使用者访问同一管道时，它们都会按相同的顺序获取所有消息。

此 消费者 管线选项的参数标识调用实例。

目前，无法为单独的环境（例如“暂存”或“开发”）设置不同的队列。

日志记录和错误处理

诸如logInfo()之类的日志将定向到 pipelined 日志。 诸如logError()之类的错误将写入 pipelined 记录并使该事件进入重试队列。 在这种情况下，您应该检查管道化日志。
出错的消息会在中设置的持续时间内重试多次。 pipelined 选项。

出于调试和监控目的，完整的触发器数据将以XML格式写入“数据”字段的触发器表中。 或者，包含触发器数据的logInfo()也具有相同的用途。

解析数据

此示例Javascript代码解析扩充功能中的eVar01。

function processPipelineMessage(xmlTrigger)
 {
 (…)
 var shopper_id = ""
 if (xmlTrigger.enrichments.length() > 0)
 {
 if (xmlTrigger.enrichments.toString().match(/eVar01/) != undefined)
 {
 var enrichments = JSON.parse(xmlTrigger.enrichments.toString())
 shopper_id = enrichments.analyticsHitSummary.dimensions. eVar01.data[0]
 }
 }
 (…)
 }

解析时请务必小心以避免出错。
由于此代码用于所有触发器，因此不需要大多数数据。 因此，当不存在时，可以将其留空。

存储触发器

此示例JS代码将触发器保存到数据库。

function processPipelineMessage(xmlTrigger)
 {
 (…)
 var event =
 <pipelineEvent
 xtkschema = "cus:pipelineEvent"
 _operation = "insert"
 created = {timeNow}
 lastModified = {timeNow}
 triggerType = {triggerType}
 timeGMT = {timeGMT}
 shopper_id = {shopper_id}
 data = {xmlTrigger.toXMLString()}
 />
 xtk.session.Write(event)
 return <undef/>;
 }

约束

此代码的性能必须最佳，因为它以高频率运行，可能会对其他营销活动产生潜在的负面影响。 尤其是当在营销服务器上每小时处理的触发事件超过100万时，或者未正确调整时。

此Javascript的上下文是有限的。 并非该API的所有函数都可用。 例如，getOption()或getCurrentdate()不起作用。

为了加快处理速度，将同时执行此脚本的多个线程。 代码必须是线程安全的。

存储事件

管道事件架构

事件存储在数据库表中。 营销活动使用它来定位客户，并通过触发器丰富电子邮件。
尽管每个触发器可以具有独特的数据结构，但所有触发器都可保存在单个表中。
triggerType字段标识数据源自哪个触发器。

以下是此表的模式代码示例：

显示事件

事件可以通过基于事件架构的简单表单显示。

处理事件

协调工作流

协调是将客户从Adobe Analytics匹配到Adobe Campaign数据库的过程。 例如，匹配的条件可以是shopper_id。

出于性能原因，必须通过工作流以批处理模式进行匹配。
频率必须设置为15分钟以优化工作负载。 因此，在Adobe Campaign中接收事件到营销工作流处理该事件之间的延迟最长为15分钟。

JavaScript中单元协调的选项

可以在JavaScript中为每个触发器运行协调查询。 它有更高的性能影响并提供更快的结果。 当需要反应性的特定用例时，可能需要该属性。

如果未对shopper_id设置索引，则可能难以实施。 如果标准与营销服务器位于不同的数据库服务器上，则它会使用性能较差的数据库链接。

清除工作流

触发器在一小时内处理。 该数量大约可以每小时100万次触发。 它解释了必须设置清除工作流的原因。 清除每天运行一次，并删除所有超过三天的触发器。

营销活动工作流

触发活动工作流通常与其他已使用的定期活动类似。
例如，它可以从对触发器的查询开始，在最后一天查找特定事件。 该目标用于发送电子邮件。 丰富或数据可能来自触发器。 营销人员可以安全地使用它，因为它不需要进行配置。

Business.Adobe.com 资源