'use strict';
console.log('Loading function');
var email_type = ["_email.send", "_email.delivered", "_email.rejected", "_email.hardbounce", "_email.softbounce", "_email.complaint", "_email.open", "_email.click", "_email.unsubscribe"];

exports.handler = (event, context, callback) => {
    /* Process the list of records and transform them */
    console.log(event);
    const output = event.records.map( function(record) {
        var new_record = {};
        var ori_data = JSON.parse(Buffer.from(record.data, 'base64').toString());
        new_record.recordId = record.recordId;
        new_record.result = 'Ok';
        console.log(ori_data.event_type);
        new_record.data = {
            "event_type": ori_data.event_type,
            "event_timestamp": ori_data.event_timestamp,
            "arrival_timestamp": ori_data.arrival_timestamp,
            "application_id": ori_data.application.app_id,
            "client_id": ori_data.client.client_id,
            "campaign_activity_id": ori_data.attributes.campaign_activity_id,
            "campaign_id": ori_data.attributes.campaign_id
        };
        if (email_type.includes(ori_data.event_type))
        {
            new_record.data.feedback = ori_data.attributes.feedback;
            new_record.data.destination = ori_data.facets.email_channel.mail_event.mail.destination[0];
            new_record.data.message_send_timestamp = ori_data.facets.email_channel.mail_event.mail.message_send_timestamp;
            new_record.data.subject = ori_data.facets.email_channel.mail_event.mail.common_headers.subject;
        }
        else {
            new_record.data.feedback = ori_data.event_type;
            new_record.data.destination = "none";
            new_record.data.message_send_timestamp = ori_data.arrival_timestamp;
            new_record.data.subject = "none";
        }
        new_record.data = Buffer.from(JSON.stringify(new_record.data)+"\n").toString('base64');
        return new_record;
    });
    
    console.log(output);
    console.log(`Processing completed.  Successful records ${output.length}.`);
    callback(null, { records: output });
};

안녕하세요. {{User.UserAttributes.FirstName}} {{User.UserAttributes.LastName}}님,

Pinpoint 테스트 안내 메일입니다.

선호하는 정보를 클릭하면 맞춤형 서비스를 제공해 드립니다.


