Data Warehouse

mParticle’s Data Warehouse integration with Amazon Redshift forwards all your incoming data to a Redshift cluster, allowing you to query the raw data directly.

The integration performs the following tasks in your Redshift cluster:

1. Creates a table for each custom app event name and each eCommerce event name with a volume above a defined threshold. Less common events are recorded in a single table, labeled otherevents.
2. Adds new columns to tables when new events or user attributes are received.
3. Creates a view unioning all tables within each schema, and a view in the PUBLIC schema that unions the views of all schema. Updates these views as new tables are created.
4. If enabled, performs data hygeine on your cluster every 24 hours to purge expired data and run vacuum and analyze commands.

By default, the integration begins loading current data into Redshift from the time it is enabled. You can work with your mParticle Customer Service Manager to load historical data.

Enable the Integration

Redshift Database Setup

1. Create a Database and Schema

Create your Redshift Database. Preferably, the database should be in the us-east-1 region. Choosing a different region will increase latency between mParticle and Redshift.

Within your database, create a schema to store your data.

2. Create groups and users to manage permissions

Once your database is ready, you need to create groups with permissions to read and write data to the database.

create group readwritegroup; 
create group readonlygroup;

grant all on schema your_schema_name to group readwritegroup;

Be sure to replace your_schema_name with your own name.

mParticle uses these groups to grant permissions for new tables it creates in the database. You must use the names readwritegroup and readonlygroup. You can also use these groups to control permissions for mParticle data in Redshift.

Create a user in each group. mParticle uses the dataloader user to create tables and write to the schema. The readonlyuser is used to run queries from the mParticle dashboard.

create user dataloader in group readwritegroup password 'Aabcde123!';

create user readonlyuser in group readonlygroup password 'Abcde123!';

mParticle Setup

After adding Amazon Redshift from the integrations Directory, you can find the settings UI at Setup > Data Warehouse.

From the main page for your Redshift configuration, select the Settings tab to provide the necessary settings to get your Redshift integration working.

Once your Data Warehose integration is configured, connect individual inputs to the Amazon Redshift output from the Connections page. You must connect every input you want to store data for.

Data Schema

Each common custom app event name and eCommerce event name have their own table in Redshift, and all other event names (e.g., session-start, session-end) are stored in a single “otherevents” table. The naming conversion of the table names are as follows.

• A custom app event name will have a table named event_[event type]_[event name]. For example, a custom app event of event type Navigation named SignUp will have a table named event_navigation_signup.
• An eCommerce event name will have a table named ecomm_[event name].
• Consent events have tables named consent_given and consent_rejected
• All other events are stored in a table named otherevents.

mParticle also creates two views, which can be used to get aggregated views of your app data.

• Under each schema, a view called eventsview that unions all tables under the schema.
• Under the “public” schema, a view called eventsview that unions all eventsview views from all schema in the database.

Common Columns

Each table has the following common columns.

eCommerce Only Columns

Event and User Attribute Columns

Each individual event name table (not including otherevents) also has one column per event attribute, named like: “ea[attribute_name]”, and one column per user attribute, named like “ua[attribute_name]“.

The benefit of these individual attribute columns is that you don’t have to use slower JSON parse functions in your query to extract attribute values from either EventAttributes or UserAttributes columns. If you wish, individual User Attribute columns can be turned off by disabling the Send user attribute columns setting.

Redshift Cluster Security Setup

For mParticle to access your cluster, the IPs of mParticle servers need to be whitelisted on your cluster. Since we regularly add new IPs as we scale our platform, the easiest approach is to follow the instructions below to set up an AWS Lambda function to automatically sync our IPs. Alternatively, you can get the most up-to-date IP list here.

1. Create a new VPC security group and note the security group ID and the AWS region. Leave the inbound rules empty as they will be managed by the Lambda function.
2. Create a new AWS Lambda function. Do not select a template.

• Download this zip file that containing the Python code for the Lambda function. The source code is available on GitHub at https://github.com/mParticle/redshift-ip-whitelist.
• Set the runtime of the Lambda function to Python, upload the zip file, and set the Lambda function handler to client.lambda_handler.
• Create a new role for the Lambda function.
• Set the timeout value to 1 min to give enough time for the function to run.

