Post Syndicated from Apoorv Gakhar original https://aws.amazon.com/blogs/messaging-and-targeting/analyze-and-improve-email-campaigns-with-amazon-simple-email-service-and-amazon-quicksight/

Email is a popular channel for applications, used in both marketing campaigns and other outbound customer communications. The challenge with email is that it can become increasingly complex to manage for companies that must send large quantities of messages per month. This complexity is especially true when companies need to measure detailed email engagement metrics to track campaign success.

As a marketer, you want to monitor several metrics, including open rates, click-through rates, bounce rates, and delivery rates. If you do not track your email results, you could potentially be wasting your campaign resources. Monitoring and interpreting your sending results can help you deliver the best content possible to your subscribers’ inboxes, and it can also ensure that your IP reputation stays high. Mailbox providers prioritize inbox placement for senders that deliver relevant content. As a business professional, tracking your emails can also help you stay on top of hot leads and important clients. For example, if someone has opened your email multiple times in one day, it might be a good idea to send out another follow-up email to touch base.

Building a large-scale email solution is a complex and expensive challenge for any business. You would need to build infrastructure, assemble your network, and warm up your IP addresses. Alternatively, working with some third-party email solutions require contract negotiations and upfront costs.

Fortunately, Amazon Simple Email Service (SES) has a highly scalable and reliable backend infrastructure to reduce the preceding challenges. It has improved content filtering techniques, reputation management features, and a vast array of analytics and reporting functions. These features help email senders reach their audiences and make it easier to manage email channels across applications. Amazon SES also provides API operations to monitor your sending activities through simple API calls. You can publish these events to Amazon CloudWatch, Amazon Kinesis Data Firehose, or by using Amazon Simple Notification Service (SNS).

In this post, you learn how to build and automate a serverless architecture that analyzes email events. We explore how to track important metrics such as open and click rate of the emails.

Solution overview

The metrics that you can measure using Amazon SES are referred to as email sending events. You can use Amazon CloudWatch to retrieve Amazon SES event data. You can also use Amazon SNS to interpret Amazon SES event data. However, in this post, we are going to use Amazon Kinesis Data Firehose to monitor our user sending activity.

Enable Amazon SES configuration sets with open and click metrics and publish email sending events to Amazon Kinesis Data Firehose as JSON records. A Lambda function is used to parse the JSON records and publish the content in the Amazon S3 bucket.

Ingested data lands in an Amazon S3 bucket that we refer to as the raw zone. To make that data available, you have to catalog its schema in the AWS Glue data catalog. You create and run the AWS Glue crawler that crawls your data sources and construct your Data Catalog. The Data Catalog uses pre-built classifiers for many popular source formats and data types, including JSON, CSV, and Parquet.

When the crawler is finished creating the table definition and schema, you analyze the data using Amazon Athena. It is an interactive query service that makes it easy to analyze data in Amazon S3 using SQL. Point to your data in Amazon S3, define the schema, and start querying using standard SQL, with most results delivered in seconds.

Now you can build visualizations, perform ad hoc analysis, and quickly get business insights from the Amazon SES event data using Amazon QuickSight. You can easily run SQL queries using Amazon Athena on data stored in Amazon S3, and build business dashboards within Amazon QuickSight.

Deploying the architecture:

Configuring Amazon Kinesis Data Firehose to write to Amazon S3:

1. Navigate to the Amazon Kinesis in the AWS Management Console. Choose Kinesis Data Firehose and create a delivery stream.
2. Enter delivery stream name as “SES_Firehose_Demo”.
3. Under the source category, select “Direct Put or other sources”.
4. On the next page, make sure to enable Data Transformation of source records with AWS Lambda. We use AWS Lambda to parse the notification contents that we only process the required information as per the use case.
5. Click the “Create New” Lambda function.
6. Click on “General Kinesis Data FirehoseProcessing” Lambda blueprint and this opens up the Lambda console. Enter following values in Lambda
   • Name: SES-Firehose-Json-Parser
   • Execution role: Create a new role with basic Lambda permissions.
