此配置的组成部分是自定义开发,需要满足以下条件:
由于编辑Javascript代码需要技术技能,因此在没有适当了解的情况下请勿尝试这样做。
Pipeline使用JavaScript函数处理每条消息。 此函数由用户定义。
它可在中进行配置 NmsPipeline_Config “JSConnector”属性下的选项。 每次收到事件时都会调用此JavaScript。 它由 pipelined 进程。
示例Javascript文件为cus:triggers.js。
此 pipelined Javascript必须以特定函数开头。
此函数为每个事件调用一次:
function processPipelineMessage(xmlTrigger) {}
它应返回为
<undefined/>
您应该重新启动 pipelined 在编辑Javascript之后。
此 trigger 数据以XML格式传递到JS函数。
示例:
<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以来的秒数)。
示例:
{
"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字段标识数据来源的触发器。
以下是此表的模式代码示例:
属性 | 类型 | 标签 | 说明 |
---|---|---|---|
pipelineEventId | 长整型 | 主键 | 触发器的内部主键。 |
数据 | 备注 | 触发数据 | XML格式的触发器数据的完整内容。 用于调试和审核。 |
triggerType | 字符串50 | TriggerType | 触发器的名称。 标识客户在网站上的行为。 |
shopper_id | 字符串32 | shopper_id | 购物者的内部标识符。 由协调工作流设置。 如果为0,则表示在Campaign中未知该客户。 |
shopper_key | 长整型 | shopper_key | 购物者的Analytics捕获的外部标识符。 |
已创建 | 日期时间 | 已创建 | 在Campaign中创建事件的时间。 |
lastModified | 日期时间 | 上次修改时间 | 上次在Adobe中修改事件的时间。 |
时间GMT | 日期时间 | 时间戳 | 在Analytics中生成事件的时间。 |
事件可以通过基于事件架构的简单表单显示。
协调是将客户从Adobe Analytics匹配到Adobe Campaign数据库的过程。 例如,匹配的条件可以是shopper_id。
出于性能原因,必须通过工作流以批处理模式进行匹配。
频率必须设置为15分钟以优化工作负载。 因此,在Adobe Campaign中接收事件到营销工作流处理该事件之间的延迟最长为15分钟。
可以在JavaScript中为每个触发器运行协调查询。 它有更高的性能影响并提供更快的结果。 对于需要反应性的特定用例,可能需要此参数。
如果未对shopper_id设置索引,则可能难以实施。 如果标准与营销服务器位于不同的数据库服务器上,则它会使用性能较差的数据库链接。
触发器在小时内处理。 该数量大约可达每小时100万次触发。 它解释了必须设置清除工作流的原因。 清除每天运行一次,并删除所有超过三天的触发器。
触发活动工作流通常与其他已使用的定期活动类似。
例如,它可以从对触发器的查询开始,在最后一天查找特定事件。 该目标用于发送电子邮件。 “扩充”或“数据”可能来自触发器。 营销人员可以安全地使用它,因为它不需要进行配置。