3. Create a new AWS policy, paste in the following json, and attach it to the new role. Make sure you replace the [aws-region], [accountid-here] and [sg-securitygroupid-here] with your AWS account Id and the security group Id from step 1.

       {
           "Version": "2012-10-17",
           "Statement": [
               {
                   "Sid": "Stmt1463090293000",
                   "Effect": "Allow",
                   "Action": [
                       "ec2:DescribeInstanceAttribute",
                       "ec2:DescribeInstanceStatus",
                       "ec2:DescribeInstances",
                       "ec2:DescribeNetworkAcls",
                       "ec2:DescribeSecurityGroups"
                   ],
                   "Resource": [
                       "*"
                   ]
               },
               {
                   "Sid": "Stmt1463090293001",
                   "Effect": "Allow",
                   "Action": [
                       "ec2:AuthorizeSecurityGroupIngress",
                       "ec2:RevokeSecurityGroupIngress"
                   ],
                   "Resource": [
                       "arn:aws:ec2:[aws-region]:[accountid-here]:security-group/[sg-securitygroupid-here]"
                   ]
               },
               {
                   "Effect": "Allow",
                   "Action": [
                       "logs:CreateLogGroup",
                       "logs:CreateLogStream",
                       "logs:PutLogEvents"
                   ],
                   "Resource": "arn:aws:logs:*:*:*"
               }
           ]
       }

4. Configure a trigger to call the Lambda function on a regular basis.

• Go to CloudWatch and create a new rule (under Events > Rules section accessible from the left panel). We suggest that you use a schedule of a fixed rate of 12 hours as the event selector for the rule. The target of the rule should be the Lambda function created above.

• In the configure input section, pick Constant (JSON text), and put in the following JSON with proper values populated.

  • The security_group_id is the security group ID created in step 1
  • the redshift_port is that redshift port of your cluster
  • the is_vpc represents if your cluster is in VPC or not

    {
        "security_group_id": "security group id created in step 1", 
        "redshift_port": 5439, 
        "is_vpc": true,
        "aws_region": "aws region noted in step 1"
    }

Partner Feed Data

Events from each connected Partner Feed will be stored under a single table. You can choose the table name for each Feed in the Connection Settings.

Error Handling

mParticle loads data into Redshift via Amazon S3 and can tolerate the Redshift cluster being unavailable for up to 30 days, depending on data volume. In the event of extended downtime on your cluster, a data replay can be arranged.

Looker Integrations

mParticle provides Looker Blocks that you can directly use to get a holistic picture of how your apps are doing. You just need to copy the lookml files into your Looker account. There are four dashboard templates. You can access mParticle’s Looker Blocks implementation by reaching out to your assigned Looker analyst or requesting a Looker trial.

• App Activity Dashboard. This dashboard gives you an overview of most common app activities, including active user count, new user count, session count, average session length, revenue data, custom funnel analytics, and user retention analysis.

• Audience Dashboard. This dashboard reports how effective an given audience is, comparing users in the audience to other app users. When looking at this dashboard, please make sure you provide a valid audience ID wrapped in quotes in the audience membership filter, e.g., “1234”. You can get the audience ID from mParticle UI.

• eCommerce Dashboard. This dashboard offers insights on revenue generated from your apps, e.g., which user acquisition channels gives you the most valuable users, how does total revenue and average revenue per user change over time, how do users’ purchase behaviors change over the course of a day, and where do users drop off in the purchase funnel.

• App Version Dashboard. This dashboard tells you how much a new app version has changed your app performance, e.g., has a new app version improved user retention, or increased revenue per user, or increased average session length, etc.

On all four dashboards, you can filter by date range and app platform. Note that in order for the user retention chart to be meaningful, please make sure the event date filter and install date filter have the same date range.

Following the Looker data models and design patterns in the prebuilt Looker Blocks, you can build any Looker report you want that better suits your analytics needs.