7. Click “Create Function”. Now replace the Lambda code with the following provided code and save the function.

   • 'use strict';
     console.log('Loading function');
     exports.handler = (event, context, callback) => {
        /* Process the list of records and transform them */
         const output = event.records.map((record) => {
             console.log(record.recordId);
             const payload =JSON.parse((Buffer.from(record.data, 'base64').toString()))
             console.log("payload : " + payload);
             
             if (payload.eventType == "Click") {
             const resultPayLoadClick = {
                     eventType : payload.eventType,
                     destinationEmailId : payload.mail.destination[0],
                     sourceIp : payload.click.ipAddress,
                 };
             console.log("resultPayLoad : " + resultPayLoadClick.eventType + resultPayLoadClick.destinationEmailId + resultPayLoadClick.sourceIp);
             
             //const parsed = resultPayLoad[0];
             //console.log("parsed : " + (Buffer.from(JSON.stringify(resultPayLoad))).toString('base64'));
             
             
             return{
                 recordId: record.recordId,
                 result: 'Ok',
                 data: (Buffer.from(JSON.stringify(resultPayLoadClick))).toString('base64'),
             };
             }
             else {
                 const resultPayLoadOpen = {
                     eventType : payload.eventType,
                     destinationEmailId : payload.mail.destination[0],
                     sourceIp : payload.open.ipAddress,
                 };
             console.log("resultPayLoad : " + resultPayLoadOpen.eventType + resultPayLoadOpen.destinationEmailId + resultPayLoadOpen.sourceIp);
             
             //const parsed = resultPayLoad[0];
             //console.log("parsed : " + (Buffer.from(JSON.stringify(resultPayLoad))).toString('base64'));
             
             
             return{
                 recordId: record.recordId,
                 result: 'Ok',
                 data: (Buffer.from(JSON.stringify(resultPayLoadOpen))).toString('base64'),
             };
             }
         });
         console.log("Output : " + output.data);
         console.log(`Processing completed.  Successful records ${output.length}.`);
         callback(null, { records: output });
     };

     Please note:

     For this blog, we are only filtering out three fields i.e. Eventname, destination_Email, and SourceIP. If you want to store other parameters you can modify your code accordingly. For the list of information that we receive in notifications, you may check out the following document.

     https://docs.aws.amazon.com/ses/latest/DeveloperGuide/event-publishing-retrieving-firehose-examples.html

8. Now, navigate back to your Amazon Kinesis Data Firehose console and choose the newly created Lambda function.
9. Keep the convert record format disabled and click “Next”.
10. In the destination, choose Amazon S3 and select a target Amazon S3 bucket. Create a new bucket if you do not want to use the existing bucket.
11. Enter the following values for Amazon S3 Prefix and Error Prefix. When event data is published.
    • Prefix:
      fhbase/year=!{timestamp:yyyy}/month=!{timestamp:MM}/day=!{timestamp:dd}/hour=!{timestamp:HH}/
    • Error Prefix:
      fherroroutputbase/!{firehose:random-string}/!{firehose:error-output-type}/!{timestamp:yyyy/MM/dd}/
12. You may utilize the above values in the Amazon S3 prefix and error prefix. If you use your own prefixes make sure to accordingly update the target values in AWS Glue which you will see in further process.
    • 
13. Keep the Amazon S3 backup option disabled and click “Next”.
14. On the next page, under the Permissions section, select create a new role. This opens up a new tab and then click “Allow” to create the role.
15. Navigate back to the Amazon Kinesis Data Firehose console and click “Next”.
16. Review the changes and click on “Create delivery stream”.

Configure Amazon SES to publish event data to Kinesis Data Firehose:

1. Navigate to Amazon SES console and select “Email Addresses” from the left side.
2. Click on “Verify a New Email Address” on the top. Enter your email address to which you send a test email.
3. Go to your email inbox and click on the verify link. Navigate back to the Amazon SES console and you will see verified status on the email address provided.
4. Open the Amazon SES console and select Configuration set from the left side.
5. Create a new configuration set. Enter “SES_Firehose_Demo”  as the configuration set name and click “Create”.
6. Choose Kinesis Data Firehose as the destination and provide the following details.
   • Name: OpenClick
   • Event Types: Open and Click
7. In the IAM Role field, select ‘Let SES make a new role’. This allows SES to create a new role and add sufficient permissions for this use case in that role.
8. Click “Save”.

Sending a Test email:

