Using Tealium Functions for Acxiom Identity Resolution

We recommend using a visitor function to capture the data from Acxiom. For more information on visitor functions, see Event and Visitor Functions.

The visitor function does the following:

Requests the additional data from Acxiom.
Sends an event containing the additional data and tealium_visitor_id to Tealium Collect.

The EventStream attributes and visitor attributes are enriched by the event sent from the function. The following figure illustrates the process of retrieving data from the identity provider and saving it in the visitor profile:

Prerequisites

EventSteam and Functions.
The Tealium Collect API as a Data Source.
Create visitor attributes to store the additional information.
Create an event spec titled acxiom_function_event. This will contain the desired attributes, which will be used to enrich the visitor attributes.
Add an enrichment to enrich the visitor attributes with the value of the event attributes.

The function works best when the Acxiom Real Tag tag is installed. This identifier will increase the confidence rating for the visitor.

Creating a function to process the event

To create the function:

Navigate to the Functions interface.
Click Add Function.
Enter a name for the function.
Enter appropriate notes to describe the function for later reference.
Select the Processed Event trigger.
Select the desired event feed for the trigger.
Click Continue.
Enter the sample code below into the Code box.
Customize the code as necessary for your configuration.
Save the function.

You can test the function with the Test feature and a tool such as Postman API Workbench.

For more information on creating a function, see Managing Functions.

Example function code

The following test example function will attempt to match a visitor profile based off of the attributes you send to it:

Attribute	Description
`acxiom_function_event`	Event Spec name
`realId`	Acxiom rTag
`address`	User’s address
`phone`	User’s phone number
`email`	User’s email address
`fullName`	User’s full name

The function will return any additional user data for profile enrichment.

This code is currently in beta.

Code

// In an event scoped function, the following modules are available for use: event, auth
import { event, store, tealium } from "tealium";
(async () => {
    
    // These endpoints will be specific to each customers setup with Acxiom as they will refer to the customers provisioned private environment.
    const access_url="https://mydomain.com/metrics/access_token"
    const query_url="https://mydomain.com/metrics"
    const query_name="demo_dsapi_match"

    // Uncomment this to find out exactly what is available to use in your event object
    console.log('Data available:\n', JSON.stringify(event, null, 2));

    const data = {};
    data.tealium_account = event?.data?.udo?.tealium_account;
    data.tealium_profile = event?.data?.udo?.tealium_profile;
    data.visitor_id = event?.data?.udo?.visitor_id;
    data.trace_id = event?.data?.firstparty_tealium_cookies?.trace_id;
    data.acxiom_real_id = event?.data?.udo?.acxiom_real_id || "";
    data.customer_email = event?.data?.udo?.customer_email;
    data.customer_first_name = event?.data?.udo?.customer_first_name;
    data.customer_last_name = event?.data?.udo?.customer_last_name;
    data.customer_full_name = `${data.customer_first_name} ${data.customer_last_name}`

    // Check if acxiom_real_id is available
    // if (typeof data.acxiom_real_id === "undefined") {
    //     console.error("acxiom_entity_id is unavailable.");
    //     return;
    // }

    // Pull in refresh token from global variables
    const refresh_token = store.get("acxiom_refresh_token")
    console.log("refresh_token: ", refresh_token)

    // Generate access token
    const access_token_request = await fetch(access_url, {
        method: "POST",
        headers: {
            "Content-Type": "application/json",
            "Authorization": `Bearer ${refresh_token}`
        },
        body: `{"grant_type":"refresh_token","refresh_token":"${refresh_token}"}`
    })
    .catch((error) => {
        console.error('Error:', error);
    });
    const access_token_response = await access_token_request.json();
    // console.log("access_token_response:", JSON.stringify(access_token_response));
    const access_token = access_token_response.jwt_token;
    // console.log("access_token: ", access_token)

    // Fetch query_execution_id from Acxiom PAIL with acxiom_real_id
    const response = await fetch(`${query_url}/named_queries/${query_name}/execute`, {
        method: "POST",
        redirect: "follow",
        headers: {
            "Content-Type": "application/json",
            "Authorization": `Bearer ${access_token}`
        },
        body: `{
            "realID": "${data?.acxiom_real_id}", 
            "address": "${data?.customer_address}", 
            "phone": "${data?.customer_phone}", 
            "email": "${data?.customer_email}", 
            "fullName": "${data?.customer_full_name}"
        }`
    })
    .then(res => {
        console.log("Res: ", JSON.stringify(res))
        return res
    })
    // .then(response => console.log("Response: ", JSON.stringify(response)))
    .catch(error => console.error('Error: ', error.message));
    const body = await response.json();
    const query_execution_id = body.query_execution_id
    
    // console.log("Status: " + response.status);
    console.log("Body: " + JSON.stringify(body, null, 2));

    // Check if Acxiom response data is available
    if (!response.ok) {
        console.error("Acxiom response data is unavailable.");
        return;
    }

    // Fetch data from Acxiom PAIL with query_execution_id
    const payload = await fetch(`${query_url}/query_executions/${query_execution_id}`, {
        method: "GET",
        headers: {
            "Content-Type": "application/json",
            "Authorization": `Bearer ${access_token}`
        }
    })
    .then(res => {
        console.log("Res: ", JSON.stringify(res))
        return res
    })
    // .then(response => response.json())
    // .then(response => console.log("Response: ", JSON.stringify(response)))
    .catch(err => console.error(err));

    const user_data = await payload.json();
    console.log("user_data: ", JSON.stringify(user_data))

    let data_object = {};
    for (let i=0; i < user_data.column_info.length; i++) {
        data_object[user_data.column_info[i].name] = user_data.data[0][i]
    }
    // data_object = JSON.stringify(data_object)

    let newEvent = {};
    newEvent = { ...data_object }
    newEvent.tealium_event = "acxiom_function_event";
    newEvent.visitor_id = data.visitor_id;
    newEvent.tealium_trace_id = data?.tealium_trace_id;
    newEvent.customer_email = data_object?.email;
    
    console.log("newEvent: " + JSON.stringify(newEvent, null, 2));

    // Send data received from Acxiom to Tealium
    tealium
        .sendCollectEvent(newEvent, data.tealium_account, data.tealium_profile)
        .then(response => {
            console.log('Status code: ', response.status);
            return response;
        })
        .then(data => console.log('Result: ', JSON.stringify(data, null, 2)))
        .catch(error => console.error('Error: ', error.message));
})();