1. 메인 (http://www.chosun.com/index.html)
2. 뉴스 (http://news.chosun.com/index.html)
3. 정치 (http://news.chosun.com/politics/index.html)
4. 스포츠 (http://news.chosun.com/sports/index.html)
5. 경제 (http://biz.chosun.com/index.html)
6. 연예 (http://news.chosun.com/ent/index.html)

감사합니다.
----

만약 위 내용을 이메일로 보낼 경우 아래와 같은 형태로 작성할 수 있습니다.
향후 Personalize를 활용하기 위한 예시입니다. (사용자별로 어떤 컨텐츠를 선호하는지 구분하고, 맞춤형서비스를 제공하는 것을 타겟으로 할 경우)

제목: {{User.UserAttributes.LastName}}님 선호하는 정보를 선택해 주세요
code 기준
<p>안녕하세요. {{User.UserAttributes.FirstName}} {{User.UserAttributes.LastName}}님({{User.UserAttributes.Alias}}),</p><p>Pinpoint 테스트 안내 메일입니다.</p><p>선호하는 정보를 클릭하면 맞춤형 서비스를 제공해 드립니다.</p><ol><li><a href="http://www.chosun.com/index.html" target="_blank">메인</a></li><li><a href="http://news.chosun.com/index.html" target="_blank">뉴스</a></li><li><a href="http://news.chosun.com/politics/index.html" target="_blank">정치</a></li><li><a href="http://news.chosun.com/sports/index.html" target="_blank">스포츠</a></li><li><a href="http://biz.chosun.com/index.html" target="_blank">경제</a></li><li><a href="http://news.chosun.com/ent/index.html" target="_blank">연예</a></li></ol><p>감사합니다.</p>

SELECT
  last_activity_by_user.*
FROM 
(
  SELECT
    email_log.destination, email_log.event_type, email_log.event_timestamp, email_log.feedback
  FROM 
  (
    SELECT
      destination, MAX(event_timestamp) AS last_timestamp
    FROM
      pinpoint_log
    GROUP BY
      destination
  ) last_data
  INNER JOIN
    pinpoint_log email_log
  ON
    last_data.destination = email_log.destination AND last_data.last_timestamp = email_log.event_timestamp
) last_activity_by_user
ORDER BY event_timestamp ASC

CREATE OR REPLACE VIEW "email_log_view" AS
SELECT destination, feedback, event_type, event_timestamp FROM "pinpoint"."pinpoint_log" WHERE destination != 'none' ORDER BY event_timestamp ASC;

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "AllowUserToSeeBucketListInTheConsole",
            "Action": [
                "s3:ListAllMyBuckets",
                "s3:GetBucketLocation"
            ],
            "Effect": "Allow",
            "Resource": [
                "arn:aws:s3:::*"
            ]
        },
        {
            "Sid": "AllowRootAndHomeListingOfBucket",
            "Action": [
                "s3:ListBucket"
            ],
            "Effect": "Allow",
            "Resource": [
                "arn:aws:s3:::pinpoint-data-hyouk"
            ],
            "Condition": {
                "StringEquals": {
                    "s3:delimiter": [
                        "/"
                    ],
                    "s3:prefix": [
                        "",
                        "pinpoint_segment/"
                    ]
                }
            }
        },
        {
            "Sid": "AllowListingOfUserFolder",
            "Action": [
                "s3:ListBucket"
            ],
            "Effect": "Allow",
            "Resource": [
                "arn:aws:s3:::pinpoint-data-hyouk"
            ],
            "Condition": {
                "StringLike": {
                    "s3:prefix": [
                        "pinpoint_segment/*"
                    ]
                }
            }
        },
        {
            "Sid": "AllowAllS3ActionsInUserFolder",
            "Action": [
                "s3:*"
            ],
            "Effect": "Allow",
            "Resource": [
                "arn:aws:s3:::pinpoint-data-hyouk/pinpoint_segment/*"
            ]
        }
    ]
}

{
    "Role": {
        "Path": "/",
        "RoleName": "s3ExportRole",
        "RoleId": "AROAIIPCRD2PFUZKC766O",
        "Arn": "arn:aws:iam::501497829891:role/s3ExportRole",
        "CreateDate": "2019-02-18T02:31:02Z",
        "AssumeRolePolicyDocument": {
            "Version": "2012-10-17",
            "Statement": [
                {
                    "Effect": "Allow",
                    "Principal": {
                        "Service": "pinpoint.amazonaws.com"
                    },
                    "Action": "sts:AssumeRole"
                }
            ]
        }
    }
}

$ aws iam create-role --role-name s3ExportRole --assume-role-policy-document file://trustpolicy.json

$ aws pinpoint create-export-job --application-id 3236d7413d154bd6badd940d96a5a043 --export-job-request S3UrlPrefix=s3://pinpoint-data-hyouk/pinpoint_segment/,RoleArn=arn:aws:iam::501497829891:role/s3ExportRole
{
    "ExportJobResponse": {
        "CreationDate": "2019-02-18T03:38:51.081Z",
        "Definition": {
            "RoleArn": "arn:aws:iam::501497829891:role/s3ExportRole",
            "S3UrlPrefix": "s3://pinpoint-data-hyouk/pinpoint_segment/"
        },
        "Id": "ba9a7396829448619862b19a8bf34992",
        "JobStatus": "CREATED",
        "Type": "EXPORT"
    }
}

{"ChannelType":"EMAIL","Address":"kim_hyounsoo@nate.com","EndpointStatus":"ACTIVE","OptOut":"NONE","EffectiveDate":"2019-02-18T00:02:34.876Z","User":{"UserAttributes":{"Favorite":["Music"],"FirstName":["Kim"],"LastName":["HyounsooNate"]}},"ApplicationId":"3236d7413d154bd6badd940d96a5a043","Id":"zzwl/devcx5mobniyoqdorvgjja","CreationDate":"2019-02-18T00:02:34.876Z"}
{"ChannelType":"EMAIL","Address":"hyouk@amazon.com","EndpointStatus":"ACTIVE","OptOut":"NONE","EffectiveDate":"2019-02-18T00:02:34.876Z","User":{"UserAttributes":{"Favorite":["Sports"],"FirstName":["Kim"],"LastName":["HyounsooA"]}},"ApplicationId":"3236d7413d154bd6badd940d96a5a043","Id":"hfqagb8bxtwccbiong1euah9yl4","CreationDate":"2019-02-18T00:02:34.876Z"}
{"ChannelType":"EMAIL","Address":"meelong0@gmail.com","EndpointStatus":"ACTIVE","OptOut":"NONE","EffectiveDate":"2019-02-18T00:02:34.876Z","User":{"UserAttributes":{"Favorite":["Sports"],"FirstName":["Kim"],"LastName":["HyounsooG"]}},"ApplicationId":"3236d7413d154bd6badd940d96a5a043","Id":"r+aodq6fdiv23z3hdososax+gru","CreationDate":"2019-02-18T00:02:34.876Z"}
{"ChannelType":"EMAIL","Address":"meelong0@studydev.com","EndpointStatus":"ACTIVE","OptOut":"NONE","EffectiveDate":"2019-02-18T00:02:34.876Z","User":{"UserAttributes":{"Favorite":["Travel"],"FirstName":["Kim"],"LastName":["HyounsooS"]}},"ApplicationId":"3236d7413d154bd6badd940d96a5a043","Id":"ljvckifoswwnlskvd++i2jicf6y","CreationDate":"2019-02-18T00:02:34.876Z"}
{"ChannelType":"EMAIL","Address":"meelong0@naver.com","EndpointStatus":"ACTIVE","OptOut":"NONE","EffectiveDate":"2019-02-18T00:02:34.876Z","User":{"UserAttributes":{"Favorite":["Travel"],"FirstName":["Kim"],"LastName":["HyounsooNaver"]}},"ApplicationId":"3236d7413d154bd6badd940d96a5a043","Id":"gkkboumyo6yqsodhxuvrtebrkky","CreationDate":"2019-02-18T00:02:34.876Z"}

CREATE OR REPLACE VIEW pinpoint_email_log AS 
SELECT
  "id"
, "address"
, "user"."userattributes"."firstname"
, "user"."userattributes"."lastname"
, "applicationid"
, "campaign_activity_id"
, "channeltype"
, "endpointstatus"
, "event_type"
, "event_timestamp"
, "destination"
, "feedback"
FROM
  pptest.emaillog email_log
LEFT JOIN
  pptest.exports user_info
ON
  email_log.client_id = user_info.id
ORDER BY email_log.event_timestamp ASC, user_info.id ASC

{"event_type":"_campaign.send","event_timestamp":1550717400850,"arrival_timestamp":1550717401085,"event_version":"3.1","application":{"app_id":"0e19ae99d54c40f199483417dcd19d31","sdk":{}},"client":{"client_id":"gkkboumyo6yqsodhxuvrtebrkky"},"device":{"platform":{}},"session":{},"attributes":{"treatment_id":"0","campaign_activity_id":"348241f1c3aa4442bc0887aa65f10372","campaign_id":"43f200c4680540f89b7459c710a1893f","campaign_send_status":"SUCCESS"},"client_context":{"custom":{"endpoint":"{\"ChannelType\":\"EMAIL\",\"EndpointStatus\":\"ACTIVE\",\"OptOut\":\"NONE\",\"EffectiveDate\":\"2019-02-21T02:43:57.103Z\",\"User\":{\"UserAttributes\":{\"Favorite\":[\"Travel\"],\"Alias\":[\"naver\"],\"FirstName\":[\"김\"],\"LastName\":[\"현수5\"]}}}"}},"awsAccountId":"501497829891"}

{"event_type":"_email.delivered","event_timestamp":1550717401726,"arrival_timestamp":1550717400869,"event_version":"3.1","application":{"app_id":"0e19ae99d54c40f199483417dcd19d31","sdk":{}},"client":{},"device":{"platform":{}},"session":{},"attributes":{"feedback":"delivered","treatment_id":"0","campaign_activity_id":"348241f1c3aa4442bc0887aa65f10372","campaign_id":"43f200c4680540f89b7459c710a1893f"},"client_context":{"custom":{"pp:legacy_identifier":"0e19ae99d54c40f199483417dcd19d31"}},"awsAccountId":"501497829891","facets":{"email_channel":{"mail_event":{"mail":{"message_id":"02000000vadbv9o8-q920qecu-ghpa-9fhb-defb-26rqom018d00-000000","message_send_timestamp":1550717400869,"from_address":"meelong0@studydev.com","destination":["hyouk@amazon.com"],"headers_truncated":false,"headers":[{"name":"Date","value":"Thu, 21 Feb 2019 02:50:00 +0000"},{"name":"From","value":"meelong0@studydev.com"},{"name":"To","value":"hyouk@amazon.com"},{"name":"Message-ID","value":"<415151185.7195180.1550717401116.JavaMail.ec2-user@ip-10-0-118-38.ec2.internal>"},{"name":"Subject","value":"현수1님 선호하는 정보를 선택해 주세요"},{"name":"MIME-Version","value":"1.0"},{"name":"Content-Type","value":"multipart/alternative;  boundary=\"----=_Part_7195179_1177699404.1550717401114\""},{"name":"Content-Transfer-Encoding","value":"quoted-printable"}],"common_headers":{"from":"meelong0@studydev.com","date":"Thu, 21 Feb 2019 02:50:00 +0000","to":["hyouk@amazon.com"],"subject":"현수1님 선호하는 정보를 선택해 주세요"}},"delivery":{"smtp_response":"250 ok:  Message 183158971 accepted","reporting_mta":"a8-58.smtp-out.amazonses.com","recipients":["hyouk@amazon.com"],"processing_time_millis":857}}}}}

{"event_type":"_email.open","event_timestamp":1550717500298,"arrival_timestamp":1550717400868,"event_version":"3.1","application":{"app_id":"0e19ae99d54c40f199483417dcd19d31","sdk":{}},"client":{},"device":{"platform":{}},"session":{},"attributes":{"feedback":"opened","treatment_id":"0","campaign_activity_id":"348241f1c3aa4442bc0887aa65f10372","campaign_id":"43f200c4680540f89b7459c710a1893f"},"client_context":{"custom":{"pp:legacy_identifier":"0e19ae99d54c40f199483417dcd19d31"}},"awsAccountId":"501497829891","facets":{"email_channel":{"mail_event":{"mail":{"message_id":"02000000i6hkn91h-kmka1r0d-7dqt-fka4-0jot-st8klfn7l300-000000","message_send_timestamp":1550717400868,"from_address":"meelong0@studydev.com","destination":["meelong0@gmail.com"],"headers_truncated":false,"headers":[{"name":"Date","value":"Thu, 21 Feb 2019 02:50:00 +0000"},{"name":"From","value":"meelong0@studydev.com"},{"name":"To","value":"meelong0@gmail.com"},{"name":"Message-ID","value":"<1506996128.7186845.1550717401046.JavaMail.ec2-user@ip-10-0-162-204.ec2.internal>"},{"name":"Subject","value":"현수2님 선호하는 정보를 선택해 주세요"},{"name":"MIME-Version","value":"1.0"},{"name":"Content-Type","value":"multipart/alternative;  boundary=\"----=_Part_7186844_67699459.1550717401045\""}],"common_headers":{"from":"meelong0@studydev.com","date":"Thu, 21 Feb 2019 02:50:00 +0000","to":["meelong0@gmail.com"],"subject":"현수2님 선호하는 정보를 선택해 주세요"}},"open":{"ip_address":"66.249.82.141","user_agent":"Mozilla/5.0 (Windows NT 5.1; rv:11.0) Gecko Firefox/11.0 (via ggpht.com GoogleImageProxy)"}}}}}

{"event_type":"_email.click","event_timestamp":1550717509949,"arrival_timestamp":1550717400868,"event_version":"3.1","application":{"app_id":"0e19ae99d54c40f199483417dcd19d31","sdk":{}},"client":{},"device":{"platform":{}},"session":{},"attributes":{"feedback":"http://www.chosun.com/index.html","treatment_id":"0","campaign_activity_id":"348241f1c3aa4442bc0887aa65f10372","campaign_id":"43f200c4680540f89b7459c710a1893f"},"client_context":{"custom":{"pp:legacy_identifier":"0e19ae99d54c40f199483417dcd19d31"}},"awsAccountId":"501497829891","facets":{"email_channel":{"mail_event":{"mail":{"message_id":"02000000i6hkn91h-kmka1r0d-7dqt-fka4-0jot-st8klfn7l300-000000","message_send_timestamp":1550717400868,"from_address":"meelong0@studydev.com","destination":["meelong0@gmail.com"],"headers_truncated":false,"headers":[{"name":"Date","value":"Thu, 21 Feb 2019 02:50:00 +0000"},{"name":"From","value":"meelong0@studydev.com"},{"name":"To","value":"meelong0@gmail.com"},{"name":"Message-ID","value":"<1506996128.7186845.1550717401046.JavaMail.ec2-user@ip-10-0-162-204.ec2.internal>"},{"name":"Subject","value":"현수2님 선호하는 정보를 선택해 주세요"},{"name":"MIME-Version","value":"1.0"},{"name":"Content-Type","value":"multipart/alternative;  boundary=\"----=_Part_7186844_67699459.1550717401045\""}],"common_headers":{"from":"meelong0@studydev.com","date":"Thu, 21 Feb 2019 02:50:00 +0000","to":["meelong0@gmail.com"],"subject":"현수2님 선호하는 정보를 선택해 주세요"}},"click":{"ip_address":"114.202.31.81","user_agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/72.0.3626.109 Safari/537.36","link":"http://www.chosun.com/index.html"}}}}}