1. Navigate to Amazon SES console, click on “Email Addresses” on the left side.
2. Select your verified email address and click on “Send a Test email”.
3. Make sure you select the raw email format. You may use the following format to send out a test email from the console. Make sure you send out this email to a recipient inbox to which you have the access.

   • X-SES-CONFIGURATION-SET: SES_Firehose_Demo
     X-SES-MESSAGE-TAGS: Email=NULL
     From: test-v[email protected]
     To: [email protected]
     Subject: Test email
     Content-Type: multipart/alternative;
         		boundary="----=_boundary"
     
     ------=_boundary
     Content-Type: text/html; charset=UTF-8
     Content-Transfer-Encoding: 7bit
     This is a test email.
     
     <a href="https://aws.amazon.com/">Amazon Web Services</a>
     ------=_boundary

4. Once the email is received in the recipient’s inbox, open the email and click the link present in the same. This generates a click and open event and send the response back to SES.

Creating Glue Crawler:

1. Navigate to the AWS Glue console, select “crawler” from the left side, and then click on “Add crawler” on the top.
2. Enter the crawler name as “SES_Firehose_Crawler” and click “Next”.
3. Under Crawler source type, select “Data stores” and click “Next”.
4. Select Amazon S3 as the data source and prove the required path. Include the path until the “fhbase” folder.
5. Select “no” under Add another data source section.
6. In the IAM role, select the option to ‘Create an IAM role’. Enter the name as “SES_Firehose-Crawler”. This provides the necessary permissions automatically to the newly created role.
7. In the frequency section, select run on demand and click “Next”. You may choose this value as per your use case.
8. Click on add Database and provide the name as “ses_firehose_glue_db”. Click on create and then click “Next”.
9. Review your Glue crawler setting and click on “Finish”.
10. Run the above-created crawler. This crawls the data from the specified Amazon S3 bucket and create a catalog and table definition.
11. Now navigate to “tables” on the left, and verify a “fhbase” table is created after you run the crawler.

If you want to analyze the data stored until now, you can use Amazon Athena and test the queries. If not, you can move to the Amazon Quicksight directly.

Analyzing the data using Amazon Athena:

1. Open Athena console and select the database, which is created using AWS Glue
2. Click on “setup a query result location in Amazon S3” as shown in the following screenshot.
   • 
3. Navigate to the Amazon S3 bucket created in earlier steps and create a folder called “AthenaQueryResult”. We store our Athena query result in this bucket.
4. Now navigate back to Amazon Athena and select the Amazon S3 bucket with the folder location as shown in the following screenshot and click “Save”.
   • 
5. Run the following query to test the sample output and accordingly modify your SQL query to get the desired output.
   • Select * from “ses_firehose_glue_db”.”fhbase”
     • 
     • 

Note: If you want to track the opened emails by unique Ip addresses then you can modify your SQL query accordingly. This is because every time an email gets opened, you will receive a notification even if the same email was previously opened.

Visualizing the data in Amazon QuickSight dashboards:

1. Now, let’s analyze this data using Amazon Athena via Amazon Quicksight.
2. Log into Amazon Quicksight and choose Manage data, New dataset. Choose Amazon Athena as a new data source.
3. Enter the data source name as “SES-Demo” and click on “Create the data source”.
4. Select your database from the drop-down as “ses_firehose_glue_db” and table “fhbase” that you have created in AWS Glue.
5. And add a custom SQL based on your use case and click on “Confirm query”. Refer to the example below.
6. You can perform ad hoc analysis and modify your query according to your business needs as shown in the following image. Click “Save & Visualize”.
7. You can now visualize your event data on Amazon Quicksight dashboard. You can use various graphs to represent your data. For this demo, the default graph is used and two fields are selected to populate on the graph, as shown below.

Conclusion:

This architecture shows how to track your email sending activity at a granular level. You set up Amazon SES to publish event data to Amazon Kinesis Data Firehose based on fine-grained email characteristics that you define. You can also track several types of email sending events, including sends, deliveries, bounces, complaints, rejections, rendering failures, and delivery delays. This information can be useful for operational and analytical purposes.

To get started with Amazon SES, follow this quick start guide and you can learn more about monitoring sending activity here.

About the Authors

Chirag Oswal is a solutions architect and AR/VR specialist working with the public sector India. He works with AWS customers to help them adopt the cloud operating model on a large scale.

Apoorv Gakhar is a Cloud Support Engineer and an Amazon SES Expert. He is working with AWS to help the customers integrate their applications with various AWS Services.

Additional Resources:

Amazon SES Dedicated IP Pools

Amazon Personalize optimizer using Amazon Pinpoint events

Template Personalization using Amazon Pinpoint