[也適用於v8]{class="badge positive" title="亦適用於Campaign v8"}

設定自訂實施的事件 events

此設定的部分是自訂開發，需要以下專案：

由於編輯Javascript程式碼需要技術技能，因此請勿在未經適當瞭解的情況下嘗試。

在JavaScript中處理事件 events-javascript

JavaScript檔案 file-js

Pipeline會使用JavaScript函式來處理每則訊息。 此函式由使用者定義。

已在「JSConnector」屬性下的​ NmsPipeline_Config ​選項中設定。 每次收到事件時都會呼叫此JavaScript。 由pipelined處理序執行。

範例Javascript檔案為cus：triggers.js。

JavaScript 函數 function-js

pipelined Javascript必須以特定函式開頭。

此函式會針對每個事件呼叫一次：

function processPipelineMessage(xmlTrigger) {}

它應該會傳回為

<undefined/>

您應該在編輯Javascript後重新啟動pipelined。

觸發資料格式 trigger-format

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>

資料格式擴充 enrichment-format

對於每個觸發程式，內容會在Adobe Analytics中以JSON格式定義。
例如，在觸發器中LogoUpload_uploading_Visits：

例如：

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

事件處理順序 order-events

事件會依位移順序逐一處理。 pipelined的每個執行緒處理不同的資料分割。

擷取的最後一個事件的「offset」會儲存在資料庫中。 因此，如果流程停止，它會從最後一個訊息重新啟動。 此資料儲存在內建方案xtk：pipelineOffset中。

此指標是每個執行個體和每個取用者專屬的。 因此，當許多執行個體使用不同的消費者存取相同的管道時，他們每個人都會以相同的順序收到所有訊息。

管線選項的​ 消費者 ​引數可識別呼叫的執行個體。

目前，對於不同的環境（例如「測試」或「開發」），無法擁有不同的佇列。

記錄與錯誤處理 logging-error-handling

記錄檔(例如logInfo())會導向至pipelined記錄檔。 錯誤(例如logError())會寫入pipelined記錄檔，導致事件進入重試佇列。 在此情況下，您應該檢查管線記錄。
在pipelined選項中設定的期間內，錯誤訊息會重試多次。

為了偵錯和監控之目的，完整的觸發程式資料會以XML格式寫入「資料」欄位中的觸發程式表格中。 或者，包含觸發程式資料的logInfo()也可達到相同目的。

剖析資料 data-parsing

此範例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]
 }
 }
 (…)
 }

剖析時請小心，以免發生錯誤。
由於此程式碼用於所有觸發器，因此大部分資料並非必要。 因此，當不存在時，可以保留空白。

儲存觸發器 storing-triggers-js

此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/>;
 }

限制 constraints

此程式碼的效能必須是最佳的，因為它會在高頻率執行，而且可能會對其他行銷活動造成潛在的負面影響。 特別是在行銷伺服器上每小時處理超過一百萬個觸發事件時，或是未正確調整時。

此Javascript的內容有限。 並非所有API函式都可使用。 例如，getOption()或getCurrentdate()無法運作。

為了啟用更快速的處理，此指令碼的多個執行緒會同時執行。 程式碼必須是執行緒安全。

儲存事件 store-events

管道事件結構描述 pipeline-event-schema

事件儲存在資料庫表格中。 行銷活動會使用它來鎖定客戶，並使用觸發器豐富電子郵件。
雖然每個觸發器可以有不同的資料結構，但所有觸發器都可儲存在單一表格中。
triggerType欄位會識別觸發資料來源的來源。

以下是此表格的結構描述程式碼範例：

顯示事件 display-events

事件可以基於事件結構的簡單表單來顯示。

處理事件 processing-the-events

調解工作流程 reconciliation-workflow

調解是將客戶從Adobe Analytics對應到Adobe Campaign資料庫的程式。 例如，相符的標準可以是shopper_id。

基於效能考量，相符必須由工作流程以批次模式完成。
頻率必須設定為15分鐘以最佳化工作負載。 因此，在Adobe Campaign中接收事件與行銷工作流程處理事件之間的延遲最長為15分鐘。

JavaScript中用於單元協調的選項 options-unit-reconciliation

您可以在JavaScript中為每個觸發程式執行調解查詢。 效能影響更大，成果更快速。 在需要反應性的特定使用案例中，可能有此需要。

如果shopper_id上未設定索引，則可能很難實作。 如果條件位在與行銷伺服器不同的資料庫伺服器上，則會使用效能不佳的資料庫連結。

清除工作流程 purge-workflow

觸發程式會在小時內處理。 音量大約為每小時100萬個觸發器。 它說明了必須建立清除工作流程的原因。 清除每天執行一次，並刪除所有超過三天的觸發器。

行銷活動工作流程 campaign-workflow

觸發行銷活動工作流程通常與其他已使用的週期性行銷活動類似。
例如，它可以從對最後一天期間尋找特定事件的觸發器的查詢開始。 該目標用於傳送電子郵件。 擴充功能或資料可以來自觸發器。 行銷人員可以安全地使用它，因為它不需要設定。