#platform event

[salesforceblog]

Extract, transform, and load (ETL) for Salesforce integration

Extracting data from the source systems. This typically involves data from several source systems, and both relational and non-relational structures.

Transforming the data to fit operational needs, which can also include data quality levels. The transform stage usually applies a series of rules or functions to the extracted data from the source to derive the data for loading into the end target(s).

Loading the data into the target system. The target system can vary widely from database, operational data store, data mart, data warehouse, or other operational systems.

Most mature ETL tools provide a change data capture capability. This capability is where the tool identifies records in the source system that have changed since the last extract, which reduces the amount of record processing.

Salesforce now also supports Change Data Capture which is the publishing of change events which represent changes to Salesforce records. With Change Data Capture, the client or external system receives near-real-time changes of Salesforce records in JSON format. This allows the client or external system to synchronize corresponding records in an external data store.

[salesforceblog]

Replace Future/Queueable jobs with Platform Event

The "Platform Event" can be     publish or subscribe either programmatic(Trigger) or declarative(Process Builder). 

External integration can publish the Platform Event just by creating a record in Salesforce Platform Event object using either SOAP/REST API.

For external application like Java need to have a streaming API Bayeux - CometD protocol setup. 

[salesforceblog]

Salesforce platform event test class example

Sobject[] platEvents = new List<Sobject>(); Test.startTest();     Employee_Event__e ee = new Employee_Event__e(         Employee_Id__c = load.id         ,Event_Type__c = 'Employee Created');     Dept_Event__e de = new Dept_Event__e(         Dept_Id__c = lf.id         ,Event_Type__c = 'Dept Name Changed');     platEvents.add(ee);     platEvents.add(de);     EventBus.publish(platEvents);     Test.getEventBus().deliver(); Test.stopTest();

[salesforceblog]

An ideal template for Platform Event trigger/handler

Trigger

trigger ApprovalRequestEventSubscriber on Approval_Request_Event__e (after insert) {    Set<Id> supplierSpendInsertSet = new Set<Id>();    for(Approval_Request_Event__e evt : Trigger.new){        if(evt.Event_Type__c == 'Supplier Spend Insert'){// Condition 1            //Only one set for each condition         supplierSpendInsertSet.add(evt.Approval_Request_Id__c);        }/*else if(condition){ //Condition 2 //Any other condition }*/    }    if(! supplierSpendInsertSet.isEmpty()){ //only one handler for each set        ApprovalRequestEventSubscribeHandler.handleSupplierSpendInsertSet(supplierSpendInsertSet);    } }

Handler

public class ApprovalRequestEventSubscribeHandler {    public static void handleSupplierSpendInsertSet(Set<Id> supplierSpendInsertSet){     ApprovalRequestEventSubscribeHandler.shareWithCreatedByGroup(supplierSpendInsertSet);        //Sequence any other method(logic) needed    }    public static void shareWithCreatedByGroup(Set<Id> supplierSpendInsertSet){        //do sharing logic here    } }

[salesforceblog]

Fire Platform Events from Batch Apex Classes

Automatic Event Generator Batch Class

public with sharing class BatchLeadConvert implements Database.Batchable<SObject>,Database.RaisesPlatformEvents{

   private final String CONVERTED_STATUS = [SELECT Id, MasterLabel FROM LeadStatus WHERE IsConverted=true LIMIT 1].MasterLabel;

   public Database.QueryLocator start(Database.BatchableContext ctx){        return Database.getQueryLocator([SELECT Id FROM Lead WHERE ConvertedContactId = null]);    }

   public void execute(Database.BatchableContext ctx, List<Lead> records){        List<Database.LeadConvert> leadConverts = new List<Database.LeadConvert>();        for(Lead record:records){            Database.LeadConvert lc = new Database.LeadConvert();            lc.setConvertedStatus(CONVERTED_STATUS);            lc.setLeadId(record.Id);

           leadConverts.add(lc);        }        Database.convertLead(leadConverts, true);    }

   public void finish(Database.BatchableContext ctx){

   } }

Event Subscriber Trigger

trigger BatchApexErrorTrigger on BatchApexErrorEvent (after insert) { List<BatchLeadConvertErrors__c> errorLogList = new List<BatchLeadConvertErrors__c>();    for(BatchApexErrorEvent evt : Trigger.new){     BatchLeadConvertErrors__c errorLog = new BatchLeadConvertErrors__c();        errorLog.AsyncApexJobId__c = evt.AsyncApexJobId;        errorLog.Records__c = evt.JobScope;        errorLog.StackTrace__c = evt.StackTrace;        errorLogList.add(errorLog);    }    insert errorLogList; }

Note : Here  BatchLeadConvertErrors__c is a custom object we used to track the error logs.

[salesforceblog]

Salesforce Change Data Capture (CDC) Events and its test

When you enable  Change Data Capture for a specific Standard Object or a Custom Object Salesforce Automatically create a corresponding Change Event Object for Example :

1. Account -> AccountChangeEvent

2. Employee__c -> Employee__ChangeEvent

If Change Data Capture enabled for for either a Standard or a Custom Object then in case of any DML operation for the same object records Salesforce creates corresponding Change Event record after the completion of the DML asynchronously.

After Insert trigger is also possible on Change Event Records for any asynchronous processing. Underneath Salesforce is implementing the Platform Event concept for even subscribing the event through streaming channel. Here is an example to subscribe to AccountChangeEvent from Workbench.

Channel Name : /data/AccountChangeEvent

Note : You can also test CDC at  https://salesforcelwc.herokuapp.com/

[salesforceblog]

Subscribe to Salesforce Platform Events from Workbench

From Java : https://developer.salesforce.com/docs/atlas.en-us.platform_events.meta/platform_events/code_sample_java_client_intro.htm

Note : You can also test platform event subscription at  https://salesforcelwc.herokuapp.com/

From Workbench :